[アーティクル]
09/28/2010

プログラムによるタスクの追加

ランタイムエンジン内の次の種類のオブジェクトに、タスクを追加できます。

これらのクラスはコンテナと見なされ、すべて Executables プロパティを継承します。コンテナにはタスクのコレクションを含めることができます。これらのタスクは、コンテナの実行中にランタイムによって処理される実行可能オブジェクトです。コレクション内のオブジェクトの実行順序は、コンテナ内の各タスクに設定された PrecedenceConstraint によって決まります。優先順位制約によって、コレクション内の Executable の成功、失敗、または完了に基づく、実行の分岐ができます。

各コンテナには、個々の Executable オブジェクトを含んでいる Executables コレクションがあります。各実行可能タスクは Executable..::..Execute メソッドおよび Executable..::..Validate メソッドを継承して実装します。これらの 2 つのメソッドはランタイムエンジンによって呼び出され、各 Executable を処理します。

パッケージにタスクを追加するには、Executables の既存のコレクションを持つコンテナが必要です。ほとんどの場合、コレクションに追加するタスクはパッケージです。新しいタスクの実行可能ファイルをそのコンテナのコレクションに追加するには、Executables..::..Add メソッドを呼び出します。このメソッドには単一の文字列パラメータがあり、CLSID、PROGID、STOCK モニカ、または、追加するタスクの TaskInfo..::..CreationName が格納されます。

タスク名

名前または ID でタスクを指定できますが、Executables..::..Add メソッドで最もよく使用されるパラメータは STOCK モニカです。STOCK モニカによって識別される実行可能ファイルにタスクを追加するには、次の構文を使用します。

      Executable exec = package.Executables.Add("STOCK:BulkInsertTask");

    Dim exec As Executable = package.Executables.Add("STOCK:BulkInsertTask")

次の一覧は、STOCK モニカの後に使用する各タスクの名前を示したものです。

ActiveXScriptTask
BulkInsertTask
ExecuteProcessTask
ExecutePackageTask
Exec80PackageTask
FileSystemTask
FTPTask
MSMQTask
PipelineTask
ScriptTask
SendMailTask
SQLTask
TransferStoredProceduresTask
TransferLoginsTask
TransferErrorMessagesTask
TransferJobsTask
TransferObjectsTask
TransferDatabaseTask
WebServiceTask
WmiDataReaderTask
WmiEventWatcherTask
XMLTask

明示的な構文を使用する場合、または追加しようとするタスクに STOCK モニカがない場合は、長い名前を使用して実行可能ファイルにタスクを追加できます。この構文では、タスクのバージョン番号も指定する必要があります。

      Executable exec = package.Executables.Add(
        "Microsoft.SqlServer.Dts.Tasks.ScriptTask.ScriptTask, " +
        "Microsoft.SqlServer.ScriptTask, Version=10.0.000.0, " +
        "Culture=neutral, PublicKeyToken=89845dcd8080cc91");

    Dim exec As Executable = package.Executables.Add( _
      "Microsoft.SqlServer.Dts.Tasks.ScriptTask.ScriptTask, " & _
      "Microsoft.SqlServer.ScriptTask, Version=10.0.000.0, " & _
      "Culture=neutral, PublicKeyToken=89845dcd8080cc91")

タスクのバージョンを指定しないで、次の例のようにクラスの AssemblyQualifiedName プロパティを使用して、プログラムによってタスクの長い名前を取得できます。この例では、Microsoft.SqlServer.SQLTask アセンブリへの参照が必要です。

using Microsoft.SqlServer.Dts.Tasks.ExecuteSQLTask;
...
      Executable exec = package.Executables.Add(
        typeof(Microsoft.SqlServer.Dts.Tasks.ExecuteSQLTask.ExecuteSQLTask).AssemblyQualifiedName);

Imports Microsoft.SqlServer.Dts.Tasks.ExecuteSQLTask
...
    Dim exec As Executable = package.Executables.Add( _
      GetType(Microsoft.SqlServer.Dts.Tasks.ExecuteSQLTask.ExecuteSQLTask).AssemblyQualifiedName)

