加载本地包的输出

项目
03/09/2017

使用 ADO.NET 将输出保存到 SQL Server 目标，或使用 System.IO 命名空间中的类将输出保存到平面文件目标时，客户端应用程序即可读取 Integration Services 包的输出。但是，客户端应用程序也可以直接从内存读取包的输出，而无需中间步骤来持久化这些数据。此解决方案的关键是Microsoft.SqlServer.Dts.DtsClient命名空间，该命名空间包含 System.Data 命名空间中的 IDbDataParameter IDbCommand接口和 IDbDataParameter 接口的专用实现IDbConnection。默认情况下，程序集 Microsoft.SqlServer.Dts.DtsClient.dll 安装在 %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn 中。

注意

本主题介绍的过程要求数据流任务以及所有父对象的 DelayValidation 属性均设置为其默认值 False。

说明

本过程说明如何使用托管代码开发客户端应用程序，该应用程序使用 DataReader 目标直接从内存加载包的输出。此处总结的步骤在随后的代码示例中演示。

将数据包输出加载到客户端应用程序中

在包中，配置 DataReader 目标，以接收要读入到客户端应用程序中的输出。使用说明性的名称为 DataReader 目标命名，因为您稍后将在客户端应用程序中使用此名称。请记录 DataReader 目标的名称。
在开发项目中，通过查找程序集 Microsoft.SqlServer.Dts.DtsClient.dll 来设置对命名空间的引用Microsoft.SqlServer.Dts.DtsClient。默认情况下，此程序集安装在 C:\Program Files\Microsoft SQL Server\100\DTS\Binn 中。使用 C# Using 或 Visual Basic Imports 语句将命名空间导入代码。
在代码中，使用连接字符串创建一个对象DtsClient.DtsConnection，其中包含运行包所需的命令行参数dtexec.exe。有关详细信息，请参阅 dtexec Utility。然后，使用此连接字符串打开连接。还可以使用 dtexecui 实用工具直观地创建所需的连接字符串。

备注

该示例代码演示如何使用 /FILE <path and filename> 语法从文件系统加载包。但您也可以使用 /SQL <package name> 语法从 MSDB 数据库加载包，或者使用 /DTS \<folder name>\<package name> 语法从 Integration Services 包存储区加载包。
创建类型为 DtsClient.DtsCommand 的对象，该对象使用先前创建的 DtsConnection，并将该对象的 CommandText 属性设置为包中 DataReader 目标的名称。然后，调用命令对象的 ExecuteReader 方法以将包结果加载到新的 DataReader 中。
还可以通过对 DtsDataParameter 对象使用 DtsCommand 对象的集合来间接参数化包的输出，以将值传递给在包中定义的变量。在包中，您可以使用这些变量作为查询参数或在表达式中使用这些变量以影响返回给 DataReader 目标的结果。必须先在 DtsClient 命名空间的包中定义这些变量，然后才能将其与客户端应用程序中的DtsDataParameter对象一起使用。（可能需要单击在“变量”窗口中选择“变量列”工具栏按钮以显示Namespace列。在客户端代码中，将 a DtsDataParameter 添加到集合DtsCommand中Parameters时，请省略变量名称中的 DtsClient 命名空间引用。例如：
```
command.Parameters.Add(new DtsDataParameter("MyVariable", 1));
```
根据需要重复调用 DataReader 的 Read 方法以遍历输出数据的各行。使用这些数据，或将这些数据保存在客户端应用程序，以供将来使用。

重要

