@@ -3,43 +3,44 @@ Imports System.Data.SqlClient
33Imports System.Reflection
44
55Public Class Connection
6- Inherits Databasic.Connection
7-
8- Public Overrides ReadOnly Property Provider As DbConnection
9- Get
10- Return Me ._provider
11- End Get
12- End Property
13- Private _provider As SqlConnection
14-
15- Public Overrides ReadOnly Property ProviderResource As System.Type = GetType (ProviderResource)
16-
17- Public Overrides ReadOnly Property ClientName As String = "System.Data.SqlClient"
18-
19- Public Overrides ReadOnly Property Statement As System.Type = GetType (Statement)
20-
21- Public Overrides Sub Open(dsn As String )
22- Me ._provider = New SqlConnection(dsn)
23- Me ._provider.Open()
24- AddHandler Me ._provider.InfoMessage, AddressOf Connection.errorHandler
25- End Sub
26-
27- Protected Shared Sub errorHandler(sender As Object , args As SqlInfoMessageEventArgs)
28- Dim sqlErrors As Databasic.SqlErrorsCollection = New SqlErrorsCollection()
29- For index = 0 To args.Errors.Count - 1
30- sqlErrors.Add( New Databasic.MsSql.SqlError(args.Errors(index)))
31- Next
32- Databasic.Events.RaiseError(sqlErrors)
33- End Sub
34-
35- Protected Overrides Function createAndBeginTransaction( Optional transactionName As String = "" , Optional isolationLevel As IsolationLevel = IsolationLevel.Unspecified) As Databasic.Transaction
36- Me .OpenedTransaction = New Transaction() With {
37- .ConnectionWrapper = Me ,
38- .Instance = Me ._provider.BeginTransaction(
39- isolationLevel, transactionName.Substring( 0 , Math.Min(transactionName.Length - 1 , 32 ))
40- )
41- }
42- Return Me .OpenedTransaction
43- End Function
6+ Inherits Databasic.Connection
7+
8+ Public Overrides ReadOnly Property Provider As DbConnection
9+ Get
10+ Return Me ._provider
11+ End Get
12+ End Property
13+ Private _provider As SqlConnection
14+
15+
16+ Public Overrides ReadOnly Property ProviderResource As System.Type = GetType (ProviderResource)
17+
18+ Public Overrides ReadOnly Property ClientName As String = "System.Data.SqlClient"
19+
20+ Public Overrides ReadOnly Property Statement As System.Type = GetType (Statement)
21+
22+ Public Overrides Sub Open(dsn As String )
23+ Me ._provider = New SqlConnection(dsn)
24+ Me ._provider.Open()
25+ AddHandler Me ._provider.InfoMessage, AddressOf Connection.errorHandler
26+ End Sub
27+
28+ Protected Shared Sub errorHandler(sender As Object , args As SqlInfoMessageEventArgs)
29+ Dim sqlErrors As Databasic.SqlErrorsCollection = New SqlErrorsCollection()
30+ For index = 0 To args.Errors.Count - 1
31+ sqlErrors.Add( New Databasic.MsSql.SqlError(args.Errors(index)))
32+ Next
33+ Databasic.Events.RaiseError(sqlErrors)
34+ End Sub
35+
36+ Protected Overrides Function createAndBeginTransaction( Optional transactionName As String = "" , Optional isolationLevel As IsolationLevel = IsolationLevel.Unspecified) As Databasic.Transaction
37+ Me .OpenedTransaction = New Transaction() With {
38+ .ConnectionWrapper = Me ,
39+ .Instance = Me ._provider.BeginTransaction(
40+ isolationLevel, transactionName.Substring( 0 , Math.Min(transactionName.Length - 1 , 32 ))
41+ )
42+ }
43+ Return Me .OpenedTransaction
44+ End Function
4445
4546End Class
0 commit comments