SQL Server BI Step by Step SSIS 4 －－-合并数据2

核心提示： 最后我们设置一下连接管理器,因为我们在脚本中要获取数据库连接,所以在这里我们添加一个连接的名称,注意这里我并没有连接到原来的OLE DB连接,我在脚本中使用了SqlDataReader,此处需要新建一个ADO.NET连接. 图片看不清楚？请点击这里查看原图（大图）。 设置完以后,我们

最后我们设置一下连接管理器,因为我们在脚本中要获取数据库连接,所以在这里我们添加一个连接的名称,注意这里我并没有连接到原来的OLE DB连接,我在脚本中使用了SqlDataReader,此处需要新建一个ADO.NET连接.

图片看不清楚？请点击这里查看原图（大图）。　

设置完以后,我们再切换到脚本,直接设置脚本,打开脚本编辑器,输入如下脚本,然后关闭.确定.

Imports　System

Imports　System.Data

Imports　System.Math

Imports　Microsoft.SqlServer.Dts.Pipeline.Wrapper

Imports　Microsoft.SqlServer.Dts.Runtime.Wrapper

Imports　Microsoft.SqlServer.Dts.Runtime

Imports　System.Data.SqlClient



Public　Class　ScriptMain
　　Inherits　UserComponent

　　Dim　connMgr　As　IDTSConnectionManager90

　　Dim　sqlConn　As　SqlConnection

　　Dim　sqlCmd　As　SqlCommand

　　Dim　sqlParam　As　SqlParameter

　　Public　Overrides　Sub　AcquireConnections(ByVal　Transaction　As　Object)

　　　　connMgr　=　Me.Connections.DBConnection

　　　　sqlConn　=　CType(connMgr.AcquireConnection(Nothing),　SqlConnection)

　　End　Sub
　　Public　Overrides　Sub　PreExecute()
sqlCmd　=　New　SqlCommand("SELECT　[Name]　FROM　Product　WHERE　ProductNumber=@ProductNumber",　sqlConn)

　　　　sqlParam　=　New　SqlParameter("@ProductNumber",　SqlDbType.NVarChar,　25)

　　　　sqlCmd.Parameters.Add(sqlParam)

　　End　Sub

　　Public　Overrides　Sub　RecordsInput_ProcessInputRow(ByVal　Row　As　RecordsInputBuffer)
　　　　Dim　reader　As　SqlDataReader
　　　　sqlCmd.Parameters("@ProductNumber").Value　=　Row.ProductNumber

　　　　reader　=　sqlCmd.ExecuteReader()
　　　　If　reader.Read()　Then
　　　　　　'此处可以根据需要进行字段的比较
　　　　　　If　(reader("Name").ToString()　<>　Row.Name)　Then
　　　　　　　　Row.DirectRowToUpdateRecordsOutput()
　　　　　　Else

　　　　　　　　Row.DirectRowToIgnoreRecordsOutput()

　　　　　　End　If

　　　　Else
　　　　　　Row.DirectRowToInsertRecordsOutput()
　　　　End　If

　　　　reader.Close()
　　End　Sub
　Public　Overrides　Sub　ReleaseConnections()
　　　　connMgr.ReleaseConnection(sqlConn)
　　End　Sub
End　Class