Modify InsertOnlyAsync to match new sync API

Author: mythz

src/ServiceStack.OrmLite/Async/WriteExpressionCommandExtensionsAsync.cs

@@ -98,12 +98,14 @@ internal static Task<int> UpdateAsync<T>(this IDbCommand dbCmd, object updateOnl
             return dbCmd.ExecNonQueryAsync(token);
         }
 
-        internal static Task InsertOnlyAsync<T>(this IDbCommand dbCmd, T obj, SqlExpression<T> onlyFields, CancellationToken token)
+        internal static Task InsertOnlyAsync<T>(this IDbCommand dbCmd, T obj, Expression<Func<T, object>> onlyFields, CancellationToken token)
         {
             if (OrmLiteConfig.InsertFilter != null)
                 OrmLiteConfig.InsertFilter(dbCmd, obj);
 
-            var sql = dbCmd.GetDialectProvider().ToInsertRowStatement(dbCmd, obj, onlyFields.InsertFields);
+            var q = dbCmd.GetDialectProvider().SqlExpression<T>().Insert(onlyFields);
+
+            var sql = dbCmd.GetDialectProvider().ToInsertRowStatement(dbCmd, obj, q.InsertFields);
             return dbCmd.ExecuteSqlAsync(sql, token);
         }
 

src/ServiceStack.OrmLite/Legacy/OrmLiteWriteExpressionsApiAsyncLegacy.cs

@@ -20,6 +20,17 @@ public static class OrmLiteWriteExpressionsApiAsyncLegacy
             return dbConn.Exec(dbCmd => dbCmd.InsertOnlyAsync(obj, onlyFields, token));
         }
 
+        /// <summary>
+        /// Using an SqlExpression to only Insert the fields specified, e.g:
+        /// 
+        ///   db.InsertOnly(new Person { FirstName = "Amy" }, q => q.Insert(p => new { p.FirstName }));
+        ///   INSERT INTO "Person" ("FirstName") VALUES ('Amy');
+        /// </summary>
+        public static Task InsertOnlyAsync<T>(this IDbConnection dbConn, T obj, SqlExpression<T> onlyFields, CancellationToken token = default(CancellationToken))
+        {
+            return dbConn.Exec(dbCmd => dbCmd.InsertOnlyAsync(obj, onlyFields, token));
+        }
+
         /// <summary>
         /// Use an SqlExpression to select which fields to update and construct the where expression, E.g: 
         /// 

src/ServiceStack.OrmLite/Legacy/WriteExpressionCommandExtensionsAsyncLegacy.cs

@@ -49,6 +49,15 @@ internal static Task<int> DeleteFmtAsync(this IDbCommand dbCmd, string table, st
             var sql = WriteExpressionCommandExtensionsLegacy.DeleteFmtSql(dbCmd.GetDialectProvider(), table, @where);
             return dbCmd.ExecuteSqlAsync(sql, token);
         }
+
+        internal static Task InsertOnlyAsync<T>(this IDbCommand dbCmd, T obj, SqlExpression<T> onlyFields, CancellationToken token)
+        {
+            if (OrmLiteConfig.InsertFilter != null)
+                OrmLiteConfig.InsertFilter(dbCmd, obj);
+
+            var sql = dbCmd.GetDialectProvider().ToInsertRowStatement(dbCmd, obj, onlyFields.InsertFields);
+            return dbCmd.ExecuteSqlAsync(sql, token);
+        }
     }
 }
 

src/ServiceStack.OrmLite/OrmLiteWriteExpressionsApiAsync.cs