次のコード例は、新しいパッケージから Executables コレクションを作成し、STOCK モニカを使用してファイルシステムタスクと一括挿入タスクをコレクションに追加する方法を示しています。この例では、Microsoft.SqlServer.FileSystemTask および Microsoft.SqlServer.BulkInsertTask アセンブリへの参照が必要です。

using System;
using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Tasks.FileSystemTask;
using Microsoft.SqlServer.Dts.Tasks.BulkInsertTask;

namespace Microsoft.SqlServer.Dts.Samples
{
  class Program
  {
    static void Main(string[] args)
    {
      Package p = new Package();
      // Add a File System task to the package.
      Executable exec1 = p.Executables.Add("STOCK:FileSystemTask");
      TaskHost thFileSystemTask = exec1 as TaskHost;
      // Add a Bulk Insert task to the package.
      Executable exec2 = p.Executables.Add("STOCK:BulkInsertTask");
      TaskHost thBulkInsertTask = exec2 as TaskHost;

      // Iterate through the package Executables collection.
      Executables pExecs = p.Executables;
      foreach (Executable pExec in pExecs)
      {
        TaskHost taskHost = (TaskHost)pExec;
        Console.WriteLine("Type {0}", taskHost.InnerObject.ToString());
      }
      Console.Read();
    }
  }
}

Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Dts.Tasks.FileSystemTask
Imports Microsoft.SqlServer.Dts.Tasks.BulkInsertTask

Module Module1

  Sub Main()

    Dim p As Package = New Package()
    ' Add a File System task to the package.
    Dim exec1 As Executable = p.Executables.Add("STOCK:FileSystemTask")
    Dim thFileSystemTask As TaskHost = CType(exec1, TaskHost)
    ' Add a Bulk Insert task to the package.
    Dim exec2 As Executable = p.Executables.Add("STOCK:BulkInsertTask")
    Dim thBulkInsertTask As TaskHost = CType(exec2, TaskHost)

    ' Iterate through the package Executables collection.
    Dim pExecs As Executables = p.Executables
    Dim pExec As Executable
    For Each pExec In pExecs
      Dim taskHost As TaskHost = CType(pExec, TaskHost)
      Console.WriteLine("Type {0}", taskHost.InnerObject.ToString())
    Next
    Console.Read()

  End Sub

End Module

サンプルの出力 :

Type Microsoft.SqlServer.Dts.Tasks.FileSystemTask.FileSystemTask

Type Microsoft.SqlServer.Dts.Tasks.BulkInsertTask.BulkInsertTask

TaskHost コンテナ

TaskHost クラスは、グラフィカルユーザーインターフェイスには出現しないコンテナですが、プログラムを作成する際には非常に重要です。このクラスは、すべてのタスク用のラッパーです。Add メソッドを Executable オブジェクトとして使用してパッケージに追加されたタスクは、TaskHost オブジェクトとしてキャストできます。タスクが TaskHost としてキャストされる場合は、タスクの追加プロパティおよびメソッドを使用できます。また、タスク自体には、TaskHost の InnerObject プロパティをとおしてアクセスできます。必要に応じて、タスクを TaskHost オブジェクトとして保持し、Properties コレクションをとおしてタスクのプロパティを使用することができます。Properties を使用する利点は、汎用性の高いコードを記述できることです。タスク固有のコードが必要な場合は、タスクを適切なオブジェクトにキャストする必要があります。

次のコード例は、BulkInsertTask を含む TaskHost、thBulkInsertTask を BulkInsertTask オブジェクトにキャストする方法を示しています。

      BulkInsertTask myTask = thBulkInsertTask.InnerObject as BulkInsertTask;

    Dim myTask As BulkInsertTask = CType(thBulkInsertTask.InnerObject, BulkInsertTask)

次のコード例は、実行可能ファイルを TaskHost にキャストし、次に InnerObject プロパティを使用して、ホストに含まれている実行可能ファイルの種類を特定する方法を示しています。

using System;
using Microsoft.SqlServer.Dts.Runtime;
using Microsoft.SqlServer.Dts.Tasks.FileSystemTask;
using Microsoft.SqlServer.Dts.Tasks.BulkInsertTask;

