Language: Version 1.6.1.0

Database.Test/Database.Test.vbproj

@@ -1,17 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <RootNamespace>Database.Test</RootNamespace>
-    <TargetFramework>net6.0</TargetFramework>
-
-    <IsPackable>false</IsPackable>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.1.0" />
-    <PackageReference Include="MSTest.TestAdapter" Version="2.2.8" />
-    <PackageReference Include="MSTest.TestFramework" Version="2.2.8" />
-    <PackageReference Include="coverlet.collector" Version="3.1.2" />
-  </ItemGroup>
-
-</Project>

Database.Test/UnitTest1.vb

@@ -1,12 +0,0 @@
-Imports Microsoft.VisualStudio.TestTools.UnitTesting
-
-Namespace Database.Test
-    <TestClass>
-    Public Class UnitTest1
-        <TestMethod>
-        Sub TestSub()
-
-        End Sub
-    End Class
-End Namespace
-

Database/Adapters/MSSQLServer.vb

@@ -4,7 +4,6 @@ Imports System.Data.SqlClient
 Imports DigitalData.Modules.Encryption
 Imports DigitalData.Modules.Logging
 Imports DigitalData.Modules.Base
-Imports System.Threading
 
 Public Class MSSQLServer
     Implements IDatabase
@@ -265,174 +264,118 @@ Public Class MSSQLServer
         End Try
     End Function
 
-    ''' <summary>
+    '<DebuggerStepThrough()>
-    ''' Returns a Datatable for a SQL Statement 
+    Public Function GetDatatable(SqlCommand As String) As DataTable Implements IDatabase.GetDatatable
-    ''' </summary>
+        Return GetDatatable(SqlCommand, QueryTimeout)
-    ''' <param name="pSqlCommand">SQL Command Text for Datatable (select XYZ from TableORView)</param>
-    ''' <returns>A datatable</returns>
-    Public Function GetDatatable(pSqlCommand As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable Implements IDatabase.GetDatatable
-        Using oSqlConnection = GetSQLConnection()
-            Return GetDatatableWithConnectionObject(pSqlCommand, oSqlConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
-        End Using
     End Function
 
     ''' <summary>
