Add initial work on async connections

src/NPoco.Abstractions/IAsyncBaseDatabase.cs

@@ -0,0 +1,41 @@
+using System.Data;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace NPoco
+{
+    public interface IAsyncBaseDatabase : IBaseDatabase
+    {
+        /// <summary>
+        /// Opens the DbConnection manually
+        /// </summary>
+        Task<IAsyncDatabase> OpenSharedConnectionAsync(CancellationToken cancellationToken = default);
+
+        /// <summary>
+        /// Closes the DBConnection manually
+        /// </summary>
+        Task CloseSharedConnectionAsync();
+
+#if NETSTANDARD2_1_OR_GREATER
+        /// <summary>
+        /// Manually begin a transaction. Recommended to use GetTransaction
+        /// </summary>        
+        Task BeginTransactionAsync();
+
+        /// <summary>
+        /// Manually begin a transaction. Recommended to use GetTransaction
+        /// </summary>        
+        Task BeginTransactionAsync(IsolationLevel isolationLevel);
+
+        /// <summary>
+        /// Manually abort/rollback a transaction
+        /// </summary>        
+        Task AbortTransactionAsync();
+
+        /// <summary>
+        /// Manually commit a transaction
+        /// </summary>        
+        Task CompleteTransactionAsync();
+#endif
+    }
+}

src/NPoco.Abstractions/IAsyncDatabase.cs

@@ -99,7 +99,7 @@ public interface IAsyncDatabase : IAsyncQueryDatabase
         Task SaveAsync<T>(T poco, CancellationToken cancellationToken = default);
     }
 
-    public interface IAsyncQueryDatabase : IBaseDatabase
+    public interface IAsyncQueryDatabase : IAsyncBaseDatabase
     {
         /// <summary>
         /// Fetch the only row of type T using the sql and parameters specified

src/NPoco.Abstractions/NPoco.Abstractions.csproj

@@ -10,7 +10,6 @@
   <ItemGroup>
 	<PackageReference Condition="'$(TargetFramework)' == 'net461' " Include="System.ValueTuple" Version="4.5.0" />
 	<PackageReference Condition="'$(TargetFramework)' == 'net461' or '$(TargetFramework)' == 'netstandard2.0' " Include="Microsoft.Bcl.AsyncInterfaces" Version="1.1.1" />
-	<!--<PackageReference Include="System.Linq.Async" Version="5.0.0" />-->
 	<PackageReference Include="System.Reflection.Emit.Lightweight" Version="4.7.0" />
   </ItemGroup>
 

src/NPoco/AsyncDatabase.cs

@@ -3,15 +3,13 @@
 using NPoco.Expressions;
 using System;
 using System.Collections.Generic;
-using System.Data;
 using System.Data.Common;
 using System.Linq;
 using System.Threading.Tasks;
 using NPoco.Extensions;
 using NPoco.Linq;
 using System.Threading;
 using System.Runtime.CompilerServices;
-using System.Runtime.InteropServices.ComTypes;
 
 namespace NPoco
 {

src/NPoco/AsyncHelper.cs

@@ -11,5 +11,10 @@ internal static T RunSync<T>(this Task<T> task)
         {
             return task.ConfigureAwait(false).GetAwaiter().GetResult();
         }
+
+        internal static void RunSync(this Task task)
+        {
+            task.ConfigureAwait(false).GetAwaiter().GetResult();
+        }
     }
 }