Bir ODBC hedef komut dosyası bileşeni ile oluşturma

Yöneticisine bağlanan bir ODBC bağlantısı oluşturma AdventureWorks veritabanıdır.

Aşağıdaki Transact-SQL komutu çalıştırarak hedef tablo oluşturmak AdventureWorks veritabanı:

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

Yeni bir komut dosyası bileşeni için veri akışı Tasarımcısı yüzey ekleyin ve hedef olarak yapılandırın.

Hedef bileşeninde Geliş yönündeki çok kaynak ya da dönüştürme çıkışını bağlanmak için SSIS Tasarımcı. (Bir kaynaktan bir hedef herhangi bir dönüştürme olmaksızın doğrudan bağlanabilirsiniz.) Bu örnek çalıştığından emin olmak için , Geliş yönündeki bileşeni çıkışını en azından içermelidirAddressID and Şehir sütunlarındanPerson.Address tablosuAdventureWorks örnek veritabanı.

Açık Komut dosyası dönüştürme Düzenleyicisi.Üzerinde Giriş bir sütun sayfa, seçin.AddressID and Şehir sütunlar.

Üzerinde Giriş ve çıkışlarını sayfa, giriş gibi daha tanımlayıcı bir adla yeniden adlandırın.MyAddressInput.

Üzerinde Bağlantı Yöneticisi sayfa ekleme veya ODBC Bağlantı Yöneticisi gibi bir açıklayıcı adla oluşturun.MyODBCConnectionManager.

Üzerinde Komut dosyası sayfasında, tıklatın.Komut dosyası Düzenleve aşağıda gösterilen kodu girin...ScriptMain sınıf.

Komut dosyası geliştirme ortamı, Kapat'ı kapatmak Komut dosyası dönüştürme Düzenleyicisive sonra da örnek çalıştırın.

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

    }
}