Add db.UpdateableByObject(o).ExecuteCommandAsync()

This commit is contained in:
sunkaixuan 2023-02-15 15:30:42 +08:00
parent edadb93211
commit 02d3400cd6
4 changed files with 12 additions and 3 deletions

View File

@ -286,7 +286,7 @@ namespace OrmTest
Console.WriteLine(""); Console.WriteLine("");
Console.WriteLine("#### Subquery Start ####"); Console.WriteLine("#### Subquery Start ####");
var db = GetInstance(); var db = GetInstance();
var list = db.Queryable<Order>().Take(10).Select(it => new var list = db.Queryable<Order>().Take(10).Select(it => new
{ {
customName = SqlFunc.Subqueryable<Custom>().Where("it.CustomId=id").Select(s => s.Name), customName = SqlFunc.Subqueryable<Custom>().Where("it.CustomId=id").Select(s => s.Name),

View File

@ -136,7 +136,7 @@ namespace OrmTest
object o = db.Queryable<Order>().First(); object o = db.Queryable<Order>().First();
db.UpdateableByObject(o).ExecuteCommand(); db.UpdateableByObject(o).ExecuteCommandAsync().GetAwaiter().GetResult();
object os = db.Queryable<Order>().Take(2).ToList(); object os = db.Queryable<Order>().Take(2).ToList();
db.UpdateableByObject(os).ExecuteCommand(); db.UpdateableByObject(os).ExecuteCommand();
Console.WriteLine("#### Updateable End ####"); Console.WriteLine("#### Updateable End ####");

View File

@ -86,7 +86,7 @@ namespace OrmTest
int result2 = db.Fastest<System.Data.DataTable>().AS("order").BulkCopy( dataTable); int result2 = db.Fastest<System.Data.DataTable>().AS("order").BulkCopy( dataTable);
object o = db.Queryable<Order>().First(); object o = db.Queryable<Order>().First();
db.InsertableByObject(o).ExecuteCommand(); db.InsertableByObject(o).ExecuteCommandAsync().GetAwaiter().GetResult();
object os = db.Queryable<Order>().Take(2).ToList(); object os = db.Queryable<Order>().Take(2).ToList();
db.InsertableByObject(os).ExecuteCommand(); db.InsertableByObject(os).ExecuteCommand();

View File

@ -3,6 +3,7 @@ using System.Collections;
using System.Collections.Generic; using System.Collections.Generic;
using System.Reflection; using System.Reflection;
using System.Text; using System.Text;
using System.Threading.Tasks;
namespace SqlSugar namespace SqlSugar
{ {
@ -19,5 +20,13 @@ namespace SqlSugar
var result= inertable.GetType().GetMethod("ExecuteCommand").Invoke(inertable,new object[] { }); var result= inertable.GetType().GetMethod("ExecuteCommand").Invoke(inertable,new object[] { });
return (int)result; return (int)result;
} }
public async Task<int> ExecuteCommandAsync()
{
if (Context == null) return 0;
var inertable = MethodInfo.Invoke(Context, new object[] { objectValue });
var result = inertable.GetType().GetMethod("ExecuteCommandAsync").Invoke(inertable, new object[] { });
return await (Task<int>)result;
}
} }
} }