Execute SQL Task 参数和变量的映射

Execute SQL Task能够执行带参数的SQL查询语句或存储过程（SP），通过SSIS的变量（Variable）对参数赋值。对于不同的Connection Manager，在Task中需要使用不同的符号（Parameter marker）来标记一个参数，并且在Parameter Mapping中设置参数名字（Parameter Name）。

在Execute SQL Task Editor中，设置Parameter Mapping的界面如下：

Variable Name：变量的名字，变量的作用域分为User和System，使用 :: 来引用作用域中的变量
Direction：参数的方向，分为输入参数（Input），输出参数（Output）和返回值（Returnvalue）
Data Type：参数的Data Type，必须和变量（Variable）的数据类型相兼容
Parameter Name：参数名字，不同的Connection Manager，其值不同，对于OLEDB Connection Manager，使用0，1，2等数值表示第一个，第二个参数，第三个参数等。
Parameter Size：默认值是-1，表示让SSIS确定参数的长度。如果参数的数据类型是变长的（varchar或varbinary），必须设置参数的长度，为参数值分配足够长度的空间。

在Parameter Mapping中，Parameter Marker和Name受到Connection Type的影响，如下表：

Connection type	Parameter marker	Parameter name	Example SQL command
ADO	?	Param1, Param2, …	SELECT FirstName, LastName, Title FROM Person.Contact WHERE ContactID = ?
ADO.NET	@<parameter name>	@<parameter name>	SELECT FirstName, LastName, Title FROM Person.Contact WHERE ContactID = @parmContactID
ODBC	?	1, 2, 3, …	SELECT FirstName, LastName, Title FROM Person.Contact WHERE ContactID = ?
EXCEL and OLE DB	?	0, 1, 2, 3, …	SELECT FirstName, LastName, Title FROM Person.Contact WHERE ContactID = ?

1，执行SQL查询语句

楼主在实际开发中，最常用的Connection Type是OLEDB，设置Task的ConnectionType为OLE DB，在SQLStatement属性中使用 ? 来标记一个参数，? 叫做参数标记（Parameter Marker）。

select ID,c1
from dbo.dt_test
where c1=?

使用SSIS 变量（Variable）为参数赋值，Parameter Name必须是0，1，2等数字

2，执行SP，设置参数的方向

使用Execute SQL Task执行SP时，参数映射的Direction属性使用Input，Output和Returnvalue 分别表示：输入参数，输出参数和SP的返回值

declare @return_value int
declare @output_var int
declare @input_var int
set @input_var=1exec @return_value=dbo.usp_test @para1=@input_var, @para2= @output_var output;

使用OLEDB Connection Manager，使用 ? 表示一个参数，如图

在Parameter Mapping Tab中设置参数映射：

第一个参数是SP的返回值，Direction 选择 Returnvalue，Parameter Name 是 0；
第二个参数是SP的输入参数，Direction 选择 Input，Parameter Name 是 1；
第三个参数是SP的输出参数，Direction 选择 Output，Parameter Name 是 2；

3，设置参数的Data Type

楼主整理的参数的Data Type和TSQL 数据类型的映射关系

3.1，数值类型

BYTE：映射 SSIS 的 DBTYPE_UI1，映射 TSQL 的 TinyInt
SHORT：映射 SSIS 的 DBTYPE_I2，映射 TSQL 的 smallint
LONG：映射 SSIS 的 DBType_I8，映射 TSQL 的 bigint
FLOAT：映射 TSQL 的 float(24)
DOUBLE：映射 TSQL 的 float(53)
DECIMAL：映射 TSQL 的 decimal

3.2，日期/时间类型

DATE：映射TSQL的DateTime2(7)

注意：如果SSIS 变量的Data Type是DateTime，那么参数的Data Type应使用 DATE，但是，数据类型为DateTime的变量，只保留到秒，毫秒位是0.

3.3，字符串类型

