5

这是原始查询，使用ado.net源和使用源内指定的 .net providers\odbc 数据提供程序可以正常工作。

SELECT a.FA_CLNT_ID, a.FA_ACCT_NM, a.ACCT_E_DT, a.POL_PER_CURR_DT, a.POL_PER_NEXT_DT, a.FA_ACCT_NUM, a.GRP_SALES_OFFC_CD, a.ACCT_C_DT   
FROM  gyv2M.DDM_ACCT_STRUC a   
INNER JOIN  
(SELECT max(DDM_ACCT_STRUC_TP) as   DDM_ACCT_STRUC_TP, FA_CLNT_ID 
 FROM gyv2M.DDM_ACCT_STRUC  
 WHERE FA_DM_ROW_DT <= '6/30/2011' AND DM_ROW_E_DT <= '6/30/2011'
 GROUP BY  FA_CLNT_ID) b 
 ON a.DDM_ACCT_STRUC_TP = b.DDM_ACCT_STRUC_TP AND a.FA_CLNT_ID = b.FA_CLNT_ID AND FA_DM_ROW_DT <= '6/30/2011' AND a.DM_ROW_E_DT <= '6/30/2011'

但我需要让它自动化，以便 DATE 从 sql server 中的表中获取值。我创建了一个变量来存储该日期值，但我想使用该变量作为参数传递给上述查询。不幸的是，我没有找到数据访问模式：来自 ado.net 源中变量的 sql 命令。我搜索了一些其他网站，发现我们可以使用表达式生成器使用一些表达式。rt 点击 preperties ..> 表达式 ..> etc.. 成功评估了表达式。表达式如下所示，但我在那里感到震惊。接下来是什么 ？如何在 ado.net source 中将评估的表达式作为源命令传递？请帮忙。

SELECT a.FA_CLNT_ID, a.FA_ACCT_NM, a.ACCT_E_DT, a.POL_PER_CURR_DT, a.POL_PER_NEXT_DT, a.FA_ACCT_NUM, a.GRP_SALES_OFFC_CD, a.ACCT_C_DT   
FROM  gyv2M.DDM_ACCT_STRUC a   
INNER JOIN  
(SELECT max(DDM_ACCT_STRUC_TP) as   DDM_ACCT_STRUC_TP, FA_CLNT_ID 
 FROM gyv2M.DDM_ACCT_STRUC  
 WHERE FA_DM_ROW_DT <=  '@[User::RepDate]'  AND DM_ROW_E_DT <=  '@[User::RepDate]'
 GROUP BY  FA_CLNT_ID) b 
 ON a.DDM_ACCT_STRUC_TP = b.DDM_ACCT_STRUC_TP AND a.FA_CLNT_ID = b.FA_CLNT_ID AND FA_DM_ROW_DT <=  '@[User::RepDate]'  AND a.DM_ROW_E_DT <=  '@[User::RepDate]'

更新

你好，

非常感谢您的回复。正如您所指定的，我创建了一个用户变量 user:RepDate，其中包含 datetime 和一个执行 sql 任务，该任务将 datetime 分配给该变量 RepDate。而且是的，我能够评估表达式，并且能够看到在 ado.net souce sql 命令模式下构建的查询。这是查询：

SELECT a.FA_CLNT_ID, a.FA_ACCT_NM, a.ACCT_E_DT, a.POL_PER_CURR_DT, a.POL_PER_NEXT_DT, a.FA_ACCT_NUM, a.GRP_SALES_OFFC_CD, a.ACCT_C_DT   
FROM  gyv2M.DDM_ACCT_STRUC a   
INNER JOIN  
(SELECT max(DDM_ACCT_STRUC_TP) as   DDM_ACCT_STRUC_TP, FA_CLNT_ID 
 FROM gyv2M.DDM_ACCT_STRUC  
 WHERE FA_DM_ROW_DT <= @[User::RepDate]  AND DM_ROW_E_DT <=  @[User::RepDate] 
 GROUP BY  FA_CLNT_ID) b 
 ON a.DDM_ACCT_STRUC_TP = b.DDM_ACCT_STRUC_TP AND a.FA_CLNT_ID = b.FA_CLNT_ID AND FA_DM_ROW_DT <=  @[User::RepDate] AND a.DM_ROW_E_DT <=  @[User::RepDate]

但我收到下面给出的以下错误。我认为这是因为内部查询需要我在原始查询中指定的日期格式'mm/dd/yyyy'..但是我们从用户变量中提供日期时间。您能告诉我如何使用内置函数将用户变量的日期时间格式转换为指定格式吗？我试过 DT_Date 但没有运气。

