sql errors and exceptions handling

Author: tomFlidr

Connection.vb

@@ -20,15 +20,21 @@ Public Class Connection
 	Public Overrides Sub Open(dsn As String)
         Me._provider = New NpgsqlConnection(dsn)
         Me._provider.Open()
-        ' TODO
-        'AddHandler Me._provider.InfoMessage, AddressOf Connection.errorHandler
+        AddHandler Me._provider.Notice, 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 NpgsqlNoticeEventArgs)
+        Dim sqlErrors As Databasic.SqlErrorsCollection = New SqlErrorsCollection()
+        sqlErrors.Add(New Databasic.PostgreSql.SqlError(args.Notice))
+        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.PostgreSql.vbproj

@@ -89,6 +89,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" />

SqlError.vb

@@ -0,0 +1,40 @@
+Public Class SqlError
+    Inherits Databasic.SqlError
+
+    Public Property ColumnName As String
+    Public Property ConstraintName As String
+    Public Property DataTypeName As String
+    Public Property Detail As String
+    Public Property File As String
+    Public Property Hint As String
+    Public Property InternalPosition As Integer
+    Public Property InternalQuery As String
+    Public Property Line As String
+    Public Property Position As Integer
+    Public Property Routine As String
+    Public Property SchemaName As String
+    Public Property Severity As String
+    Public Property TableName As String
+    Public Property Where As String
+
+    Public Sub New(pgSqlNotice As Global.Npgsql.PostgresNotice)
+        Me.Message = pgSqlNotice.MessageText
+        Me.Code = pgSqlNotice.SqlState
+
+        Me.ColumnName = pgSqlNotice.ColumnName
+        Me.ConstraintName = pgSqlNotice.ConstraintName
+        Me.DataTypeName = pgSqlNotice.DataTypeName
+        Me.Detail = pgSqlNotice.Detail
+        Me.File = pgSqlNotice.File
+        Me.Hint = pgSqlNotice.Hint
+        Me.InternalPosition = pgSqlNotice.InternalPosition
+        Me.InternalQuery = pgSqlNotice.InternalQuery
+        Me.Line = pgSqlNotice.Line
+        Me.Position = pgSqlNotice.Position
+        Me.Routine = pgSqlNotice.Routine
+        Me.SchemaName = pgSqlNotice.SchemaName
+        Me.Severity = pgSqlNotice.Severity
+        Me.TableName = pgSqlNotice.TableName
+        Me.Where = pgSqlNotice.Where
+    End Sub
+End Class

Transaction.vb

@@ -3,6 +3,7 @@ Imports Npgsql
 
 Public Class Transaction
     Inherits Databasic.Transaction
+
     Public Overrides Property Instance As DbTransaction
         Get
             Return Me._instance
@@ -12,4 +13,35 @@ Public Class Transaction
         End Set
     End Property
     Private _instance As NpgsqlTransaction
+
+    Public Shadows Sub Rollback(name As String)
+        Try
+            Me._instance.Rollback(name)
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+        Catch ex As Exception
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+            Throw ex
+        End Try
+    End Sub
+
+    Public Sub Save(name As String)
+        Try
+            Me._instance.Save(name)
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+        Catch ex As Exception
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+            Throw ex
+        End Try
+    End Sub
+
+    Public Sub Release(name As String)
+        Try
+            Me._instance.Release(name)
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+        Catch ex As Exception
+            Me.ConnectionWrapper.OpenedTransaction = Nothing
+            Throw ex
+        End Try
+    End Sub
+
 End Class

content/App.config.install.xdt

@@ -4,7 +4,7 @@
     <clear xdt:Transform="InsertIfMissing" />
     <add
       name="Databasic.Example.PqSql"
-      connectionString="Server=127.0.0.1;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
+      connectionString="Server=localhost;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
       providerName="Npgsql"
       xdt:Transform="InsertIfMissing" 
       xdt:Locator="Match(name)" />

content/App.config.uninstall.xdt

@@ -3,7 +3,7 @@
   <connectionStrings>
     <add
       name="Databasic.Example.PqSql"
-      connectionString="Server=127.0.0.1;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
+      connectionString="Server=localhost;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
       providerName="Npgsql"
       xdt:Transform="Remove"
       xdt:Locator="Match(name)" />

content/Web.config.install.xdt

@@ -4,7 +4,7 @@
     <clear xdt:Transform="InsertIfMissing" />
     <add
       name="Databasic.Example.PqSql"
-      connectionString="Server=127.0.0.1;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
+      connectionString="Server=localhost;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
       providerName="Npgsql"
       xdt:Transform="InsertIfMissing"
       xdt:Locator="Match(name)" />

content/Web.config.uninstall.xdt

@@ -3,7 +3,7 @@
   <connectionStrings>
     <add
       name="Databasic.Example.PqSql"
-      connectionString="Server=127.0.0.1;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
+      connectionString="Server=localhost;Port=5432;Database=DATABASE;User Id=USER_NAME;Password=PASSWORD;"
       providerName="Npgsql"
       xdt:Transform="Remove"
       xdt:Locator="Match(name)" />