sql errors and exceptions handling

Author: tomFlidr

Connection.vb

@@ -23,11 +23,20 @@ Public Class Connection
         AddHandler Me._provider.InfoMessage, AddressOf Connection.errorHandler
     End Sub
 
-    Public Overrides Function CreateAndBeginTransaction(Optional transactionName As String = "", Optional isolationLevel As IsolationLevel = IsolationLevel.Unspecified) As Databasic.Transaction
-        Return New Transaction() With {
+    Protected Shared Sub errorHandler(sender As Object, args As MySqlInfoMessageEventArgs)
+        Dim sqlErrors As Databasic.SqlErrorsCollection = New SqlErrorsCollection()
+        For index = 0 To args.errors.Length - 1
+            sqlErrors.Add(New Databasic.MySql.SqlError(args.errors(index)))
+        Next
+        Databasic.Events.RaiseError(sqlErrors)
+    End Sub
+
+    Protected Overrides Function createAndBeginTransaction(Optional transactionName As String = "", Optional isolationLevel As IsolationLevel = IsolationLevel.Unspecified) As Databasic.Transaction
+        Me.OpenedTransaction = New Transaction() With {
             .ConnectionWrapper = Me,
             .Instance = Me._provider.BeginTransaction(isolationLevel)
         }
+        Return Me.OpenedTransaction
     End Function
 
 End Class

Databasic.MySql.vbproj

@@ -78,6 +78,7 @@
       <DependentUpon>Settings.settings</DependentUpon>
       <DesignTimeSharedInput>True</DesignTimeSharedInput>
     </Compile>
+    <Compile Include="SqlError.vb" />
     <Compile Include="ProviderResource.vb" />
     <Compile Include="Statement.vb" />
     <Compile Include="Transaction.vb" />

ProviderResource.vb

@@ -31,22 +31,51 @@
 		Return Databasic.Statement.Prepare("SELECT LAST_INSERT_ID()", transaction).FetchOne().ToInstance(Of Object)()
 	End Function
 
-	'Public Overrides Function GetAll(
-	'		connection As Databasic.Connection,
-	'		columns As String,
-	'		table As String,
-	'		Optional offset As Int64? = Nothing,
-	'		Optional limit As Int64? = Nothing,
-	'		Optional orderByStatement As String = ""
-	'	) As Databasic.Statement
-	'	Dim sql = $"SELECT {columns} FROM {table}"
-	'	offset = If(offset, 0)
-	'	limit = If(limit, 0)
-	'	If limit > 0 Then
-	'		sql += If(orderByStatement.Length > 0, " ORDER BY " + orderByStatement, "") +
-	'				$" LIMIT {If(limit = 0, "18446744073709551615", limit.ToString())} OFFSET {offset}"
-	'	End If
-	'	Return Databasic.Statement.Prepare(sql, connection).FetchAll()
-	'End Function
+    'Public Overrides Function GetAll(
+    '		connection As Databasic.Connection,
+    '		columns As String,
+    '		table As String,
+    '		Optional offset As Int64? = Nothing,
+    '		Optional limit As Int64? = Nothing,
+    '		Optional orderByStatement As String = ""
+    '	) As Databasic.Statement
+    '	Dim sql = $"SELECT {columns} FROM {table}"
+    '	offset = If(offset, 0)
+    '	limit = If(limit, 0)
+    '	If limit > 0 Then
+    '		sql += If(orderByStatement.Length > 0, " ORDER BY " + orderByStatement, "") +
+    '				$" LIMIT {If(limit = 0, "18446744073709551615", limit.ToString())} OFFSET {offset}"
+    '	End If
+    '	Return Databasic.Statement.Prepare(sql, connection).FetchAll()
+    'End Function
+
+    Public Overridable Function GetList(
+        conditionSqlStatement As String,
+        conditionParams As Object,
+        orderBySqlStatement As String,
+        offset As Int64?,
+        limit As Int64?,
+        connectionOrTransaction As Object,
+        ByRef classMetaDescription As MetaDescription
+    ) As Databasic.Statement
+        Dim columns As String = String.Join(",", Databasic.ProviderResource.ColumnsArray(classMetaDescription.ClassType, 0))
+        Dim sql As String = $"SELECT {columns} FROM {ActiveRecord.Resource.Table(classMetaDescription)}"
+        Dim params As Object = Nothing
+        If Not String.IsNullOrEmpty(conditionSqlStatement) Then
+            sql += " WHERE " + conditionSqlStatement
+            params = conditionParams
+        End If
+        If Not String.IsNullOrEmpty(orderBySqlStatement) Then
+            sql += " ORDER BY " + orderBySqlStatement
+        End If
+        If offset.HasValue Then
+            ' offset a number, but could be 0, limit is unknown
+            sql += $" LIMIT {If(Not limit.HasValue, "18446744073709551615", limit.ToString())} OFFSET {offset}"
+        ElseIf limit.HasValue And limit > 0 Then
+            ' offset is null, limit is a number, but could be 0
+            sql += $" LIMIT {limit.ToString()}"
+        End If
+        Return Databasic.Statement.Prepare(sql, connectionOrTransaction).FetchAll(params)
+    End Function
 
 End Class

SqlError.vb

@@ -0,0 +1,15 @@
+Imports MySql.Data.MySqlClient
+
+Public Class SqlError
+    Inherits Databasic.SqlError
+
+    Public Property Level As String
+
+    Public Sub New(mySqlError As Global.MySql.Data.MySqlClient.MySqlError)
+        Me.Message = mySqlError.Message
+        Me.Code = mySqlError.Code
+
+        Me.Level = mySqlError.Level
+    End Sub
+
+End Class

Transaction.vb

@@ -3,6 +3,7 @@ Imports MySql.Data.MySqlClient
 
 Public Class Transaction
     Inherits Databasic.Transaction
+
     Public Overrides Property Instance As DbTransaction
         Get
             Return Me._instance
@@ -12,4 +13,5 @@ Public Class Transaction
         End Set
     End Property
     Private _instance As MySqlTransaction
+
 End Class

content/App.config.install.xdt

@@ -4,7 +4,7 @@
     <clear xdt:Transform="InsertIfMissing" />
     <add
       name="Databasic.Example.MySql"
-      connectionString="server=127.0.0.1;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
+      connectionString="server=localhost;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
       providerName="MySql.Data.MySqlClient"
       xdt:Transform="InsertIfMissing" 
       xdt:Locator="Match(name)" />

content/App.config.uninstall.xdt

@@ -3,7 +3,7 @@
   <connectionStrings>
     <add
       name="Databasic.Example.MySql"
-      connectionString="server=127.0.0.1;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
+      connectionString="server=localhost;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
       providerName="MySql.Data.MySqlClient"
       xdt:Transform="Remove"
       xdt:Locator="Match(name)" />

content/Web.config.install.xdt

@@ -4,7 +4,7 @@
     <clear xdt:Transform="InsertIfMissing" />
     <add
       name="Databasic.Example.MySql"
-      connectionString="server=127.0.0.1;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
+      connectionString="server=localhost;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
       providerName="MySql.Data.MySqlClient"
       xdt:Transform="InsertIfMissing"
       xdt:Locator="Match(name)" />

content/Web.config.uninstall.xdt

@@ -3,7 +3,7 @@
   <connectionStrings>
     <add
       name="Databasic.Example.MySql"
-      connectionString="server=127.0.0.1;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
+      connectionString="server=localhost;port=3306;uid=USER_NAME;pwd=PASSWORD;database=DATABASE;"
       providerName="MySql.Data.MySqlClient"
       xdt:Transform="Remove"
       xdt:Locator="Match(name)" />