Error at Data Flow Task 4 [ADO NET Source [1]]: The component "ADO NET Source" (1) was unable to retrieve column information for the SQL command. The following error occurred: ERROR [42601] [IBM][CLI Driver][DB2] SQL0104N  An unexpected token "[" was found following "".  Expected tokens may include:  "CONCAT || / MICROSECONDS MICROSECOND SECONDS SECOND MINUTES".  SQLSTATE=42601
ADDITIONAL INFORMATION:

Pipeline component has returned HRESULT error code 0xC02020FF from a method call. (Microsoft.SqlServer.DTSPipelineWrap)
BUTTONS:
OK

***更新2***

标题：Microsoft Visual Studio

数据流任务 [ADO NET 源 [1]] 出错：组件“ADO NET 源”(1) 无法检索 SQL 命令的列信息。发生了以下错误：错误 [22007] [IBM][CLI Driver][DB2] SQL0180N 日期时间值的字符串表示的语法不正确。SQLSTATE=22007

附加信息：

管道组件已从方法调用返回 HRESULT 错误代码 0xC02020FF。(Microsoft.SqlServer.DTSPipelineWrap)

纽扣：

好的

4

2 回答 2

8

您可以使用以下步骤：

  1. 在 ADO.NET 源中使用您的工作查询。[您无法映射 ADO.NET 源的参数]
  2. 选择您的Dataflow并单击Properties。
  3. 在属性窗格中，查找名为“Expressions”的属性。展开它并单击“...”图标以打开 Property Expressions Editor（下面的屏幕截图）。为您的数据源选择属性SqlCommand并使用表达式构建器使用 SSIS 变量（在您的情况下为日期时间变量）准备查询。

ADO.NET 查询准备

在您的表达式构建器中尝试此操作 - 请注意，您的变量必须是字符串，如果不是，您可以使用(DT_WSTR,30)它来转换它。由于您使用的是日期，因此您的 SQL 将需要处理字符串格式的日期，即to_date()在 Oracle 中使用。

 "SELECT a.FA_CLNT_ID, a.FA_ACCT_NM, a.ACCT_E_DT, a.POL_PER_CURR_DT, a.POL_PER_NEXT_DT, a.FA_ACCT_NUM, a.GRP_SALES_OFFC_CD, a.ACCT_C_DT   
FROM  gyv2M.DDM_ACCT_STRUC a   
INNER JOIN  
(SELECT max(DDM_ACCT_STRUC_TP) as   DDM_ACCT_STRUC_TP, FA_CLNT_ID 
 FROM gyv2M.DDM_ACCT_STRUC 
WHERE FA_DM_ROW_DT <= '"+ (DT_WSTR,30)@[User::RepDate] +"'  AND DM_ROW_E_DT <= '"+ (DT_WSTR,30)@[User::RepDate] +"' 
 GROUP BY  FA_CLNT_ID) b 
 ON a.DDM_ACCT_STRUC_TP = b.DDM_ACCT_STRUC_TP AND a.FA_CLNT_ID = b.FA_CLNT_ID AND FA_DM_ROW_DT <= '" +(DT_WSTR,30)@[User::RepDate] +"' AND a.DM_ROW_E_DT <='"+(DT_WSTR,30)@[User::RepDate]+"'"

希望这可以帮助！

于 2012-11-09T05:49:26.847 回答
0

在你的表达式生成器中试试这个，

 "SELECT a.FA_CLNT_ID, a.FA_ACCT_NM, a.ACCT_E_DT, a.POL_PER_CURR_DT, a.POL_PER_NEXT_DT, a.FA_ACCT_NUM, a.GRP_SALES_OFFC_CD, a.ACCT_C_DT   
FROM  gyv2M.DDM_ACCT_STRUC a   
INNER JOIN  
(SELECT max(DDM_ACCT_STRUC_TP) as   DDM_ACCT_STRUC_TP, FA_CLNT_ID 
 FROM gyv2M.DDM_ACCT_STRUC 
WHERE FA_DM_ROW_DT <= '"+ (DT_WSTR,30)@[User::RepDate] +"'  AND DM_ROW_E_DT <= '"+ (DT_WSTR,30)@[User::RepDate] +"' 
 GROUP BY  FA_CLNT_ID) b 
 ON a.DDM_ACCT_STRUC_TP = b.DDM_ACCT_STRUC_TP AND a.FA_CLNT_ID = b.FA_CLNT_ID AND FA_DM_ROW_DT <= '" +(DT_WSTR,30)@[User::RepDate] +"' AND a.DM_ROW_E_DT <='"+(DT_WSTR,30)@[User::RepDate]+"'"

希望这有效！

于 2012-11-14T07:43:36.977 回答