读取最后一行数据后，此 DataReader 实现的 Read 方法将再返回一次 true。因此在 Read 返回 true 时很难使用遍历 DataReader 的常规代码。如果您的代码在读取预期行数后尝试关闭 DataReader 或连接，而不对 Read 方法进行附加的最终调用时，该代码将引发未处理的异常。但是，如果代码尝试通过循环读取此最终迭代的数据，当仍然返回true但最后一行已传递时Read，代码将引发未经处理ApplicationException的消息“SSIS IDataReader 已超过结果集的末尾”。此行为与其他 DataReader 实现的行为不同。因此，使用循环读取 DataReader 中的各行，而 Read 返回 true 时，您需要针对上次成功调用 ApplicationException 方法编写代码以捕获、测试和放弃此预期的 Read。或者，如果您事先知道应读取的行数，则可以处理这些行，然后在关闭 DataReader 和连接之前再调用一次 Read 方法。
调用 Dispose 对象的 DtsCommand 方法。如果已使用任何 DtsDataParameter 对象，这样做尤其重要。
关闭 DataReader 和连接对象。

示例

下面的示例将运行一个包，用于计算单个聚合值并将该值保存到 DataReader 目标，然后从 DataReader 读取此值，并在 Windows 窗体的文本框中显示该值。

在将包的输出加载到客户端应用程序时不一定要使用参数。如果不想使用参数，则可以省略 DtsClient 命名空间中的变量的使用，并省略使用该DtsDataParameter对象的代码。

创建测试包

创建新的 Integration Services 包。示例代码使用“DtsClientWParamPkg.dtsx”作为包的名称。
在 DtsClient 命名空间中添加类型为 String 的变量。示例代码使用 Country 作为该变量的名称。（可能需要单击“变量”窗口中的“选择变量列”工具栏按钮才会显示“命名空间”列。）
添加连接到 AdventureWorks2012 示例数据库的 OLE DB 连接管理器。
向包添加数据流任务，并切换到数据流设计图面。
向数据流添加 OLE DB 源，并将其配置为使用之前创建的 OLE DB 连接管理器以及下面的 SQL 命令：
```
SELECT * FROM Sales.vIndividualCustomer WHERE CountryRegionName = ?
```
单击“Parameters设置查询参数”对话框中，将查询中的单个输入参数 Parameter0 映射到 DtsClient：：Country 变量。
向数据流添加聚合转换，并将 OLE DB 源的输出连接到该转换。打开“聚合转换编辑器”并将其配置为对所有输入列执行“全部计数”操作，并使用 alias CustomerCount 输出聚合值。
向数据流添加 DataReader 目标，并将聚合转换的输出连接到 DataReader 目标。示例代码使用“DataReaderDest”作为 DataReader 的名称。为目标选择单个可用输入列 CustomerCount。
保存包。接下来要创建的测试应用程序将运行该包并直接从内存检索其输出。

创建测试应用程序

创建新的 Windows 窗体应用程序。
通过在 %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn 中浏览到同名程序集来添加对命名空间的引用Microsoft.SqlServer.Dts.DtsClient。
复制以下示例代码并将其粘贴到窗体的代码模块中。
根据需要修改变量的值dtexecArgs，使其包含运行包dtexec.exe所需的命令行参数。示例代码从文件系统加载包。
根据需要修改变量的值 dataReaderName ，使其包含包中 DataReader 目标的名称。
在窗体中放入一个按钮和一个文本框。示例代码用作 btnRun 按钮的名称，并 txtResults 用作文本框的名称。
运行该应用程序并单击按钮。在短暂运行包后，您应能够看到在窗体的文本框中显示由包计算的聚合值（Canada 的客户计数）。

代码示例

Imports System.Data
Imports Microsoft.SqlServer.Dts.DtsClient