@@ -145,10 +145,10 @@ public static Task<int> UpdateAddAsync<T>(this IDbConnection dbConn,
         /// <summary>
         /// Using an SqlExpression to only Insert the fields specified, e.g:
         /// 
-        ///   db.InsertOnly(new Person { FirstName = "Amy" }, q => q.Insert(p => new { p.FirstName }));
+        ///   db.InsertOnly(new Person { FirstName = "Amy" }, p => new { p.FirstName });
         ///   INSERT INTO "Person" ("FirstName") VALUES ('Amy');
         /// </summary>
-        public static Task InsertOnlyAsync<T>(this IDbConnection dbConn, T obj, SqlExpression<T> onlyFields, CancellationToken token = default(CancellationToken))
+        public static Task InsertOnlyAsync<T>(this IDbConnection dbConn, T obj, Expression<Func<T, object>> onlyFields, CancellationToken token = default(CancellationToken))
         {
             return dbConn.Exec(dbCmd => dbCmd.InsertOnlyAsync(obj, onlyFields, token));
         }

tests/ServiceStack.OrmLiteV45.Tests/ApiMySqlTestsAsync.cs

@@ -231,7 +231,7 @@ await db.InsertAsync(new Person { Id = 8, FirstName = "Tupac", LastName = "Shaku
             await db.InsertAllAsync(new[] { new Person { Id = 10, FirstName = "Biggie", LastName = "Smalls", Age = 24 } });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO `Person` (`Id`,`FirstName`,`LastName`,`Age`) VALUES (@Id,@FirstName,@LastName,@Age)"));
 
-            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, db.From<PersonWithAutoId>().Insert(p => new { p.FirstName, p.Age }));
+            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, p => new { p.FirstName, p.Age });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO `PersonWithAutoId` (`FirstName`,`Age`) VALUES ('Amy',27)"));
 
             await db.UpdateAsync(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27 });

tests/ServiceStack.OrmLiteV45.Tests/ApiPostgreSqlTestsAsync.cs

@@ -231,7 +231,7 @@ await db.InsertAsync(new Person { Id = 8, FirstName = "Tupac", LastName = "Shaku
             await db.InsertAllAsync(new[] { new Person { Id = 10, FirstName = "Biggie", LastName = "Smalls", Age = 24 } });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"person\" (\"id\",\"first_name\",\"last_name\",\"age\") VALUES (:Id,:FirstName,:LastName,:Age)"));
 
-            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, db.From<PersonWithAutoId>().Insert(p => new { p.FirstName, p.Age }));
+            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, p => new { p.FirstName, p.Age });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"person_with_auto_id\" (\"first_name\",\"age\") VALUES ('Amy',27)"));
 
             await db.UpdateAsync(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27 });

tests/ServiceStack.OrmLiteV45.Tests/ApiSqlServerTestsAsync.cs

@@ -232,7 +232,7 @@ await db.InsertAsync(new Person { Id = 8, FirstName = "Tupac", LastName = "Shaku
             await db.InsertAllAsync(new[] { new Person { Id = 10, FirstName = "Biggie", LastName = "Smalls", Age = 24 } });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"Person\" (\"Id\",\"FirstName\",\"LastName\",\"Age\") VALUES (@Id,@FirstName,@LastName,@Age)"));
 
-            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, db.From<PersonWithAutoId>().Insert(p => new { p.FirstName, p.Age }));
+            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, p => new { p.FirstName, p.Age });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"PersonWithAutoId\" (\"FirstName\",\"Age\") VALUES ('Amy',27)"));
 
             await db.UpdateAsync(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27 });

tests/ServiceStack.OrmLiteV45.Tests/ApiSqliteTestsAsync.cs

@@ -231,7 +231,7 @@ await db.InsertAsync(new Person { Id = 8, FirstName = "Tupac", LastName = "Shaku
             await db.InsertAllAsync(new[] { new Person { Id = 10, FirstName = "Biggie", LastName = "Smalls", Age = 24 } });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"Person\" (\"Id\",\"FirstName\",\"LastName\",\"Age\") VALUES (@Id,@FirstName,@LastName,@Age)"));
 
-            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, db.From<PersonWithAutoId>().Insert(p => new { p.FirstName, p.Age }));
+            await db.InsertOnlyAsync(new PersonWithAutoId { FirstName = "Amy", Age = 27 }, p => new { p.FirstName, p.Age });
             Assert.That(db.GetLastSql(), Is.EqualTo("INSERT INTO \"PersonWithAutoId\" (\"FirstName\",\"Age\") VALUES ('Amy',27)"));
 
             await db.UpdateAsync(new Person { Id = 1, FirstName = "Jimi", LastName = "Hendrix", Age = 27 });