5

我正在使用 BIML 构建多个 SSIS 包，并且我必须在日期间隔之间从 OLE DB 源中检索数据。这是要生成包的xml：

<Dataflow Name="DFT Insert into <#=TableName#>">
    <Transformations>
        <OleDbSource Name="Retreive from Source (<#=TableName#>)" ConnectionName="AS400">
            <DirectInput>
                SELECT s.* 
                FROM <#=TableSchema#>.<#=TableName#> s
                WHERE s.date &gt; ? AND s.date &lt;= ?
            </DirectInput>
            <Parameters>
                <Parameter Name="0" VariableName="User.StartDate"/>
                <Parameter Name="1" VariableName="User.MiddleDate"/>
            </Parameters>
        </OleDbSource>

        <OleDbDestination Name="Insert into Destination (<#=TableName#>)" ConnectionName="DB2Mirror" KeepNulls="true" CheckConstraints="false">
            <ExternalTableOutput Table="[<#=TableSchema#>].[<#=TableName#>]" />
        </OleDbDestination>   
    </Transformations>
</Dataflow>

这种结构通常可以工作，因为我已经尝试过了，但使用的是 ID（整数）而不是日期（字符串）。我在尝试生成包时收到的错误如下：

Could not execute Query on Connection AS400
OleDbCommand.Prepare method requires all variable length parameters to have an explicitly set non-zero Size.

我知道我可以创建一个 ssis 变量并将查询中的日期连接为表达式，但我想坚持<DirectInput>使用<VariableInput>

附加信息

变量中的日期时间（对不起，我忘了提到它是日期时间，但我认为它没有太大变化）格式是正确的：yyyy-mm-dd hh:mm:ss。我很确定格式没有问题，因为我尝试创建一个变量作为表达式，像这样连接日期：<Variable Name="Query" DataType="String" EvaluateAsExpression="true">&quot;SELECT * FROM table WHERE col &gt; '&quot; + @[User::StartDate] + &quot;'&quot;</Variable>并且它有效。我忘了提到的一件事可能很重要，源 dbms 是一个 db2

4

1 回答 1

3

给定下表定义

CREATE TABLE dbo.so_42623962
(
    RowSk int NOT NULL
,   [Date] date
);

这是我最小的、可行的 Biml，它使用带有 OLE DB 源的参数

<Biml xmlns="http://schemas.varigence.com/biml.xsd">
<Connections>
    <OleDbConnection Name="tempdb" ConnectionString="Data Source=localhost\dev2016;Initial Catalog=tempdb;Provider=SQLNCLI11.0;Integrated Security=SSPI;"/>
</Connections>
<Packages>
    <Package Name="so_42623962" >
        <Variables>
            <Variable Name="StartDate" DataType="String">2017-01-01</Variable>
            <Variable Name="MiddleDate" DataType="String">2017-01-01</Variable>
        </Variables>
        <Tasks>
            <Dataflow Name="DFT Demo">
                <Transformations>
                    <OleDbSource Name="SRC Query" ConnectionName="tempdb">
                        <DirectInput><![CDATA[SELECT * 
                        FROM dbo.so_42623962 AS X 
                        WHERE X.[Date] > ? AND X.[Date] <= ? ;]]></DirectInput>
                        <Parameters>
                            <Parameter Name="0" VariableName="User.StartDate" />
                            <Parameter Name="1" VariableName="User.MiddleDate" />
                        </Parameters>
                    </OleDbSource>
                    <DerivedColumns Name="DER Placeholder" />
                </Transformations>
            </Dataflow>
        </Tasks>
    </Package>
</Packages>
</Biml>

这将构建一个包就好了。如果我取出需要转义大于/小于字符的 CDATA，它仍然有效

        <Dataflow Name="DFT Escaped">
            <Transformations>
                <OleDbSource Name="SRC Query" ConnectionName="tempdb">
                    <DirectInput>SELECT * 
                    FROM dbo.so_42623962 AS X 
                    WHERE X.[Date] &gt; ? AND X.[Date] &lt;= ?;</DirectInput>
                    <Parameters>
                        <Parameter Name="0" VariableName="User.StartDate" />
                        <Parameter Name="1" VariableName="User.MiddleDate" />
                    </Parameters>
                </OleDbSource>
                <DerivedColumns Name="DER Placeholder" />
            </Transformations>
        </Dataflow>

如果我不用Date大括号包裹列，它仍然有效

        <Dataflow Name="DFT Escapedx2">
            <Transformations>
                <OleDbSource Name="SRC Query" ConnectionName="tempdb">
                    <DirectInput>SELECT * 
                    FROM dbo.so_42623962 AS X 
                    WHERE X.Date &gt; ? AND X.Date &lt;= ?;</DirectInput>
                    <Parameters>
                        <Parameter Name="0" VariableName="User.StartDate" />
                        <Parameter Name="1" VariableName="User.MiddleDate" />
                    </Parameters>
                </OleDbSource>
                <DerivedColumns Name="DER Placeholder" />
            </Transformations>
        </Dataflow>

那么我的工作演示和你的演示之间还剩下什么？更容易解决的是日期的值（开始/中间日期）。我使用 yyyy-mm-dd aka ccyy-mm-dd 往往被我使用的系统更普遍地理解，但您可以尝试 yyyymmdd 的 ISO 标准。

更难处理的是您的连接管理器被命名为 AS400。事实上，这敲响了警钟，因为我不得不处理他们使用朱利安日期的另一个问题的“奇怪”日期，但我看到 AS400 使用类似“奇怪”​​的CYMD格式，你必须用将 yyyy-mm-dd 日期转换为 CYMD 的派生列。应该不难，但考虑到可能的日期格式的丰富性，我不会冒险猜测。

于 2017-03-10T04:23:27.367 回答