Public Class Form1

  Private Sub btnRun_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles btnRun.Click

    Dim dtexecArgs As String
    Dim dataReaderName As String
    Dim countryName As String

    Dim dtsConnection As DtsConnection
    Dim dtsCommand As DtsCommand
    Dim dtsDataReader As IDataReader
    Dim dtsParameter As DtsDataParameter

    Windows.Forms.Cursor.Current = Cursors.WaitCursor

    dtexecArgs = "/FILE ""C:\...\DtsClientWParamPkg.dtsx"""
    dataReaderName = "DataReaderDest"
    countryName = "Canada"

    dtsConnection = New DtsConnection()
    With dtsConnection
      .ConnectionString = dtexecArgs
      .Open()
    End With

    dtsCommand = New DtsCommand(dtsConnection)
    dtsCommand.CommandText = dataReaderName

    dtsParameter = New DtsDataParameter("Country", DbType.String)
    dtsParameter.Direction = ParameterDirection.Input
    dtsCommand.Parameters.Add(dtsParameter)

    dtsParameter.Value = countryName

    dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.Default)

    With dtsDataReader
      .Read()
      txtResults.Text = .GetInt32(0).ToString("N0")
    End With

    'After reaching the end of data rows,
    ' call the Read method one more time.
    Try
      dtsDataReader.Read()
    Catch ex As Exception
      MessageBox.Show("Exception on final call to Read method:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception on final call to Read method", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    ' The following method is a best practice, and is
    '  required when using DtsDataParameter objects.
    dtsCommand.Dispose()

    Try
      dtsDataReader.Close()
    Catch ex As Exception
      MessageBox.Show("Exception closing DataReader:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception closing DataReader", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    Try
      dtsConnection.Close()
    Catch ex As Exception
      MessageBox.Show("Exception closing connection:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception closing connection", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    Windows.Forms.Cursor.Current = Cursors.Default

  End Sub

End Class

using System;
using System.Windows.Forms;
using System.Data;
using Microsoft.SqlServer.Dts.DtsClient;

namespace DtsClientWParamCS
{
  public partial class Form1 : Form
  {
    public Form1()
    {
      InitializeComponent();
      this.btnRun.Click += new System.EventHandler(this.btnRun_Click);
    }

    private void btnRun_Click(object sender, EventArgs e)
    {
      string dtexecArgs;
      string dataReaderName;
      string countryName;

      DtsConnection dtsConnection;
      DtsCommand dtsCommand;
      IDataReader dtsDataReader;
      DtsDataParameter dtsParameter;

      Cursor.Current = Cursors.WaitCursor;

      dtexecArgs = @"/FILE ""C:\...\DtsClientWParamPkg.dtsx""";
      dataReaderName = "DataReaderDest";
      countryName = "Canada";

      dtsConnection = new DtsConnection();
      {
        dtsConnection.ConnectionString = dtexecArgs;
        dtsConnection.Open();
      }

      dtsCommand = new DtsCommand(dtsConnection);
      dtsCommand.CommandText = dataReaderName;

      dtsParameter = new DtsDataParameter("Country", DbType.String);
      dtsParameter.Direction = ParameterDirection.Input;
      dtsCommand.Parameters.Add(dtsParameter);

      dtsParameter.Value = countryName;

      dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.Default);

      {
        dtsDataReader.Read();
        txtResults.Text = dtsDataReader.GetInt32(0).ToString("N0");
      }

      //After reaching the end of data rows,
      // call the Read method one more time.
      try
      {
        dtsDataReader.Read();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception on final call to Read method:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception on final call to Read method", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      // The following method is a best practice, and is
      //  required when using DtsDataParameter objects.
      dtsCommand.Dispose();

      try
      {
        dtsDataReader.Close();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception closing DataReader:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception closing DataReader", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      try
      {
        dtsConnection.Close();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception closing connection:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception closing connection", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      Cursor.Current = Cursors.Default;

    }
  }
}

Integration Services 图标（小型） 随时了解 Integration Services
有关来自Microsoft的最新下载、文章、示例和视频，以及来自社区的所选解决方案，请访问 MSDN 上的 Integration Services 页面：

访问 MSDN 上的 Integration Services 页

若要获得有关这些更新的自动通知，请订阅该页上提供的 RSS 源。

另请参阅

了解本地和远程执行加载与以编程方式加载和运行远程包之间的差异

通过