0

我的编排由 HTTP 消息触发，然后执行以下 SQL 查询（出于安全原因，已更改字段和表名称）：

SELECT Distinct '900' AS 'Type', 
    (DeTeamPATH.PKEY) AS 'Personal_ID', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.TENTLOGON, 121), ' ') 
    AS 'TLG', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.CIV_NAMES01, 121), ' ') 
    AS 'First name', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.CIV_NAMES02, 121), ' ') 
    AS 'Middle name', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.SURNAME, 121), ' ') 
    AS 'Surname', 
    ISNULL(CONVERT(nVarChar(30), UsTeam.STREET01, 121), ' ') 
    AS 'Corporation', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.GENDER, 121), ' ') 
    AS 'Gender', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.LOCAL_ADDRESS01 + ', ' 
    + DeTeam.LOCAL_ADDRESS03, 121), ' ') 
    AS 'Street Address',
    ISNULL(CONVERT(nVarChar(30), DeTeam.LOCAL_ADDRESS04, 121), ' ') 
    AS 'Suburb', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.COUNTRY, 121), ' ') 
    AS 'Country', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.LOCAL_POST, 121), ' ') 
    AS 'Postcode', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.BIRTHDATE, 121), ' ') 
    AS 'Date of Birth', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.EMAIL, 121), ' ') 
    AS 'Email address', 
    ISNULL(CONVERT(nVarChar(30), DeTeam.DOME_PHONE, 121), ' ') 
    AS 'Primary phone', 
    DeTeam.ICEPHONE AS 'Phone_2', 
    ISNULL(CONVERT(nVarChar(30), DeTeamPATH.Person_START, 121), ' ') 
    AS 'Session_start', 
    ISNULL(CONVERT(nVarChar(30), DeTeamPATH.Person_FINISH, 121), ' ') 
    AS 'Session_expiry'
FROM DeTeam

INNER JOIN DeTeamPATH 
    ON DeTeamPATH.PKEY = DeTeam.DeTeamKEY
INNER JOIN Fort 
    ON DeTeamPATH.ROUTEID = Fort.ROUTEID OR DeTeamPATH.STREAM=Fort.ROUTEID
INNER JOIN US_DE_SEM 
    ON US_DE_SEM.US_DE_SEMER = DeTeamPATH.SEM_START 
    OR US_DE_SEM.US_DE_SEMER = DeTeamPATH.SEM_FINISH
INNER JOIN UsTeam 
    ON UsTeam.TeamUS = DeTeamPATH.TeamUS

where DeTeam.TENTLOGON != ' ' and DeTeamPATH.PKEY != ' ' and 
      DeTeam.CIV_NAMES01 != ' ' and DeTeam.CIV_NAMES02 != ' ' and 
      DeTeam.SURNAME != ' ' and UsTeam.STREET01 != ' ' and 
      DeTeam.GENDER != ' ' and DeTeam.COUNTRY != ' ' and 
      DeTeam.TENTLOGON != ' ' and DeTeam.LOCAL_POST != ' ' and 
      DeTeam.BIRTHDATE != ' ' and DeTeam.EMAIL != ' ' and 
      DeTeam.DOME_PHONE != ' ' and DeTeamPATH.Person_START != ' ';

然后它将数据写入一个平面文件（文本文件）并将其放在我的 FTP 服务器上的一个目录中。但是，文本文件只有一行 - 这是 SQL SELECT 查询的一个结果。当我直接在服务器上运行查询时，我得到了大约六个结果。我希望文件包含所有六个结果，但我希望在不久的将来通过该 SELECT 语句获得更多结果，所以我不想限制查询将检索多少结果，因为我希望它获得所有结果.

有人可以帮助我或告诉我我做错了什么吗？如果您需要更多详细信息，请告诉我，我将编辑此问题以包含它们。

4

1 回答 1

0

我有自己问题的答案！

在Write Flat File活动中，Map Inputs 选项卡的From Orchestration部分中的行重复出现，而To Activity部分中的行则不重复出现。所以，要解决这个问题，我必须编辑我的平面文件架构，并更改数据的属性，以便将事件标记为无界。（它之前的 Range 为 1，因此只有 1 行会被放入文本文件中。）我还必须在我的Write Flat File活动中删除所有以前的输入映射，并将From Orchestration中的行映射到To Activity中的数据.

如果我可以这样说，我已经把这个答案放在这里，以防将来有人遇到同样的问题。我发现在 Internet 上找到有使用 WebSphere Cast Iron 经验的人是很困难的……所以如果这对任何人有帮助，我会很高兴！

@DaleM 感谢您的评论和帮助！

于 2013-01-21T02:27:50.387 回答