-    ''' Returns a datatable for a SQL Statement 
+    ''' Returns a datatable for a sql-statement 
     ''' </summary>
-    ''' <param name="pSqlCommandObject">SQL Command Object for Datatable (select XYZ from TableORView)</param>
+    ''' <param name="SqlCommand">sqlcommand for datatable (select XYZ from TableORView)</param>
-    ''' <returns>A datatable</returns>
+    ''' <returns>Returns a datatable</returns>
-    Public Function GetDatatable(pSqlCommandObject As SqlCommand, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable Implements IDatabase.GetDatatable
+    Public Function GetDatatable(SqlCommand As String, Timeout As Integer) As DataTable Implements IDatabase.GetDatatable
         Using oSqlConnection = GetSQLConnection()
-            Return GetDatatableWithConnectionObject(pSqlCommandObject, oSqlConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+            Return GetDatatableWithConnectionObject(SqlCommand, oSqlConnection, TransactionMode.WithTransaction, Nothing, Timeout)
         End Using
     End Function
 
-    Public Function GetDatatable(pSqlCommand As String, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
+    '<DebuggerStepThrough()>
+    Public Function GetDatatable(SqlCommand As String, Transaction As SqlTransaction, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
         Using oSqlConnection = GetSQLConnection()
-            Return GetDatatableWithConnectionObject(pSqlCommand, oSqlConnection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
+            Return GetDatatableWithConnectionObject(SqlCommand, oSqlConnection, TransactionMode.ExternalTransaction, Transaction, Timeout)
         End Using
     End Function
 
-    Public Function GetDatatable(pSqlCommandObject As SqlCommand, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
+    '<DebuggerStepThrough()>
-        Using oSqlConnection = GetSQLConnection()
+    Public Async Function GetDatatableAsync(SqlCommand As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of DataTable)
-            Return GetDatatableWithConnectionObject(pSqlCommandObject, oSqlConnection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
+        Return Await Task.Run(Function() GetDatatable(SqlCommand, Timeout))
-        End Using
     End Function
 
-    Public Async Function GetDatatableAsync(pSqlCommand As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of DataTable)
+    '<DebuggerStepThrough()>
-        Return Await Task.Run(Function() GetDatatable(pSqlCommand, pTimeout))
+    Public Function GetDatatableWithConnection(SqlCommand As String, pConnectionString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
-    End Function
-
-    Public Async Function GetDatatableAsync(pSqlCommandObject As SqlCommand, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of DataTable)
-        Return Await Task.Run(Function() GetDatatable(pSqlCommandObject, pTimeout))
-    End Function
-
-    Public Function GetDatatableWithConnection(pSqlCommand As String, pConnectionString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
         Using oConnection = GetConnection(pConnectionString)
-            Return GetDatatableWithConnectionObject(pSqlCommand, oConnection, pTimeout:=Timeout)
+            Return GetDatatableWithConnectionObject(SqlCommand, oConnection, Timeout:=Timeout)
         End Using
     End Function
 
-    Public Function GetDatatableWithConnection(pSqlCommandObject As SqlCommand, pConnectionString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
+    Public Function GetDatatableWithConnectionObject(SqlCommand As String, SqlConnection As SqlConnection,
-        Using oConnection = GetConnection(pConnectionString)
+                                                     Optional TransactionMode As TransactionMode = TransactionMode.WithTransaction,
-            Return GetDatatableWithConnectionObject(pSqlCommandObject, oConnection, pTimeout:=Timeout)
+                                                     Optional Transaction As SqlTransaction = Nothing,
-        End Using
+                                                     Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
-    End Function
+        Dim oTransaction As SqlTransaction = MaybeGetTransaction(SqlConnection, TransactionMode, Transaction)
-
-    Public Function GetDatatableWithConnectionObject(pSqlCommand As String, pSqlConnection As SqlConnection,
-                                                     Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                     Optional pTransaction As SqlTransaction = Nothing,
-                                                     Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
-        Dim oSQLCommand As New SqlCommand(pSqlCommand)
-        Return GetDatatableWithConnectionObject(oSQLCommand, pSqlConnection, pTransactionMode, pTransaction, pTimeout)
-    End Function
-
-    Public Function GetDatatableWithConnectionObject(pSqlCommandObject As SqlCommand, pSqlConnection As SqlConnection,
-                                                     Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                     Optional pTransaction As SqlTransaction = Nothing,
-                                                     Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
-        Dim oTransaction As SqlTransaction = MaybeGetTransaction(pSqlConnection, pTransactionMode, pTransaction)
         Dim oTable As New DataTable() With {.TableName = Constants.DEFAULT_TABLE}
 
         Try
-            pSqlCommandObject.Connection = pSqlConnection
+            Dim oAdapter As New SqlDataAdapter(New SqlCommand With {
-            pSqlCommandObject.Transaction = oTransaction
+                .CommandText = SqlCommand,
-            pSqlCommandObject.CommandTimeout = pTimeout
+                .Connection = SqlConnection,
+                .Transaction = oTransaction,
+                .CommandTimeout = Timeout
+            })
 
-            Using oAdapter As New SqlDataAdapter(pSqlCommandObject)
+            Logger.Debug("GetDatatableWithConnectionObject: Running Query [{0}]", SqlCommand)
-                Logger.Debug("GetDatatableWithConnectionObject: Running Query [{0}]", pSqlCommandObject.CommandText)
-                oAdapter.Fill(oTable)
-            End Using
 
+            oAdapter.Fill(oTable)
         Catch ex As Exception
             Logger.Error(ex)
-            Logger.Warn("GetDatatableWithConnectionObject: Error in GetDatatableWithConnection while executing command: [{0}]", pSqlCommandObject)
+            Logger.Warn("GetDatatableWithConnectionObject: Error in GetDatatableWithConnection while executing command: [{0}]", SqlCommand)
             Throw ex
         Finally
-            MaybeCommitTransaction(oTransaction, pTransactionMode)
+            MaybeCommitTransaction(oTransaction, TransactionMode)
         End Try
 
         Return oTable
     End Function
 
-    Public Function ExecuteNonQuery(pSQLCommand As String) As Boolean Implements IDatabase.ExecuteNonQuery
+    '<DebuggerStepThrough()>
+    Public Function ExecuteNonQuery(SQLCommand As String) As Boolean Implements IDatabase.ExecuteNonQuery
         Using oConnection = GetSQLConnection()
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, QueryTimeout)
+            Return ExecuteNonQueryWithConnectionObject(SQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, QueryTimeout)
         End Using
     End Function
 
-    Public Function ExecuteNonQuery(pSQLCommandObject As SqlCommand) As Boolean
+    '<DebuggerStepThrough()>
+    Public Function ExecuteNonQuery(SQLCommand As String, Timeout As Integer) As Boolean Implements IDatabase.ExecuteNonQuery
         Using oConnection = GetSQLConnection()
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommandObject, oConnection, TransactionMode.WithTransaction, Nothing, QueryTimeout)
+            Return ExecuteNonQueryWithConnectionObject(SQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, Timeout)
         End Using
     End Function
 
-    Public Function ExecuteNonQuery(pSQLCommand As String, pTimeout As Integer) As Boolean Implements IDatabase.ExecuteNonQuery
+    '<DebuggerStepThrough()>
+    Public Function ExecuteNonQuery(SQLCommand As String, Transaction As SqlTransaction, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
         Using oConnection = GetSQLConnection()
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+            Return ExecuteNonQueryWithConnectionObject(SQLCommand, Transaction.Connection, TransactionMode.ExternalTransaction, Transaction, Timeout)
         End Using
     End Function
 
-    Public Function ExecuteNonQuery(pSQLCommandObject As SqlCommand, pTimeout As Integer) As Boolean
+    '<DebuggerStepThrough()>
-        Using oConnection = GetSQLConnection()
+    Public Async Function ExecuteNonQueryAsync(SQLCommand As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Boolean)
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommandObject, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+        Return Await Task.Run(Function() ExecuteNonQuery(SQLCommand, Timeout))
-        End Using
-    End Function
-
-
-    Public Function ExecuteNonQuery(pSQLCommand As String, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
-        Using oConnection = GetSQLConnection()
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommand, pTransaction.Connection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
-        End Using
-    End Function
-
-    Public Function ExecuteNonQuery(pSQLCommandObject As SqlCommand, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
-        Using oConnection = GetSQLConnection()
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommandObject, pTransaction.Connection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
-        End Using
-    End Function
-
-    Public Async Function ExecuteNonQueryAsync(pSQLCommand As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Boolean)
-        Return Await Task.Run(Function() ExecuteNonQuery(pSQLCommand, pTimeout))
-    End Function
-
-    Public Async Function ExecuteNonQueryAsync(pSQLCommandObject As SqlCommand, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Boolean)
-        Return Await Task.Run(Function() ExecuteNonQuery(pSQLCommandObject, pTimeout))
     End Function
 
+    '<DebuggerStepThrough()>
     Public Function ExecuteNonQueryWithConnection(pSQLCommand As String, ConnString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
         Using oConnection = GetConnection(ConnString)
             Return ExecuteNonQueryWithConnectionObject(pSQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, Timeout)
         End Using
     End Function
 
-    Public Function ExecuteNonQueryWithConnection(pSQLCommandObject As SqlCommand, ConnString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
+    Public Function ExecuteNonQueryWithConnectionObject(SqlCommand As String, SqlConnection As SqlConnection,
-        Using oConnection = GetConnection(ConnString)
+                                                        Optional TransactionMode As TransactionMode = TransactionMode.WithTransaction,
-            Return ExecuteNonQueryWithConnectionObject(pSQLCommandObject, oConnection, TransactionMode.WithTransaction, Nothing, Timeout)
+                                                        Optional Transaction As SqlTransaction = Nothing,
-        End Using
+                                                        Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
-    End Function
+        Dim oTransaction As SqlTransaction = MaybeGetTransaction(SqlConnection, TransactionMode, Transaction)
-
-    Public Function ExecuteNonQueryWithConnectionObject(pSqlCommand As String, pSqlConnection As SqlConnection,
-                                                        Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                        Optional pTransaction As SqlTransaction = Nothing,
-                                                        Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
-        Dim oSQLCommand As New SqlCommand(pSqlCommand)
-        Return ExecuteNonQueryWithConnectionObject(oSQLCommand, pSqlConnection, pTransactionMode, pTransaction, pTimeout)
-    End Function
-
-    Public Function ExecuteNonQueryWithConnectionObject(pSqlCommandObject As SqlCommand, pSqlConnection As SqlConnection,
-                                                        Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                        Optional pTransaction As SqlTransaction = Nothing,
-                                                        Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Boolean
-        Dim oTransaction As SqlTransaction = MaybeGetTransaction(pSqlConnection, pTransactionMode, pTransaction)
 
         Try
-            Logger.Debug("ExecuteNonQueryWithConnectionObject: Running Command [{0}]", pSqlCommandObject.CommandText)
+            Logger.Debug("ExecuteNonQueryWithConnectionObject: Running Command [{0}]", SqlCommand)
 
-            pSqlCommandObject.Connection = pSqlConnection
+            Using oSQLCOmmand = SqlConnection.CreateCommand()
-            pSqlCommandObject.Transaction = oTransaction
+                oSQLCOmmand.CommandText = SqlCommand
-            pSqlCommandObject.CommandTimeout = pTimeout
+                oSQLCOmmand.CommandTimeout = Timeout
-            pSqlCommandObject.ExecuteNonQuery()
+                oSQLCOmmand.Transaction = oTransaction
+                oSQLCOmmand.ExecuteNonQuery()
+            End Using
 
             Return True
         Catch ex As Exception
@@ -440,126 +383,96 @@ Public Class MSSQLServer
             Logger.Warn("ExecuteNonQueryWithConnectionObject: Error in ExecuteNonQueryWithConnectionObject while executing command: [{0}]-[{1}]", SqlCommand, SqlConnection.ConnectionString)
             Return False
         Finally
-            MaybeCommitTransaction(oTransaction, pTransactionMode)
+            MaybeCommitTransaction(oTransaction, TransactionMode)
         End Try
     End Function
 
-    Public Function GetScalarValue(pSqlQuery As String) As Object Implements IDatabase.GetScalarValue
+    '<DebuggerStepThrough()>
+    Public Function GetScalarValue(SQLQuery As String) As Object Implements IDatabase.GetScalarValue
         Using oConnection As SqlConnection = GetSQLConnection()
-            Return GetScalarValueWithConnectionObject(pSqlQuery, oConnection)
+            Return GetScalarValueWithConnectionObject(SQLQuery, oConnection)
         End Using
     End Function
 
-    Public Function GetScalarValue(pSqlCommandObject As SqlCommand) As Object
+    '<DebuggerStepThrough()>
-        Using oConnection As SqlConnection = GetSQLConnection()
+    Public Function GetScalarValue(SQLCommand As String, Timeout As Integer) As Object Implements IDatabase.GetScalarValue
-            Return GetScalarValueWithConnectionObject(pSqlCommandObject, oConnection)
-        End Using
-    End Function
-
-    Public Function GetScalarValue(pSqlCommand As String, pTimeout As Integer) As Object Implements IDatabase.GetScalarValue
         Using oConnection = GetSQLConnection()
-            Return GetScalarValueWithConnectionObject(pSqlCommand, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+            Return GetScalarValueWithConnectionObject(SQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, Timeout)
         End Using
     End Function
 
-    Public Function GetScalarValue(pSqlCommandObject As SqlCommand, pTimeout As Integer) As Object
+    '<DebuggerStepThrough()>
+    Public Function GetScalarValue(SQLCommand As String, Transaction As SqlTransaction, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
         Using oConnection = GetSQLConnection()
-            Return GetScalarValueWithConnectionObject(pSqlCommandObject, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+            Return GetScalarValueWithConnectionObject(SQLCommand, oConnection, TransactionMode.ExternalTransaction, Transaction, Timeout)
         End Using
     End Function
 
-    Public Function GetScalarValue(pSQLCommand As String, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
+    '<DebuggerStepThrough()>
-        Using oConnection = GetSQLConnection()
+    Public Async Function GetScalarValueAsync(SQLQuery As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Object)
-            Return GetScalarValueWithConnectionObject(pSQLCommand, oConnection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
+        Return Await Task.Run(Function() GetScalarValue(SQLQuery, Timeout))
-        End Using
     End Function
 
-    Public Function GetScalarValue(pSQLCommandObject As SqlCommand, pTransaction As SqlTransaction, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
+    '<DebuggerStepThrough()>
-        Using oConnection = GetSQLConnection()
+    Public Function GetScalarValueWithConnection(SQLCommand As String, pConnectionString As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
-            Return GetScalarValueWithConnectionObject(pSQLCommandObject, oConnection, TransactionMode.ExternalTransaction, pTransaction, pTimeout)
-        End Using
-    End Function
-
-    Public Async Function GetScalarValueAsync(pSQLCommand As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Object)
-        Return Await Task.Run(Function() GetScalarValue(pSQLCommand, pTimeout))
-    End Function
-
-    Public Async Function GetScalarValueAsync(pSQLCommandObject As SqlCommand, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Task(Of Object)
-        Return Await Task.Run(Function() GetScalarValue(pSQLCommandObject, pTimeout))
-    End Function
-
-    Public Function GetScalarValueWithConnection(pSQLCommand As String, pConnectionString As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
         Using oConnection = GetConnection(pConnectionString)
-            Return GetScalarValueWithConnectionObject(pSQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+            Return GetScalarValueWithConnectionObject(SQLCommand, oConnection, TransactionMode.WithTransaction, Nothing, Timeout)
         End Using
     End Function
 
-    Public Function GetScalarValueWithConnection(pSqlCommandObject As SqlCommand, pConnectionString As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
+    Public Function GetScalarValueWithConnectionObject(SqlCommand As String, SqlConnection As SqlConnection,
-        Using oConnection = GetConnection(pConnectionString)
+                                                       Optional TransactionMode As TransactionMode = TransactionMode.WithTransaction,
-            Return GetScalarValueWithConnectionObject(pSqlCommandObject, oConnection, TransactionMode.WithTransaction, Nothing, pTimeout)
+                                                       Optional Transaction As SqlTransaction = Nothing,
-        End Using
+                                                       Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
-    End Function
 
-    Public Function GetScalarValueWithConnectionObject(pSqlCommand As String, pSqlConnection As SqlConnection,
+        Dim oTransaction As SqlTransaction = MaybeGetTransaction(SqlConnection, TransactionMode, Transaction)
-                                                       Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                       Optional pTransaction As SqlTransaction = Nothing,
-                                                       Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
-        Dim oSQLCommand As New SqlCommand(pSqlCommand)
-        Return GetScalarValueWithConnectionObject(oSQLCommand, pSqlConnection, pTransactionMode, pTransaction, pTimeout)
-    End Function
-
-    Public Function GetScalarValueWithConnectionObject(pSqlCommandObject As SqlCommand, pSqlConnection As SqlConnection,
-                                                       Optional pTransactionMode As TransactionMode = TransactionMode.WithTransaction,
-                                                       Optional pTransaction As SqlTransaction = Nothing,
-                                                       Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
-
-        Dim oTransaction As SqlTransaction = MaybeGetTransaction(pSqlConnection, pTransactionMode, pTransaction)
         Dim oResult As Object = Nothing
 
         Try
-            pSqlCommandObject.Connection = pSqlConnection
+            Using oSQLCOmmand = SqlConnection.CreateCommand()
-            pSqlCommandObject.CommandTimeout = pTimeout
+                oSQLCOmmand.CommandText = SqlCommand
-            pSqlCommandObject.Transaction = oTransaction
+                oSQLCOmmand.CommandTimeout = Timeout
-            oResult = pSqlCommandObject.ExecuteScalar()
+                oSQLCOmmand.Transaction = oTransaction
 
+                oResult = oSQLCOmmand.ExecuteScalar()
+            End Using
         Catch ex As Exception
             Logger.Error(ex)
-            Logger.Warn("GetDatatableWithConnectionObject: Error in GetDatatableWithConnection while executing command: [{0}]", pSqlCommandObject)
+            Logger.Warn("GetDatatableWithConnectionObject: Error in GetDatatableWithConnection while executing command: [{0}]", SqlCommand)
-
         Finally
-            MaybeCommitTransaction(oTransaction, pTransactionMode)
+            MaybeCommitTransaction(oTransaction, TransactionMode)
         End Try
 
         Return oResult
     End Function
 
-    Public Function GetScalarValue(pSqlCommand As SqlCommand, pOutputParameter As String, Optional pTimeout As Integer = Constants.DEFAULT_TIMEOUT) As Object
+    Public Function GetScalarValue(SQLCommand As SqlCommand, OutputParameter As String, Timeout As Integer) As Object
         Try
             If TestCanConnect() = False Then
                 Return Nothing
             End If
 
-            Logger.Debug("GetScalarValue: Running Query [{0}]", pSqlCommand)
+            Logger.Debug("GetScalarValue: Running Query [{0}]", SQLCommand)
 
-            If pSqlCommand.CommandText.Contains(" ") Then
+            If SQLCommand.CommandText.Contains(" ") Then
-                pSqlCommand.CommandType = CommandType.Text
+                SQLCommand.CommandType = CommandType.Text
             Else
-                pSqlCommand.CommandType = CommandType.StoredProcedure
+                SQLCommand.CommandType = CommandType.StoredProcedure
             End If
 
             Using oConnection As SqlConnection = GetSQLConnection()
 
-                pSqlCommand.Connection = oConnection
+                SQLCommand.Connection = oConnection
-                pSqlCommand.Parameters(pOutputParameter).Direction = ParameterDirection.Output
+                SQLCommand.Parameters(OutputParameter).Direction = ParameterDirection.Output
-                pSqlCommand.CommandTimeout = pTimeout
+                SQLCommand.CommandTimeout = Timeout
-                pSqlCommand.ExecuteNonQuery()
+                SQLCommand.ExecuteNonQuery()
                 oConnection.Close()
 
-                Return pSqlCommand.Parameters(pOutputParameter).Value
+                Return SQLCommand.Parameters(OutputParameter).Value
             End Using
         Catch ex As Exception
             Logger.Error(ex)
-            Logger.Warn($"GetScalarValue failed SQLCommand [{pSqlCommand}]")
+            Logger.Warn($"GetScalarValue failed SQLCommand [{SQLCommand}]")
 
             Return Nothing
         End Try
@@ -596,6 +509,7 @@ Public Class MSSQLServer
         End Try
     End Sub
 
+    '<DebuggerStepThrough()>
     Private Sub NewExecuteNonQueryAsync_Callback(ByVal result As IAsyncResult)
         Dim command As SqlCommand = CType(result.AsyncState, SqlCommand)
         Dim res = command.EndExecuteNonQuery(result)

Database/Database.vbproj

@@ -99,7 +99,6 @@
     <Compile Include="Dispatcher.vb" />
     <Compile Include="Exceptions.vb" />
     <Compile Include="Adapters\Firebird.vb" />
-    <Compile Include="Helpers.vb" />
     <Compile Include="IDatabase.vb" />
     <Compile Include="Adapters\ODBC.vb" />
     <Compile Include="Adapters\Oracle.vb" />

Database/Helpers.vb

@@ -1,10 +0,0 @@
-Public Class Helpers
-
-    Public Shared Function MaybeEscapeSQLCommand(pSQLCommand As String) As String
-
-
-
-    End Function
-
-
-End Class

Database/IDatabase.vb

@@ -1,5 +1,4 @@
 Imports System.Data.Common
-Imports System.Data.SqlClient
 
 Public Interface IDatabase
     ''' <summary>
