Imports System.Data
Imports System.Data.SqlClient

Public Class ProcessTransactionClass ProcessTransaction


    Private c As New Collection

    Public Sub ptExecuteNonQuery()Sub ptExecuteNonQuery(ByVal commandText() As String, ByVal cCN As Collection)

        Dim s As String

        Dim flag As Boolean
        For Each s In cCN
            If Not ptExecuteNonQuery_test(commandText, s) Then
                flag = False
                Exit For
            Else
                flag = True
            End If
        Next

        Dim sqlTa As SqlTransaction
        If flag Then
            For Each sqlTa In c
                sqlTa.Commit()
            Next
        Else
            For Each sqlTa In c
                sqlTa.Rollback()
            Next
        End If

    End Sub


    Private Function ptExecuteNonQuery_test()Function ptExecuteNonQuery_test(ByVal commandText() As String, ByVal cn As String) As Boolean

        Dim sqlcn As New SqlConnection(cn)
        Dim sqlCmd As New SqlCommand
        Try
            sqlcn.Open()
            Dim sqlTa As SqlTransaction = sqlcn.BeginTransaction()
            c.Add(sqlTa)

            sqlCmd.CommandType = CommandType.Text
            sqlCmd.Connection = sqlcn
            sqlCmd.Transaction = sqlTa
            Dim CommStr As String
            For Each CommStr In commandText
                sqlCmd.CommandText = CommStr
                sqlCmd.ExecuteNonQuery()
            Next
            Return True
        Catch ex As Exception
            Return False
        Finally
            sqlCmd.Dispose()
            sqlcn.Close()
            sqlcn.Dispose()
        End Try

    End Function
End Class