SqlBulkCopyWrapper.vb

Imports System.Data.SqlClient
Imports System.Collections.Generic
Imports SD.LLBLGen.Pro.ORMSupportClasses

Public Interface ISqlBulkCopyWrapper
    Sub WriteToServer(ByVal destTableName As String, ByVal table As DataTable, ByVal mappings As IEnumerable(Of SqlBulkCopyColumnMapping), ByRef tran As ITransaction)
End Interface

Public Class SqlBulkCopyWrapper
    Implements ISqlBulkCopyWrapper

    Public Sub WriteToServer(ByVal destTableName As String, ByVal table As DataTable, ByVal mappings As IEnumerable(Of SqlBulkCopyColumnMapping), ByRef tran As ITransaction) Implements ISqlBulkCopyWrapper.WriteToServer
        Dim copy As New SqlBulkCopy(CType(tran.ConnectionToUse, SqlConnection), _
                   SqlBulkCopyOptions.Default, _
                   CType(tran.PhysicalTransaction, SqlTransaction))

        If Not mappings Is Nothing AndAlso mappings.Count > 1 Then
            For Each map As SqlBulkCopyColumnMapping In mappings
                copy.ColumnMappings.Add(map)
            Next
        End If

        copy.DestinationTableName = destTableName
        copy.WriteToServer(table)
    End Sub

End Class