ローカル パッケージの出力の読み込み
クライアント アプリケーションは、ADO.NET を使用して SQL Server 変換先に出力が保存された場合、または System.IO 名前空間のクラスを使用してフラット ファイル変換先に出力が保存された場合に、Integration Services パッケージの出力を読み取ることができます。ただし、メモリから直接、パッケージの出力を読み取ることもできます。その際、データを保持するための中間手段を必要としません。このソリューションの重要な点は、System.Data 名前空間からの IDbConnection、IDbCommand、および IDbDataParameter の各インターフェイスを特別に実装した Microsoft.SqlServer.Dts.DtsClient 名前空間です。既定では、アセンブリ Microsoft.SqlServer.Dts.DtsClient.dll は、%ProgramFiles%\Microsoft SQL Server\100\DTS\Binn にインストールされています。
.gif "注意") 注意 |
|---|
このトピックで説明されている手順では、データ フロー タスクおよび親オブジェクトの 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 ユーティリティ」を参照してください。次に、この接続文字列を使用して接続を開きます。dtexecui ユーティリティを使用しても、必要な接続文字列を視覚的に作成できます。
注意このサンプル コードは、/FILE <path and filename> 構文を使用してファイル システムからパッケージを読み込む方法を示していますが、/SQL <package name> 構文を使用して MSDB データベースからパッケージを読み込んだり、/DTS \<folder name>\<package name> 構文を使用して Integration Services パッケージ ストアからパッケージを読み込むこともできます。
前に作成した DtsConnection を使用する DtsClient.DtsCommand という種類のオブジェクトを作成し、その CommandText プロパティに、パッケージ内の DataReader 変換先の名前を設定します。次に、コマンド オブジェクトの ExecuteReader メソッドを呼び出して、パッケージの結果を新しい DataReader に読み込みます。
必要に応じて、DtsCommand オブジェクトで DtsDataParameter オブジェクトのコレクションを使用して、パッケージに定義された変数に値を渡すことによって、パッケージの出力を間接的にパラメータ化できます。パッケージ内では、これらの変数をクエリ パラメータとして、または式で使用して、DataReader 変換先に返される結果に影響を与えることができます。クライアント アプリケーションから DtsDataParameter オブジェクトとこれらの変数を使用するには、あらかじめ DtsClient 名前空間でパッケージに変数を定義しておく必要があります ([変数] ウィンドウの [変数列の選択] ツール バー ボタンをクリックすると、[名前空間] 列が表示されます)。クライアント コードで、DtsDataParameter を DtsCommand の Parameters コレクションに追加する場合、変数名からの DtsClient 名前空間参照を省略してください。次に例を示します。
command.Parameters.Add(new DtsDataParameter("MyVariable", 1));出力データの行をループするのに必要なだけ、DataReader の Read メソッドを繰り返し呼び出します。クライアント アプリケーションで、データを使用するか、または後で使用するために保存します。
.gif "重要な注意事項")
重要DataReader のこの実装の Read メソッドは、データの最後の行が読み取られた後にもう一度 true を返します。このため、Read が true を返している間、DataReader をループする通常のコードを使用することが難しくなります。予定した行数を読み取った後に Read メソッドの追加の最終呼び出しがないと、コードで DataReader または接続を閉じようとした場合に、ハンドルされていない例外が発生します。しかし、コードがこのループの最後の反復でデータを読み取ろうとした場合、Read がまだ true を返しているのに最後の行に到達すると、ハンドルされていない ApplicationException が発生し、"SSIS IDataReader は結果セットの末尾に到達しました。" というメッセージが表示されます。この動作は、その他の DataReader 実装の動作とは異なります。したがって、Read が true を返している間にループを使用して DataReader 内の行を最後まで読み取るようにするには、最後の Read メソッドの正常な呼び出しで予想されるこの ApplicationException をキャッチ、テスト、および破棄するコードを記述する必要があります。あるいは、予定の行数があらかじめわかっている場合は、行を処理してから、DataReader および接続を閉じる前にもう一度 Read メソッドを呼び出します。
DtsCommand オブジェクトの Dispose メソッドを呼び出します。DtsDataParameter オブジェクトを使用している場合、これは特に重要です。
DataReader と接続オブジェクトを閉じます。
例
次の例では、1 つの集計値を計算してその値を DataReader 変換先に保存するパッケージを実行します。次に、この値を DataReader から読み取って、Windows フォーム上のテキスト ボックスに表示します。
パッケージの出力をクライアント アプリケーションに読み込む場合は、パラメータを使用する必要はありません。パラメータを使用しない場合は、DtsClient 名前空間で変数を使用する必要はありません。DtsDataParameter オブジェクトを使用するコードも省略できます。
テスト パッケージを作成するには
新しい Integration Services パッケージを作成します。サンプル コードでは、パッケージの名前として "DtsClientWParamPkg.dtsx" が使用されています。
DtsClient 名前空間に文字列型の変数を追加します。サンプル コードでは、変数の名前として Country が使用されています ([変数] ウィンドウの [変数列の選択] ツール バー ボタンをクリックすると、[名前空間] 列が表示されます)。
AdventureWorks サンプル データベースに接続する OLE DB 接続マネージャを追加します。
データ フロー タスクをパッケージに追加し、[データ フロー] デザイン画面に切り替えます。
OLE DB ソースをデータ フローに追加し、前に作成した OLE DB 接続マネージャを使用するように構成して、次の SQL コマンドを実行します。
SELECT * FROM Sales.vIndividualCustomer WHERE CountryRegionName = ?[クエリ パラメータの設定] ダイアログ ボックスで [パラメータ] をクリックし、クエリで単一の入力パラメータ Parameter0 を DtsClient::Country 変数にマップします。
データ フローに集計変換を追加し、OLE DB ソースの出力を変換に接続します。集計変換エディタを開いて、すべての入力列 (*) で "すべてのカウント" 操作が実行され、集計された値が CustomerCount の別名で出力されるように構成します。
データ フローに DataReader 変換先を追加し、集計変換の出力を DataReader 変換先に接続します。サンプル コードでは、DataReader の名前として "DataReaderDest" が使用されています。変換先に対して使用可能な単一の入力列 CustomerCount を選択します。
パッケージを保存します。次に作成されたテスト アプリケーションではパッケージが実行され、その出力がメモリから直接取得されます。
テスト アプリケーションを作成するには
新しい Windows フォーム アプリケーションを作成します。
Microsoft.SqlServer.Dts.DtsClient 名前空間への参照を追加します。これを行うには、%ProgramFiles%\Microsoft SQL Server\100\DTS\Binn にある同じ名前のアセンブリを参照します。
次のサンプル コードをコピーし、フォームのコード モジュールに貼り付けます。
パッケージを実行するために dtexec.exe で必要なコマンド ライン パラメータを格納するため、必要に応じて変数 dtexecArgs の値を変更します。サンプル コードは、ファイル システムからパッケージを読み込みます。
パッケージ内の DataReader 変換先の名前を格納するため、必要に応じて変数 dataReaderName の値を変更します。
ボタンとテキスト ボックスをフォームに追加します。サンプル コードでは、ボタンの名前に 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;
}
}
}
|
.gif "Integration Services のアイコン (小)")
最新の Integration Services の入手