namespace Microsoft.SqlServer.Dts.Samples
{
  class Program
  {
    static void Main(string[] args)
    {
      Package p = new Package();
      // Add a File System task to the package.
      Executable exec1 = p.Executables.Add("STOCK:FileSystemTask");
      TaskHost thFileSystemTask1 = exec1 as TaskHost;
      // Add a Bulk Insert task to the package.
      Executable exec2 = p.Executables.Add("STOCK:BulkInsertTask");
      TaskHost thFileSystemTask2 = exec2 as TaskHost;

      // Iterate through the package Executables collection.
      Executables pExecs = p.Executables;
      foreach (Executable pExec in pExecs)
      {
        TaskHost taskHost = (TaskHost)pExec;
        if (taskHost.InnerObject is Microsoft.SqlServer.Dts.Tasks.FileSystemTask.FileSystemTask)
        {
          // Do work with FileSystemTask here.
          Console.WriteLine("Found task of type {0}", taskHost.InnerObject.ToString());
        }
        else if (taskHost.InnerObject is Microsoft.SqlServer.Dts.Tasks.BulkInsertTask.BulkInsertTask)
        {
          // Do work with BulkInsertTask here.
          Console.WriteLine("Found task of type {0}", taskHost.InnerObject.ToString());
        }
        // Add additional statements to check InnerObject, if desired.
      }
      Console.Read();
    }
  }
}

Imports Microsoft.SqlServer.Dts.Runtime
Imports Microsoft.SqlServer.Dts.Tasks.FileSystemTask
Imports Microsoft.SqlServer.Dts.Tasks.BulkInsertTask

Module Module1

  Sub Main()

    Dim p As Package = New Package()
    ' Add a File System task to the package.
    Dim exec1 As Executable = p.Executables.Add("STOCK:FileSystemTask")
    Dim thFileSystemTask1 As TaskHost = CType(exec1, TaskHost)
    ' Add a Bulk Insert task to the package.
    Dim exec2 As Executable = p.Executables.Add("STOCK:BulkInsertTask")
    Dim thFileSystemTask2 As TaskHost = CType(exec2, TaskHost)

    ' Iterate through the package Executables collection.
    Dim pExecs As Executables = p.Executables
    Dim pExec As Executable
    For Each pExec In pExecs
      Dim taskHost As TaskHost = CType(pExec, TaskHost)
      If TypeOf taskHost.InnerObject Is Microsoft.SqlServer.Dts.Tasks.FileSystemTask.FileSystemTask Then
        ' Do work with FileSystemTask here.
        Console.WriteLine("Found task of type {0}", taskHost.InnerObject.ToString())
      ElseIf TypeOf taskHost.InnerObject Is Microsoft.SqlServer.Dts.Tasks.BulkInsertTask.BulkInsertTask Then
        ' Do work with BulkInsertTask here.
        Console.WriteLine("Found task of type {0}", taskHost.InnerObject.ToString())
      End If
      ' Add additional statements to check InnerObject, if desired.
    Next
    Console.Read()

  End Sub

End Module

サンプル出力 :

Found task of type Microsoft.SqlServer.Dts.Tasks.FileSystemTask.FileSystemTask

Found task of type Microsoft.SqlServer.Dts.Tasks.BulkInsertTask.BulkInsertTask

Executables..::..Add ステートメントは、新しく作成された Executable オブジェクトから TaskHost オブジェクトにキャストされる実行可能ファイルを返します。

新しいオブジェクトでプロパティを設定したり、メソッドを呼び出したりする場合、次の 2 つのオプションがあります。

TaskHost の Properties コレクションを使用します。たとえば、オブジェクトからプロパティを取得するには、th.Properties["propertyname"].GetValue(th)) を使用します。プロパティを設定するには、th.Properties["propertyname"].SetValue(th, <value>); を使用します。
TaskHost の InnerObject をタスクのクラスにキャストします。たとえば、一括挿入タスクが Executable としてパッケージに追加され、その後 TaskHost にキャストされた後で、このタスクを BulkInsertTask にキャストするには、BulkInsertTask myTask = th.InnerObject as BulkInsertTask; を使用します。

タスク固有のクラスにキャストせずに TaskHost クラスをコード内で使用する場合、次の利点があります。