@@ -8,8 +7,8 @@ Public Interface IDatabase
     Property DBInitialized As Boolean
     Property CurrentConnectionString As String
 
-    Function GetDatatable(SqlCommand As String, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
+    Function GetDatatable(SqlCommand As String, Timeout As Integer) As DataTable
-    Function GetDatatable(SqlCommand As SqlCommand, Optional Timeout As Integer = Constants.DEFAULT_TIMEOUT) As DataTable
+    Function GetDatatable(SqlCommand As String) As DataTable
 
     Function ExecuteNonQuery(SQLCommand As String, Timeout As Integer) As Boolean
     Function ExecuteNonQuery(SQLCommand As String) As Boolean

Database/My Project/AssemblyInfo.vb

@@ -13,7 +13,7 @@ Imports System.Runtime.InteropServices
 <Assembly: AssemblyCompany("Digital Data")>
 <Assembly: AssemblyProduct("Modules.Database")>
 <Assembly: AssemblyCopyright("Copyright © 2022")>
-<Assembly: AssemblyTrademark("2.2.7.5")>
+<Assembly: AssemblyTrademark("2.2.7.4")>
 
 <Assembly: ComVisible(False)>
 
@@ -31,5 +31,5 @@ Imports System.Runtime.InteropServices
 ' übernehmen, indem Sie "*" eingeben:
 ' <Assembly: AssemblyVersion("1.0.*")>
 
-<Assembly: AssemblyVersion("2.2.7.5")>
+<Assembly: AssemblyVersion("2.2.7.4")>
-<Assembly: AssemblyFileVersion("2.2.7.5")>
+<Assembly: AssemblyFileVersion("2.2.7.4")>

Jobs/EDMI/ZUGFeRD/EmailFunctions.vb

@@ -83,13 +83,14 @@ Public Class EmailFunctions
             Dim oFinalBodyText = String.Format(EmailStrings.EMAIL_WRAPPING_TEXT.Replace(EmailStrings.constNAME_ZUGFERD_PORTAL, NamePortal), oCompleteBodyText)
 
             Dim oEmailAddress = pEmailData.From
-            Dim oAttachment = pEmailData.Attachment
+            Dim oAttachmentPath = pEmailData.Attachment
-            If oAttachment <> String.Empty Then
+            If oAttachmentPath <> String.Empty Then
-                _logger.Debug($"Attachment_String [{oAttachment}]!")
+                _logger.Debug($"Attachment_String [{oAttachmentPath}]!")
-                If IO.File.Exists(oAttachment) = False Then
+                If IO.File.Exists(oAttachmentPath) = False Then
-                    _logger.Info($"Attachment.File [{oAttachment}] is not existing!!!")
+                    _logger.Info($"Attachment.File [{oAttachmentPath}] is not existing!!!")
                 End If
             End If
+            Dim oAttachmentPathEscaped = oAttachmentPath.Replace("'", "''")
 
             If IsNothing(oEmailAddress) OrElse String.IsNullOrWhiteSpace(oEmailAddress) Then
                 _logger.Warn("Could not find email-address for MessageId {0}", MessageId)
@@ -133,7 +134,7 @@ Public Class EmailFunctions
                        ,'{oFinalBodyText}'
                        ,'{SourceProcedure}'
                        ,'{oCreatedWho}'
-                       ,'{oAttachment}')"
+                       ,'{oAttachmentPathEscaped}')"
                 _mssql.ExecuteNonQuery(oInsert)
             Else
                 'If oDTResult.Rows.Count = 0 Then

