以编程方式加载和运行本地包
适用范围：
SQL Server Azure 数据工厂中的 SSIS Integration Runtime
可以使用运行包中介绍的方法，根据需要或在预定时间运行 Integration Services 包。 但是，也可以只用几行代码，从自定义应用程序（如 Windows 窗体应用程序、控制台应用程序、ASP.NET Web 窗体或 Web 服务、Windows 服务）运行包。
本主题讨论：
以编程方式加载包
以编程方式运行包
本主题中用于加载和运行包的所有方法都需要引用 Microsoft.SqlServer.ManagedDTS 程序集。 在新项目中添加引用之后，使用 using 或 Imports 语句导入 Microsoft.SqlServer.Dts.Runtime 命名空间。
以编程方式加载包
若要以编程方式在本地计算机中加载包，无论包是本地存储还是远程存储，都可以调用以下方法之一：
| 存储位置 | 调用的方法 |
|---|---|
| 文件 | LoadPackage |
| SSIS 包存储区 | LoadFromDtsServer |
| SQL Server | LoadFromSqlServer |
重要
Application 类中用于处理 SSIS 包存储区的方法只支持“.”、localhost 或本地服务器的服务器名称。 不能使用“(local)”。
以编程方式运行包
以托管代码方式开发在本地计算机上运行包的自定义应用程序需要采用以下方式。 此处总结的步骤在随后的控制台应用程序示例中演示。
以编程方式在本地计算机中运行包
启动 Visual Studio 开发环境，以您首选的开发语言创建新的应用程序。 本示例使用的是控制台应用程序；但您也可以从 Windows 窗体应用程序、ASP.NET Web 窗体或 Web 服务或者 Windows 服务运行包。
在“项目”菜单上，单击“添加引用”，向 Microsoft.SqlServer.ManagedDTS.dll 添加一个引用。 单击“确定”。
使用 Visual Basic Imports 语句或 C# using 语句来导入 Microsoft.SqlServer.Dts.Runtime 命名空间。
在主例程中添加以下代码。 完成的控制台应用程序应类似于下面的示例。
注意
该示例代码演示如何使用 LoadPackage 方法从文件系统加载包。 也可以通过调用 LoadFromSqlServer 方法，从 MSDB 数据库加载包，或者通过调用 LoadFromDtsServer 方法，从 Integration Services 包存储区加载包。
运行该项目。 示例代码执行随 SQL Server 示例安装的 CalculatedColumns 示例包。 包执行的结果显示在控制台窗口中。
代码示例
Imports Microsoft.SqlServer.Dts.Runtime
Module Module1
Sub Main()
Dim pkgLocation As String
Dim pkg As New Package
Dim app As New Application
Dim pkgResults As DTSExecResult
pkgLocation = _
"C:\Program Files\Microsoft SQL Server\100\Samples\Integration Services" & _
"\Package Samples\CalculatedColumns Sample\CalculatedColumns\CalculatedColumns.dtsx"
pkg = app.LoadPackage(pkgLocation, Nothing)
pkgResults = pkg.Execute()
Console.WriteLine(pkgResults.ToString())
Console.ReadKey()
End Sub
End Module
using System;
using Microsoft.SqlServer.Dts.Runtime;
namespace RunFromClientAppCS
{
class Program
{
static void Main(string[] args)
{
string pkgLocation;
Package pkg;
Application app;
DTSExecResult pkgResults;
pkgLocation =
@"C:\Program Files\Microsoft SQL Server\100\Samples\Integration Services" +
@"\Package Samples\CalculatedColumns Sample\CalculatedColumns\CalculatedColumns.dtsx";
app = new Application();
pkg = app.LoadPackage(pkgLocation, null);
pkgResults = pkg.Execute();
Console.WriteLine(pkgResults.ToString());
Console.ReadKey();
}
}
}
从运行中的包捕获事件
当您按照上面的示例所示以编程方式运行包时，还可以捕获包执行时发生的错误及其他事件。 为此，请添加从 DefaultEvents 类继承的类，并在加载包时传递对该类的引用。 下面的示例仅捕获 OnError 事件，但还有其他很多事件可以通过 DefaultEvents 类捕获。
以编程方式在本地计算机中运行包同时捕获包事件
按照前面示例中的步骤为此示例创建项目。
在主例程中添加以下代码。 完成的控制台应用程序应类似于下面的示例。
运行该项目。 示例代码执行随 SQL Server 示例安装的 CalculatedColumns 示例包。 包执行的结果显示在控制台窗口中，同时显示发生的所有错误。
代码示例
Imports Microsoft.SqlServer.Dts.Runtime
Module Module1
Sub Main()
Dim pkgLocation As String
Dim pkg As New Package
Dim app As New Application
Dim pkgResults As DTSExecResult
Dim eventListener As New EventListener()
pkgLocation = _
"C:\Program Files\Microsoft SQL Server\100\Samples\Integration Services" & _
"\Package Samples\CalculatedColumns Sample\CalculatedColumns\CalculatedColumns.dtsx"
pkg = app.LoadPackage(pkgLocation, eventListener)
pkgResults = pkg.Execute(Nothing, Nothing, eventListener, Nothing, Nothing)
Console.WriteLine(pkgResults.ToString())
Console.ReadKey()
End Sub
End Module
Class EventListener
Inherits DefaultEvents
Public Overrides Function OnError(ByVal source As Microsoft.SqlServer.Dts.Runtime.DtsObject, _
ByVal errorCode As Integer, ByVal subComponent As String, ByVal description As String, _
ByVal helpFile As String, ByVal helpContext As Integer, _
ByVal idofInterfaceWithError As String) As Boolean
' Add application-specific diagnostics here.
Console.WriteLine("Error in {0}/{1} : {2}", source, subComponent, description)
Return False
End Function
End Class
using System;
using Microsoft.SqlServer.Dts.Runtime;
namespace RunFromClientAppWithEventsCS
{
class MyEventListener : DefaultEvents
{
public override bool OnError(DtsObject source, int errorCode, string subComponent,
string description, string helpFile, int helpContext, string idofInterfaceWithError)
{
// Add application-specific diagnostics here.
Console.WriteLine("Error in {0}/{1} : {2}", source, subComponent, description);
return false;
}
}
class Program
{
static void Main(string[] args)
{
string pkgLocation;
Package pkg;
Application app;
DTSExecResult pkgResults;
MyEventListener eventListener = new MyEventListener();
pkgLocation =
@"C:\Program Files\Microsoft SQL Server\100\Samples\Integration Services" +
@"\Package Samples\CalculatedColumns Sample\CalculatedColumns\CalculatedColumns.dtsx";
app = new Application();
pkg = app.LoadPackage(pkgLocation, eventListener);
pkgResults = pkg.Execute(null, null, eventListener, null, null);
Console.WriteLine(pkgResults.ToString());
Console.ReadKey();
}
}
}