Tworzenie obiekt docelowy ODBC za pomocą składnika skryptów

Utworzenie połączenia ODBC menedżera, który łączy się z AdventureWorks bazy danych.

Utworzyć tabela docelową, uruchamiając następujące polecenie języka Transact-SQL AdventureWorks bazy danych:

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

Dodać nowy składnik skryptów do powierzchni projektanta przepływ danych i skonfiguruj ją jako obiekt obiekt docelowy.

Łączenie danych wyjściowych "pod prąd" urządzenie źródłowe lub transformacja do obiekt docelowy składnika w SSIS Projektant. (urządzenie źródłowe można połączyć bezpośrednio do obiekt docelowy, bez żadnych przekształceń.) Aby upewnić się, że działa w tym przykładzie, dane wyjściowe składnika "pod prąd" musi zawierać co najmniej AddressID and Miasto kolumnyPerson.Address tabelaAdventureWorks przykładowej bazy danych.

Otwórz Skrypt transformacja edytora.Na Kolumny danych wejściowych strona, zaznacz AddressID and Miasto kolumny.

Na Wejść i wyjść strona, zmienić nazwę elementu danych wejściowych z bardziej opisową nazwę, taką jak MyAddressInput.

Na Menedżer połączeń strona, dodać lub utworzyć Menedżera połączenia ODBC z nazwę opisową, taką jak MyODBCConnectionManager.

Na Skrypt strona, kliknij przycisk Edytowanie skryptu, a następnie wpisz skrypt, pokazany poniżej w ScriptMain Klasa.

Zamknij skrypt środowiska programowania, zamknij Skrypt transformacja edytora, a następnie uruchomić próbki.

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();

    }
}