Contrib Insert now handles closed connection

Dapper.Contrib.Tests/Tests.cs

@@ -96,6 +96,21 @@ public void TestSimpleGet()
                 connection.Delete(user);
             }
         }
+        
+        public void TestClosedConnection()
+        {
+            //using (var connection = GetOpenConnection())
+            //{
+            //     connection.Insert(new User { Name = "Adama", Age = 10 }).IsMoreThan(0);
+            //}
+
+            using (var connection = GetConnection())
+            {
+                connection.Insert(new User { Name = "Adama", Age = 10 }).IsMoreThan(0);
+                var users = connection.GetAll<User>();
+                users.Count().IsMoreThan(0);
+            }
+        }
 
         public void InsertList()
         {
@@ -208,7 +223,7 @@ public void InsertGetUpdate()
 
         public void InsertWithCustomDbType()
         {
-            SqlMapperExtensions.GetDatabaseType = connection => "SQLiteConnection";
+            SqlMapperExtensions.GetDatabaseType = conn => "SQLiteConnection";
 
             bool sqliteCodeCalled = false;
             using (var connection = GetOpenConnection())

Dapper.Contrib/SqlMapperExtensions.cs

@@ -289,16 +289,24 @@ private static string GetTableName(Type type)
                     sbParameterList.Append(", ");
             }
 
+            int returnVal;
+            var wasClosed = connection.State == ConnectionState.Closed;
+            if (wasClosed) connection.Open();
+
             if (!isList)    //single entity
             {
                 var adapter = GetFormatter(connection);
-                return adapter.Insert(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
+                returnVal = adapter.Insert(connection, transaction, commandTimeout, name, sbColumnList.ToString(),
                     sbParameterList.ToString(), keyProperties, entityToInsert);
             }
-
-            //insert list of entities
-            var cmd = String.Format("insert into {0} ({1}) values ({2})", name, sbColumnList, sbParameterList);
-            return connection.Execute(cmd, entityToInsert, transaction, commandTimeout);
+            else
+            {
+                //insert list of entities
+                var cmd = String.Format("insert into {0} ({1}) values ({2})", name, sbColumnList, sbParameterList);
+                returnVal = connection.Execute(cmd, entityToInsert, transaction, commandTimeout);
+            }
+            if (wasClosed) connection.Close();
+            return returnVal;
         }
 
         /// <summary>
@@ -625,6 +633,8 @@ public partial class SqlServerAdapter : ISqlAdapter
 {
     public int Insert(IDbConnection connection, IDbTransaction transaction, int? commandTimeout, String tableName, string columnList, string parameterList, IEnumerable<PropertyInfo> keyProperties, object entityToInsert)
     {
+        //TODO: Append a select identity at end if command?
+
         var cmd = String.Format("insert into {0} ({1}) values ({2})", tableName, columnList, parameterList);
 
         connection.Execute(cmd, entityToInsert, transaction, commandTimeout);