VARCHAR：映射TSQL的varchar
NVARCHAR：映射TSQL的nvarchar

4，在做增量更新时，发现导入的数据量少于源数据

楼主在调试SSIS Package时，使用ModifiedDate字段做增量更新，Package中使用Execute SQL Task获取数据源中DataUpdateTime字段的最大值，并将该值赋值给变量:User::MaxLastModifiedDate，Package运行成功，但是导入的数据量少于源数据；通过测试，发现DateTime类型的变量，其时间部分只保留到秒，而不会计算毫秒部分，导致导入的数据量少于源数据。

调试SSIS Package，下断点（breakpoint），打开Watch Tab，查看变量运行时的值：

这两个变量定义为DateTime类型，经过测试，如果变量定义成String类型，实际上是一样的，时间只会精确到秒：

然而，数据源中的DataUpdateTime使用的Datetime2(7)，精度十分高：

发生这种问题的根源是 SSIS的数据类型和SQL Server的数据类型不是一一对应的，存在差异。为了避免这种问题，可以对MaxLastModifiedDate 变量加1s。

在使用OLEDB数据源导入数据时，使用如下的Where条件，就能把所有的数据都导入到DW中。

where DataUpdatedOn > ?    --MinLastModifiedDate
and DataUpdatedOn<=?        --MaxLastModifiedDate

注意：SSIS 变量的日期和时间类型只保留到秒，而数据库中的时间可以保留到毫秒位（1-7位毫秒数）

Execute SQL Task 参数和变量的映射相关推荐

SSIS Execute SQL Task assign output 的两种方法
按一个SQL语句select count(1) from tmp为例. 可以用: 1.存储过程+Output参数 2.SQL语句+result set ------------------------ ...
SSIS Execute SQL Task 用法
Execute Sql Task组件是一个非常有用的Control Flow Task,可以直接执行SQL语句,例如,可以执行数据更新命令(update,delete,insert),也可以执行sel ...
System variables, logging and the Execute SQL Task...(zz)
原文地址http://sqljunkies.com/WebLog/knight_reign/archive/2005/02/27/8187.aspx Here's something useful y ...
Execute Process Task
Execute Process Task 用于在Control Flow中执行应用程序,常用于对加密的数据进行解压. 1,RequireFullFileName 属性:是否需要完整的文件路径,如果在F ...
mysql jdbc 绑定变量_jdbc测试mysql数据库sql预解析(绑定变量)
jdbc测试mysql数据库sql预解析(绑定变量) 用习惯了oracle,学习mysql,想测试一下mysql绑定变量的效果.以前看网上介绍大部份都说mysql没有sql共享池的概念,所以也不存在s ...
python写sql语句_python3将变量写入SQL语句的实现方式
试了一下python操作数据库,准备将前端传回来的用户名和密码写入表中试了半天不会把变量加在在sql语句里面网上搜索了一下,要用元组来传递多个参数sql = "insert into u ...
【Java调试】通过SqlSessionFactory类对象获取mapper文件内的动态SQL在执行时的完整SQL及参数（2种使用方法+测试Demo及结果）
1. 问题最近开发新功能,调试 mapper.xml 里的SQL,遇到了极其痛苦的事情: 没有 p6spy SQL无法输出到工作台. mapper 接口没有实现 MyBatis 的 BaseMapp ...
kettle mysql 参数_kettle参数、变量详细讲解
kettle参数.变量详细讲解 kettle 3.2 以前的版本里只有 variable 和 argument,kettle 3.2 中,又引入了 parameter 概念:variable 即env ...
Mongo DB教程及SQL与Mongo DB查询的映射
目录介绍在机器上设置Mongo DB 启动Mongo DB 下载RoboMongo MongoDB术语 MongoDB的要点查询时间到了 MongoDB函数 MongoDB中的自动递增ID(SQ ...

Execute SQL Task 参数和变量的映射

Execute SQL Task 参数和变量的映射相关推荐

最新文章

热门文章