specify sqladapter for insert() and insertasync()

Dapper.Contrib NET45/SqlMapperExtensionsAsync.cs

@@ -129,7 +129,8 @@ public static partial class SqlMapperExtensions
         /// <param name="connection">Open SqlConnection</param>
         /// <param name="entityToInsert">Entity to insert</param>
         /// <returns>Identity of inserted entity</returns>
-        public static async Task<int> InsertAsync<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null, int? commandTimeout = null) where T : class
+        public static async Task<int> InsertAsync<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null,
+            int? commandTimeout = null, ISqlAdapter sqlAdapter = null) where T : class
         {
             var isList = false;
 
@@ -167,8 +168,9 @@ public static partial class SqlMapperExtensions
 
             if (!isList)    //single entity
             {
-                var adapter = GetFormatter(connection);
-                return await adapter.InsertAsync(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
+                if (sqlAdapter == null)
+                    sqlAdapter = GetFormatter(connection);
+                return await sqlAdapter.InsertAsync(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
                     sbParameterList.ToString(), keyProperties, entityToInsert);
             }
 

Dapper.Contrib.Tests NET45/TestsAsync.cs

@@ -6,6 +6,7 @@
 using System.Linq;
 using System.Reflection;
 using System.Threading.Tasks;
+using Dapper;
 using Dapper.Contrib.Extensions;
 
 namespace Dapper.Contrib.Tests
@@ -85,9 +86,12 @@ public async Task InsertGetUpdateAsync()
                 (await connection.QueryAsync<User>("select * from Users")).Count().IsEqualTo(0);
 
                 (await connection.UpdateAsync(notrackedUser)).IsEqualTo(false); //returns false, user not found
+
+                (await connection.InsertAsync(new User { Name = "Adam", Age = 10 }, sqlAdapter: new SqlServerAdapter())).IsMoreThan(0);
             }
         }
 
+
         public async Task InsertCheckKeyAsync()
         {
             using (var connection = GetOpenConnection())
@@ -272,3 +276,4 @@ public async Task DeleteAllAsync()
         }
     }
 }
+

Dapper.Contrib.Tests/Assert.cs

@@ -25,6 +25,14 @@ public static void IsMoreThan(this int obj, int other)
             }
         }
 
+        public static void IsMoreThan(this long obj, int other)
+        {
+            if (obj < other)
+            {
+                throw new ApplicationException(string.Format("{0} should be larger than {1}", obj, other));
+            }
+        }
+
         public static void IsSequenceEqualTo<T>(this IEnumerable<T> obj, IEnumerable<T> other)
         {
             if (!obj.SequenceEqual(other))

Dapper.Contrib.Tests/Tests.cs

@@ -2,10 +2,12 @@
 using System.Collections.Generic;
 using System.Data;
 using System.Data.SqlServerCe;
+using System.Diagnostics;
 using System.IO;
 using System.Linq;
 using System.Reflection;
 using System.Transactions;
+using Dapper;
 using Dapper.Contrib.Extensions;
 
 namespace Dapper.Contrib.Tests
@@ -196,9 +198,13 @@ public void InsertGetUpdate()
 
                 connection.Update(notrackedUser).IsEqualTo(false);   //returns false, user not found
 
+                //insert with custom sqladapter
+                connection.Insert(new User { Name = "Adam", Age = 10 }, sqlAdapter: new SqlServerAdapter()).IsMoreThan(0);
             }
         }
 
+       
+
         public void GetAll()
         {
             const int numberOfEntities = 100;
@@ -342,3 +348,4 @@ public void DeleteAll()
 
     }
 }
+

Dapper.Contrib/SqlMapperExtensions.cs

@@ -232,7 +232,8 @@ private static string GetTableName(Type type)
         /// <param name="connection">Open SqlConnection</param>
         /// <param name="entityToInsert">Entity to insert, can be list of entities</param>
         /// <returns>Identity of inserted entity, or number of inserted rows if inserting a list</returns>
-        public static long Insert<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null, int? commandTimeout = null) where T : class
+        public static long Insert<T>(this IDbConnection connection, T entityToInsert, IDbTransaction transaction = null,
+            int? commandTimeout = null, ISqlAdapter sqlAdapter = null) where T : class
         {
             var isList = false;
             
@@ -270,8 +271,9 @@ private static string GetTableName(Type type)
 
             if (!isList)    //single entity
             {
-                var adapter = GetFormatter(connection);
-                return adapter.Insert(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
+                if(sqlAdapter == null)
+                sqlAdapter = GetFormatter(connection);
+                return sqlAdapter.Insert(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
                     sbParameterList.ToString(), keyProperties, entityToInsert);
             }