Jobs/My Project/AssemblyInfo.vb

@@ -12,8 +12,8 @@ Imports System.Runtime.InteropServices
 <Assembly: AssemblyDescription("")>
 <Assembly: AssemblyCompany("Digital Data")>
 <Assembly: AssemblyProduct("Modules.Jobs")>
-<Assembly: AssemblyCopyright("Copyright © 2021")>
+<Assembly: AssemblyCopyright("Copyright © 2022")>
-<Assembly: AssemblyTrademark("")>
+<Assembly: AssemblyTrademark("1.8.7.0")>
 
 <Assembly: ComVisible(False)>
 
@@ -30,5 +30,5 @@ Imports System.Runtime.InteropServices
 ' Sie können alle Werte angeben oder die standardmäßigen Build- und Revisionsnummern 
 ' übernehmen, indem Sie "*" eingeben:
 
-<Assembly: AssemblyVersion("1.8.6.0")>
+<Assembly: AssemblyVersion("1.8.7.0")>
-<Assembly: AssemblyFileVersion("1.8.6.0")>
+<Assembly: AssemblyFileVersion("1.8.7.0")>

Language/My Project/AssemblyInfo.vb

@@ -13,7 +13,7 @@ Imports System.Runtime.InteropServices
 <Assembly: AssemblyCompany("")>
 <Assembly: AssemblyProduct("Language")>
 <Assembly: AssemblyCopyright("Copyright © 2022")>
