スクリプト コンポーネントによる ODBC 変換先の作成

AdventureWorks データベースに接続する ODBC 接続マネージャを作成します。

AdventureWorks データベースで次の Transact-SQL コマンドを実行して、変換先テーブルを作成します。

CREATE TABLE [Person].[Address2](
    [AddressID] [int] NOT NULL,
    [City] [nvarchar](30) NOT NULL
)

新しいスクリプト コンポーネントを [データ フロー] デザイナ画面に追加し、変換先として構成します。

SSIS デザイナで、上流変換元の出力または変換の出力を変換先コンポーネントに接続します (変換を介さずに変換元を直接変換先に接続することもできます)。このサンプルを機能させるには、上流コンポーネントの出力に、AdventureWorks サンプル データベースの Person.Address テーブルにある AddressID 列と City 列を最低限含める必要があります。

[スクリプト変換エディタ] を開きます。[入力列] ページで、AddressID 列と City 列を選択します。

[入力および出力] ページで、入力を MyAddressInput などのわかりやすい名前に変更します。

[接続マネージャ] ページで、ODBC 接続マネージャを追加または作成し、MyODBCConnectionManager などのわかりやすい名前を付けます。

[スクリプト] ページで、[スクリプトの編集] をクリックし、以下に示すスクリプトを ScriptMain クラスに入力します。

スクリプト開発環境と [スクリプト変換エディタ] を閉じ、サンプルを実行します。

Imports System.Data.Odbc
...
Public Class ScriptMain
    Inherits UserComponent

    Dim odbcConn As OdbcConnection
    Dim odbcCmd As OdbcCommand
    Dim odbcParam As OdbcParameter

    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)

        Dim connectionString As String
        connectionString = Me.Connections.MyODBCConnectionManager.ConnectionString
        odbcConn = New OdbcConnection(connectionString)
        odbcConn.Open()

    End Sub

    Public Overrides Sub PreExecute()

        odbcCmd = New OdbcCommand("INSERT INTO Person.Address2(AddressID, City) " & _
            "VALUES(?, ?)", odbcConn)
        odbcParam = New OdbcParameter("@addressid", OdbcType.Int)
        odbcCmd.Parameters.Add(odbcParam)
        odbcParam = New OdbcParameter("@city", OdbcType.NVarChar, 30)
        odbcCmd.Parameters.Add(odbcParam)

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        With odbcCmd
            .Parameters("@addressid").Value = Row.AddressID
            .Parameters("@city").Value = Row.City
            .ExecuteNonQuery()
        End With

    End Sub

    Public Overrides Sub ReleaseConnections()

        odbcConn.Close()

    End Sub

End Class

using System.Data.Odbc;
...
public class ScriptMain :
    UserComponent
{
    OdbcConnection odbcConn;
    OdbcCommand odbcCmd;
    OdbcParameter odbcParam;

    public override void AcquireConnections(object Transaction)
    {

        string connectionString;
        connectionString = this.Connections.MyODBCConnectionManager.ConnectionString;
        odbcConn = new OdbcConnection(connectionString);
        odbcConn.Open();

    }

    public override void PreExecute()
    {

        odbcCmd = new OdbcCommand("INSERT INTO Person.Address2(AddressID, City) " +
            "VALUES(?, ?)", odbcConn);
        odbcParam = new OdbcParameter("@addressid", OdbcType.Int);
        odbcCmd.Parameters.Add(odbcParam);
        odbcParam = new OdbcParameter("@city", OdbcType.NVarChar, 30);
        odbcCmd.Parameters.Add(odbcParam);

    }

    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        {
            odbcCmd.Parameters["@addressid"].Value = Row.AddressID;
            odbcCmd.Parameters["@city"].Value = Row.City;
            odbcCmd.ExecuteNonQuery();
        }

    }

    public override void ReleaseConnections()
    {

        odbcConn.Close();

    }
}