TaskHost Properties プロバイダで、コードのアセンブリへの参照が不要です。
コンパイル時にタスクの名前を認識する必要がないため、あらゆるタスクに対応できる汎用のルーチンをコーディングできます。このような汎用ルーチンには、タスク名を引数として受け取るメソッドが含まれます。このメソッドコードはすべてのタスクで動作します。これは、テストコードを記述するのに適したメソッドです。

TaskHost からタスク固有のクラスにキャストする場合は、次の利点があります。

Visual Studio プロジェクトからステートメントの完了が提供されます (IntelliSense)。
コードの実行速度が向上します。
タスク固有のオブジェクトを使用すると、事前バインドおよび結果の最適化が有効になります。事前バインドおよび遅延バインドの詳細については、「Visual Basic 言語の概念」の「事前バインドと遅延バインド」を参照してください。

次のコード例は、タスクコードの再利用の概念について、詳細を示しています。このコード例では、タスクを同等のクラスにキャストせず、代わりに実行可能ファイルを TaskHost にキャストしてから、Properties を使用してすべてのタスクに対する汎用コードを記述する方法を示しています。

using System;
using Microsoft.SqlServer.Dts.Runtime;

namespace Microsoft.SqlServer.Dts.Samples
{
  class Program
  {
    static void Main(string[] args)
    {
      Package package = new Package();

      string[] tasks = { "STOCK:SQLTask", "STOCK:ScriptTask", 
        "STOCK:ExecuteProcessTask", "STOCK:PipelineTask", 
        "STOCK:FTPTask", "STOCK:SendMailTask", "STOCK:MSMQTask" };

      foreach (string s in tasks)
      {
        TaskHost taskhost = package.Executables.Add(s) as TaskHost;
        DtsProperties props = taskhost.Properties;
        Console.WriteLine("Enumerating properties on " + taskhost.Name);
        Console.WriteLine(" TaskHost.InnerObject is " + taskhost.InnerObject.ToString());
        Console.WriteLine();

        foreach (DtsProperty prop in props)
        {
          Console.WriteLine("Properties for " + prop.Name);
          Console.WriteLine("Name : " + prop.Name);
          Console.WriteLine("Type : " + prop.Type.ToString());
          Console.WriteLine("Readable : " + prop.Get.ToString());
          Console.WriteLine("Writable : " + prop.Set.ToString());
          Console.WriteLine();
        }
      }
      Console.Read();
    }
  }
}

Imports Microsoft.SqlServer.Dts.Runtime

Module Module1

  Sub Main()

    Dim package As Package = New Package()

    Dim tasks() As String = New String() {"STOCK:SQLTask", "STOCK:ScriptTask", _
              "STOCK:ExecuteProcessTask", "STOCK:PipelineTask", _
              "STOCK:FTPTask", "STOCK:SendMailTask", "STOCK:MSMQTask"}

    For Each s As String In tasks

      Dim taskhost As TaskHost = CType(package.Executables.Add(s), TaskHost)
      Dim props As DtsProperties = taskhost.Properties
      Console.WriteLine("Enumerating properties on " & taskhost.Name)
      Console.WriteLine(" TaskHost.InnerObject is " & taskhost.InnerObject.ToString())
      Console.WriteLine()

      For Each prop As DtsProperty In props
        Console.WriteLine("Properties for " + prop.Name)
        Console.WriteLine(" Name : " + prop.Name)
        Console.WriteLine(" Type : " + prop.Type.ToString())
        Console.WriteLine(" Readable : " + prop.Get.ToString())
        Console.WriteLine(" Writable : " + prop.Set.ToString())
        Console.WriteLine()
      Next

    Next
    Console.Read()

  End Sub

End Module

最新の Integration Services の入手

マイクロソフトが提供する最新のダウンロード、アーティクル、サンプル、ビデオ、およびコミュニティで選択されたソリューションについては、MSDN または TechNet の Integration Services のページを参照してください。

これらの更新が自動で通知されるようにするには、ページの RSS フィードを購読します。

次の方法で共有

プログラムによるタスクの追加

タスク名

TaskHost コンテナ

関連項目

概念

その他のリソース