-<Assembly: AssemblyTrademark("")>
+<Assembly: AssemblyTrademark("1.6.1.0")>
 
 <Assembly: ComVisible(False)>
 
@@ -31,5 +31,5 @@ Imports System.Runtime.InteropServices
 ' übernehmen, indem Sie "*" eingeben:
 ' <Assembly: AssemblyVersion("1.0.*")>
 
-<Assembly: AssemblyVersion("1.6.0.0")>
+<Assembly: AssemblyVersion("1.6.1.0")>
-<Assembly: AssemblyFileVersion("1.6.0.0")>
+<Assembly: AssemblyFileVersion("1.6.1.0")>

Language/StringEx.vb

@@ -12,4 +12,15 @@ Public Module StringEx
         If String.IsNullOrEmpty(pString) Then Return pString
         Return pString.Substring(0, Math.Min(pLength, pString.Length))
     End Function
+
+    ''' <summary>
+    ''' Replaces single quotes in text for SQL Commands.
+    ''' </summary>
+    ''' <param name="pString">The string</param>
+    ''' <returns>The escaped string.</returns>
+    <Extension()>
+    Public Function EscapeForSQL(pString As String) As String
+        If String.IsNullOrEmpty(pString) Then Return pString
+        Return pString.Replace("'", "''")
+    End Function
 End Module

Messaging/Limilab.vb

@@ -113,17 +113,21 @@ Public Class Limilab
         End Try
     End Function
     Public Function IMAPGetMessageIDs_AllMails() As List(Of Long)
-        Dim oListuids As New List(Of Long)
         Logger.Debug("Starting IMAPGetMessageIDs ...")
         If Initialized = False Then
             Return Nothing
         End If
         Try
-            Dim oConnect As Boolean = ImapConnect()
+            Dim oConnectionSuccessful As Boolean = ImapConnect()
+            Dim oListuids As List(Of Long)
 
-            If oConnect = True Then
+            If oConnectionSuccessful = True Then
+                Logger.Debug("Checking for new messages..")
                 oListuids = ImapGetMessageIDs_All()
                 CURR_ListUIDs = oListuids
+            Else
+                Logger.Warn("Connection was NOT successful. Returning Nothing.")
+                Return Nothing
             End If
             Return oListuids
         Catch ex As Exception
@@ -223,10 +227,13 @@ Public Class Limilab
     Private Function ImapGetMessageIDs_All() As List(Of Long)
         Dim oListuids As New List(Of Long)
         Try
+            Logger.Debug("Opening Inbox..")
             CurrentImapObject.SelectInbox()
 
+            Logger.Debug("Searching messages..")
             oListuids = CurrentImapObject.Search(Flag.All)
 
+            Logger.Debug("[{0}] messages found.", oListuids.Count)
             Return oListuids
         Catch ex As Exception
             Logger.Error(ex)

Modules.sln

@@ -37,8 +37,6 @@ Project("{F184B08F-C81C-45F6-A57F-5ABD9991F28F}") = "ZooFlow", "ZooFlow\ZooFlow.
 EndProject
 Project("{F184B08F-C81C-45F6-A57F-5ABD9991F28F}") = "Messaging", "Messaging\Messaging.vbproj", "{AF664D85-0A4B-4BAB-A2F8-83110C06553A}"
 EndProject
-Project("{F184B08F-C81C-45F6-A57F-5ABD9991F28F}") = "Database.Test", "Database.Test\Database.Test.vbproj", "{91B4DFC0-543C-43A7-A9E0-6817DCA277EC}"
-EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -113,10 +111,6 @@ Global
 		{AF664D85-0A4B-4BAB-A2F8-83110C06553A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{AF664D85-0A4B-4BAB-A2F8-83110C06553A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{AF664D85-0A4B-4BAB-A2F8-83110C06553A}.Release|Any CPU.Build.0 = Release|Any CPU
-		{91B4DFC0-543C-43A7-A9E0-6817DCA277EC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{91B4DFC0-543C-43A7-A9E0-6817DCA277EC}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{91B4DFC0-543C-43A7-A9E0-6817DCA277EC}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{91B4DFC0-543C-43A7-A9E0-6817DCA277EC}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

ZooFlow/Environment.vb

@@ -3,8 +3,8 @@
 Public Class Environment
     Public Property User As New State.UserState
     Public Property Settings As New State.SettingsState
-    Public Property Service As New State.ServiceState
+    Public Property Service As State.ServiceState
     Public Property Database As MSSQLServer
     Public Property DatabaseIDB As MSSQLServer
-    Public Property Modules As New Dictionary(Of String, State.ModuleState)
+    Public Property Modules As Dictionary(Of String, State.ModuleState)
 End Class