ODBC 데이터 대상 구현하기
Imports System Imports System.Data Imports System.Math Imports Microsoft.SqlServer.Dts.Pipeline.Wrapper Imports Microsoft.SqlServer.Dts.Runtime.Wrapper 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.연결.ConnectionString odbcConn = New OdbcConnection(connectionString) odbcConn.Open()
End Sub
Public Overrides Sub PreExecute()
odbcCmd = New OdbcCommand("INSERT INTO pubs..ODBCTest(AddressID, City) VALUES(?, ?)", odbcConn) odbcParam = New OdbcParameter("@addressid", OdbcType.Int) odbcCmd.Parameters.Add(odbcParam) odbcParam = New OdbcParameter("@city", OdbcType.VarChar, 30) odbcCmd.Parameters.Add(odbcParam)
End Sub
Public Overrides Sub 입력_ProcessInputRow(ByVal Row As 입력Buffer)
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 |