diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Config.cs b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Config.cs
new file mode 100644
index 000000000..6db01b79f
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Config.cs
@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ ///
+ /// Setting up the database name does not require you to create the database
+ /// 只需要设置IP和账户密码 ，自动建库
+ ///
+ public class Config
+ {
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString = "server=localhost;Database=SqlSugar4xTest;Uid=root;Pwd=haosql; AllowLoadLocalInfile=true";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString2 = "server=localhost;Database=SqlSugar4xTest2;Uid=root;Pwd=haosql";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString3 = "server=localhost;Database=SqlSugar4xTest3;Uid=root;Pwd=haosql";
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/CustomDbTest.csproj b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/CustomDbTest.csproj
new file mode 100644
index 000000000..1022e0b54
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/CustomDbTest.csproj
@@ -0,0 +1,21 @@
+
+
+
+ Exe
+ netcoreapp3.1
+ AnyCPU;ARM32
+
+
+
+
+
+
+
+
+
+
+ Always
+
+
+
+
diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo0_SqlSugarClient.cs b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo0_SqlSugarClient.cs
new file mode 100644
index 000000000..3c9597a88
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo0_SqlSugarClient.cs
@@ -0,0 +1,454 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+namespace OrmTest
+{
+ public class Demo0_SqlSugarClient
+ {
+
+ public static void Init()
+ {
+ SqlSugarClient();//Create db
+ DbContext();//Optimizing SqlSugarClient usage
+ SingletonPattern();//Singleten Pattern
+ DistributedTransactionExample();
+ MasterSlave();//Read-write separation
+ CustomAttribute();
+ }
+
+ private static void MasterSlave()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### MasterSlave Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,//Master Connection
+ DbType = DbType.Custom,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ SlaveConnectionConfigs = new List() {
+ new SlaveConnectionConfig() { HitRate=10, ConnectionString=Config.ConnectionString2 } ,
+ new SlaveConnectionConfig() { HitRate=10, ConnectionString=Config.ConnectionString2 }
+ }
+ });
+
+
+ db.Aop.OnLogExecuted = (s, p) =>
+ {
+ Console.WriteLine(db.Ado.Connection.ConnectionString);
+ };
+ Console.WriteLine("Master:");
+ db.Insertable(new Order() { Name = "abc", CustomId = 1, CreateTime = DateTime.Now }).ExecuteCommand();
+ Console.WriteLine("Slave:");
+ db.Queryable().First();
+ Console.WriteLine("#### MasterSlave End ####");
+ }
+
+ private static void SqlSugarClient()
+ {
+ //Create db
+ Console.WriteLine("#### SqlSugarClient Start ####");
+
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Custom,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+
+ //If no exist create datebase
+ //db.DbMaintenance.CreateDatabase();
+
+ //Use db query
+ var dt = db.Ado.GetDataTable("select 1");
+
+ //Create tables
+ db.CodeFirst.InitTables(typeof(OrderItem),typeof(Order));
+ var id = db.Insertable(new Order() { Name = "order1", CustomId = 1, Price = 0, CreateTime = DateTime.Now }).ExecuteReturnIdentity();
+
+ //Insert data
+ db.Insertable(new OrderItem() { OrderId = id, Price = 0, CreateTime=DateTime.Now }).ExecuteCommand();
+ Console.WriteLine("#### SqlSugarClient End ####");
+
+ }
+
+ private static void DbContext()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### DbContext Start ####");
+ var insertObj = new Order { Name = "jack", CreateTime = DateTime.Now };
+ var InsertObjs = new Order[] { insertObj };
+
+ DbContext context = new DbContext();
+
+ context.Db.CodeFirst.InitTables();//Create Tables
+ ;
+ var orderDb = context.OrderDb;
+
+ //Select
+ var data1 = orderDb.GetById(1);
+ var data2 = orderDb.GetList();
+ var data3 = orderDb.GetList(it => it.Id == 1);
+ var data4 = orderDb.GetSingle(it => it.Id == 1);
+ var p = new PageModel() { PageIndex = 1, PageSize = 2 };
+ var data5 = orderDb.GetPageList(it => it.Name == "xx", p);
+ Console.Write(p.TotalCount);
+ var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc);
+ Console.Write(p.TotalCount);
+ List conModels = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+ var data7 = orderDb.GetPageList(conModels, p, it => it.Name, OrderByType.Asc);
+ orderDb.AsQueryable().Where(x => x.Id == 1).ToList();
+
+ //Insert
+ orderDb.Insert(insertObj);
+ orderDb.InsertRange(InsertObjs);
+ var id = orderDb.InsertReturnIdentity(insertObj);
+ orderDb.AsInsertable(insertObj).ExecuteCommand();
+
+
+ //Delete
+ orderDb.Delete(insertObj);
+ orderDb.DeleteById(11111);
+ orderDb.DeleteById(new int[] { 1111, 2222 });
+ orderDb.Delete(it => it.Id == 1111);
+ orderDb.AsDeleteable().Where(it => it.Id == 1111).ExecuteCommand();
+
+ //Update
+ orderDb.Update(insertObj);
+ orderDb.UpdateRange(InsertObjs);
+ orderDb.Update(it => new Order() { Name = "a", }, it => it.Id == 1);
+ orderDb.AsUpdateable(insertObj).UpdateColumns(it => new { it.Name }).ExecuteCommand();
+
+ //Use Inherit DbContext
+ OrderDal dal = new OrderDal();
+ var data = dal.GetById(1);
+ var list = dal.GetList();
+
+ Console.WriteLine("#### DbContext End ####");
+ }
+
+ private static void CustomAttribute()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Custom Attribute Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.Custom,
+ IsAutoCloseConnection = true,
+ InitKeyType = InitKeyType.Attribute,
+ ConfigureExternalServices = new ConfigureExternalServices()
+ {
+ EntityService = (property, column) =>
+ {
+
+ var attributes = property.GetCustomAttributes(true);//get all attributes
+
+ if (attributes.Any(it => it is KeyAttribute))// by attribute set primarykey
+ {
+ column.IsPrimarykey = true;
+ }
+ },
+ EntityNameService = (type, entity) =>
+ {
+ var attributes = type.GetCustomAttributes(true);
+ if (attributes.Any(it => it is TableAttribute))
+ {
+ entity.DbTableName = (attributes.First(it => it is TableAttribute) as TableAttribute).Name;
+ }
+ }
+ }
+ });
+ db.CodeFirst.InitTables();//Create Table
+
+ db.Insertable(new AttributeTable() { Id = Guid.NewGuid().ToString(), Name = "Name" }).ExecuteCommand();
+ var list = db.Queryable().ToList();
+
+ Console.WriteLine("#### Custom Attribute End ####");
+ }
+
+
+ private static void SingletonPattern()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Singleton Pattern Start ####");
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ var task = new Task(() =>
+ {
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ new Task(() =>
+ {
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+
+ }).Start();
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ });
+ task.Start();
+ task.Wait();
+ System.Threading.Thread.Sleep(500);
+ Console.WriteLine(string.Join(",", singleDb.TempItems.Keys));
+
+ Console.WriteLine("#### Singleton Pattern end ####");
+ }
+
+ static SqlSugarScope singleDb = new SqlSugarScope(
+ new ConnectionConfig()
+ {
+ ConfigId = 1,
+ DbType = DbType.Custom,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents()
+ {
+ OnLogExecuting = (sql, p) => { Console.WriteLine(sql); }
+ }
+ });
+
+
+ private static void DistributedTransactionExample()
+ {
+ //Console.WriteLine("");
+ //Console.WriteLine("#### Distributed TransactionExample Start ####");
+ //SqlSugarClient db = new SqlSugarClient(new List()
+ //{
+ // new ConnectionConfig(){ ConfigId="1", DbType=DbType.Custom, ConnectionString=Config.ConnectionString,InitKeyType=InitKeyType.Attribute,IsAutoCloseConnection=true },
+ // new ConnectionConfig(){ ConfigId="2", DbType=DbType.Custom, ConnectionString=Config.ConnectionString2 ,InitKeyType=InitKeyType.Attribute ,IsAutoCloseConnection=true}
+ //});
+
+ ////use db1
+ //db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem));//
+ //db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand();
+ //Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count());
+
+ ////use db2
+ //db.ChangeDatabase("2");
+ //db.DbMaintenance.CreateDatabase();//Create Database2
+ //db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem));
+ //db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand();
+ //Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count());
+
+ //// Example 1
+ //Console.WriteLine("Example 1");
+ //try
+ //{
+ // db.BeginTran();
+
+ // db.ChangeDatabase("1");//use db1
+ // db.Deleteable().ExecuteCommand();
+ // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+
+ // db.ChangeDatabase("2");//use db2
+ // db.Deleteable().ExecuteCommand();
+ // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+
+ // throw new Exception();
+ // db.CommitTran();
+ //}
+ //catch
+ //{
+ // db.RollbackTran();
+ // Console.WriteLine("---Roll back");
+ // db.ChangeDatabase("1");//use db1
+ // Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+
+ // db.ChangeDatabase("2");//use db2
+ // Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+ //}
+
+
+
+ //// Example 2
+ //Console.WriteLine("Example 2");
+
+ //var result = db.UseTran(() =>
+ //{
+
+ // db.ChangeDatabase("1");//use db1
+ // db.Deleteable().ExecuteCommand();
+ // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+
+ // db.ChangeDatabase("2");//use db2
+ // db.Deleteable().ExecuteCommand();
+ // Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+ // throw new Exception("");
+
+ //});
+ //if (result.IsSuccess == false)
+ //{
+ // Console.WriteLine("---Roll back");
+ // db.ChangeDatabase("1");//use db1
+ // Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+
+ // db.ChangeDatabase("2");//use db2
+ // Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ // Console.WriteLine(db.Queryable().Count());
+ //}
+
+ //// Example 3
+ //Console.WriteLine("Example 3");
+ //Task> result2 = AsyncTranDemo(db);
+ //result2.Wait();
+
+ //// Example 4
+ //Console.WriteLine("Example 4");
+ //var mysqldb = db.GetConnection("1");//获取ConfigId为1的数据库对象
+ //var sqlServerdb = db.GetConnection("2");//获取默认对象
+ //Console.WriteLine(mysqldb.Queryable().Count());
+ //Console.WriteLine(sqlServerdb.Queryable().Count());
+ //try
+ //{
+ // db.BeginTran();
+
+ // sqlServerdb.Deleteable().ExecuteCommand();
+ // mysqldb.Deleteable().ExecuteCommand();
+ // Console.WriteLine(mysqldb.Queryable().Count());
+ // Console.WriteLine(sqlServerdb.Queryable().Count());
+
+ // throw new Exception("");
+ // db.CommitTran();
+ //}
+ //catch (Exception)
+ //{
+ // db.RollbackTran();//数据回滚
+ // Console.WriteLine(mysqldb.Queryable().Count());
+ // Console.WriteLine(sqlServerdb.Queryable().Count());
+ //}
+ //Console.WriteLine("#### Distributed TransactionExample End ####");
+ }
+
+ ///
+ ///Async tran demo
+ ///
+ ///
+ ///
+ private static async Task> AsyncTranDemo(SqlSugarClient db)
+ {
+ //need await all
+ var result2 =await db.UseTranAsync(async () =>
+ {
+ //need await all
+
+ db.ChangeDatabase("1");//use db1
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ throw new Exception("");
+
+ });
+ Console.WriteLine("---Roll back");
+ db.ChangeDatabase("1");//use sqlserver
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use mysql
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ return result2;
+ }
+ }
+
+ ///
+ /// DbContext Example 1
+ ///
+ public class DbContext
+ {
+
+ public SqlSugarClient Db;
+ public DbContext()
+ {
+ Db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.Custom,
+ IsAutoCloseConnection = true,
+ InitKeyType = InitKeyType.Attribute,
+ AopEvents = new AopEvents()
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ }
+ }
+ });
+ }
+ public SimpleClient OrderDb => new SimpleClient(Db);
+ public SimpleClient OrderItemDb => new SimpleClient(Db);
+ }
+
+
+ public class OrderDal : DbContext
+ {
+
+ }
+ ///
+ /// DbContext Example 2
+ ///
+ ///
+ public class DbContext where T : class, new()
+ {
+
+ public SqlSugarClient Db;
+ public DbContext()
+ {
+ Db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.Custom,
+ IsAutoCloseConnection = true,
+ InitKeyType = InitKeyType.Attribute,
+ AopEvents = new AopEvents()
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ }
+ }
+ });
+ }
+ public SimpleClient CurrentDb => new SimpleClient(Db);
+ public virtual T GetById(int id)
+ {
+ return CurrentDb.GetById(id);
+ }
+ public virtual List GetList()
+ {
+ return CurrentDb.GetList();
+ }
+ public virtual bool Delete(int id)
+ {
+ return CurrentDb.DeleteById(id);
+ }
+ }
+
+}
diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo1_Queryable.cs b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo1_Queryable.cs
new file mode 100644
index 000000000..9fcd3d05a
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo1_Queryable.cs
@@ -0,0 +1,573 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Dynamic;
+using System.Linq;
+using System.Text;
+namespace OrmTest
+{
+ public class Demo1_Queryable
+ {
+
+ public static void Init()
+ {
+ EasyExamples();
+ //QueryConditions();
+ JoinTable();
+ //Async();
+ //NoEntity();
+ //Mapper();
+ //SqlFuncTest();
+ //Subquery();
+ //ReturnType();
+ //ConfiQuery();
+ }
+
+ private static void ConfiQuery()
+ {
+ var db = GetInstance();
+ List datas = new List();
+ datas.Add(new DataDictionary() { Code="1", Name="男",Type="sex" });
+ datas.Add(new DataDictionary() { Code = "2", Name = "女", Type = "sex" });
+ datas.Add(new DataDictionary() { Code = "1", Name = "南通市", Type = "city" });
+ datas.Add(new DataDictionary() { Code = "2", Name = "苏州市", Type = "city" });
+ datas.Add(new DataDictionary() { Code = "1", Name = "江苏省", Type = "province" });
+ datas.Add(new DataDictionary() { Code = "2", Name = "湖南省", Type = "province" });
+ db.CodeFirst.InitTables();
+ db.CodeFirst.InitTables();
+ db.DbMaintenance.TruncateTable();
+ db.Insertable(datas).ExecuteCommand();
+
+ if (!db.ConfigQuery.Any())
+ {
+ var types= db.Queryable().Select(it => it.Type).Distinct().ToList();
+ foreach (var type in types)
+ {
+ db.ConfigQuery.SetTable(it => it.Code, it => it.Name, type, it => it.Type == type);
+ }
+
+ db.ConfigQuery.SetTable(it => it.Id, it => it.Name, "01", it => it.Id > 1);
+ db.ConfigQuery.SetTable(it => it.Id, it => it.Name, "02", it => it.Id > 2);
+ db.ConfigQuery.SetTable(it => it.Id, it => it.Name, null);
+ }
+
+
+ var res=db.Queryable().Select(it => new Person()
+ {
+ Id=it.Id.SelectAll(),
+ SexName=it.SexId.GetConfigValue("sex"),
+ ProviceName = it.SexId.GetConfigValue("province"),
+ CityName = it.SexId.GetConfigValue("city"),
+ }).ToList();//也支持支持写在Where或者Orderby
+
+ var list = db.Queryable().Select(it => new OrderItem
+ {
+ ItemId = it.ItemId.SelectAll(),
+ OrderName = it.OrderId.GetConfigValue("01")
+ }).ToList();
+ var list2 = db.Queryable().Select(it => new OrderItem
+ {
+ ItemId = it.ItemId.SelectAll(),
+ OrderName = it.OrderId.GetConfigValue("02")
+ }).ToList();
+ var list3 = db.Queryable().Select(it => new OrderItem
+ {
+ ItemId = it.ItemId.SelectAll(),
+ OrderName = it.OrderId.GetConfigValue()
+ }).ToList();
+
+ var list4 = db.Queryable().Select(it => new OrderItem
+ {
+ ItemId = it.ItemId.SelectAll(),
+ OrderName = it.OrderId.GetConfigValue()
+ })
+ .Where(it=>it.OrderId.GetConfigValue()== "order1")
+ .OrderBy(it=>it.OrderId.GetConfigValue()).ToList();
+
+ var list5 = db.Queryable((o, i) => o.Id == i.OrderId)
+ .OrderBy((o,i)=>i.OrderId.GetConfigValue(),OrderByType.Desc)
+ .Select((o,i)=>new ViewOrder() {
+ Id= o.Id.SelectAll(),
+ Name=i.OrderId.GetConfigValue()
+ })
+ .ToList();
+ }
+
+ private static void EasyExamples()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Examples Start ####");
+ var db = GetInstance();
+ var dbTime = db.GetDate();
+ var getAll = db.Queryable().ToList();
+ var getTake = db.Queryable().Take(2).ToList();
+ var getSkip = db.Queryable().Skip(2).ToList();
+ var getOrderBy = db.Queryable().OrderBy(it => it.Name,OrderByType.Desc).ToList();
+ var getOrderBy2 = db.Queryable().OrderBy(it => it.Id).OrderBy(it => it.Name, OrderByType.Desc).ToList();
+ var getOrderBy3 = db.Queryable().OrderBy(it =>new { it.Name,it.Id}).ToList();
+ var getRandom = db.Queryable().OrderBy(it => SqlFunc.GetRandom()).First();
+ var getByPrimaryKey = db.Queryable().InSingle(2);
+ var getSingleOrDefault = db.Queryable().Where(it => it.Id == 1).Single();
+ var getFirstOrDefault = db.Queryable().First();
+ var getByWhere = db.Queryable().Where(it => it.Id == 1 || it.Name == "a").ToList();
+ var getByWhere2 = db.Queryable().Where(it => it.Id == DateTime.Now.Year).ToList();
+ var getByFuns = db.Queryable().Where(it => SqlFunc.IsNullOrEmpty(it.Name)).ToList();
+ // var getByFuns2 = db.Queryable().GroupBy(it => it.Name).Select(it => SqlFunc.AggregateDistinctCount(it.Price)).ToList();
+ var getDicionary = db.Queryable().ToDictionary(it => it.Id, it => it.Name);
+ var getDicionaryList = db.Queryable().ToDictionaryList();
+ var getTest = db.Queryable().Where(it =>string.IsNullOrWhiteSpace( it.Name)).ToList();
+ // var test01 = db.Queryable().PartitionBy(it => it.Id).ToList();
+ var q1 = db.Queryable().Take(1);
+ var q2 = db.Queryable().Take(2);
+ //var test02 = db.Union(q1, q2).ToList();
+ var test03 = db.Queryable().Take(1).ToList();
+ var dp = DateTime.Now;
+ var test05 = db.Queryable().Where(it => it.CreateTime.Month== dp.Month).ToList();
+ var test06 = db.Queryable()
+ .ToPivotTable(it => it.Id, it => it.Name, it => it.Sum(x => x.Price));
+
+ var test07 = db.Queryable()
+ .ToPivotList(it => it.Id, it => it.Name, it => it.Sum(x => x.Price));
+
+ var test08 = db.Queryable()
+ .ToPivotJson(it => it.Id, it => it.Name, it => it.Sum(x => x.Price));
+
+ //var test09 = db.Queryable().PartitionBy(it=>it.Id).ToPageListAsync(1,2,0);
+ //test09.Wait();
+
+ int c = 0;
+ var test10 = db.Queryable().OrderBy(it=>it.Id).ToPageList(3,5, ref c);
+ var test11 = db.Queryable().GroupBy(it=>new { it.CreateTime.Year }).Select(it=>it.CreateTime.Year).ToList();
+ // var test12 = db.Queryable().GroupBy(it => it.CreateTime.Date ).Select(it => it.CreateTime.Date).ToList();
+ //var test13 = db.Queryable().GroupBy(it => new { it.CreateTime.Date ,it.CreateTime.Year,it.CreateTime.Minute })
+ // .Select(it => new { it.CreateTime.Date, it.CreateTime.Year, it.CreateTime.Minute }).ToList();
+ //var test14 = db.Queryable()
+ // .GroupBy(it => it.CreateTime.Year )
+ // .GroupBy(it => it.CreateTime.Second)
+ // .GroupBy(it => it.CreateTime.Date)
+ // .Select(it => new {
+ // it.CreateTime.Year,
+ // it.CreateTime.Second,
+ // it.CreateTime.Date
+ // }).ToList();
+ var test15 = db.Queryable((o, i) => new JoinQueryInfos(
+ JoinType.Left, o.Name == SqlFunc.ToString(SqlFunc.MergeString(",", i.Name, ","))
+ ))
+ .Select().ToList();
+ // var test16 = db.Queryable().Select(it => SqlFunc.SqlServer_DateDiff("day", DateTime.Now.AddDays(-1), DateTime.Now)).ToList();
+ //var test17 =
+ // db.Queryable()
+ // .Select()
+ // .MergeTable()
+ // .Select(it => new ViewOrder()
+ // {
+ // Name = SqlFunc.Subqueryable().Select(s => s.Name)
+ // }).ToList(); ;
+ //var test18 = db.UnionAll(
+ // db.Queryable() ,
+ // db.Queryable()
+ // )
+ // .Select(it=>new ViewOrder(){
+ // Name=SqlFunc.Subqueryable().Select(s=>s.Name)
+ // }).ToList();
+ var test19 = db.Queryable().Select().ToList();
+ var test20 = db.Queryable().LeftJoin((o, cs) =>o.Id==cs.Id)
+ .ToDictionary(it => it.Id, it => it.Name);
+
+ //var test21 = db.Queryable().Where(it=>it.Id.ToString()==1.ToString()).Select(it => it.CreateTime.ToString("24")).First();
+ Console.WriteLine("#### Examples End ####");
+ }
+
+ private static void ReturnType()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### ReturnType Start ####");
+ var db = GetInstance();
+ List list = db.Queryable().ToList();
+
+ var x2=db.Ado.SqlQueryAsync("select * from [Order] ");
+ x2.Wait();
+ var x22 = db.Ado.GetScalarAsync("select * from [Order] ");
+ x22.Wait();
+ var x222 = db.Ado.ExecuteCommandAsync("select * from [Order] ");
+ x222.Wait();
+ Order item = db.Queryable().First(it => it.Id == 1);
+
+ DataTable dataTable = db.Queryable().Select(it => it.Id).ToDataTable();
+
+ var json = db.Queryable().ToJson();
+
+ List listInt = db.Queryable().Select(it => it.Id).ToList();
+
+ var dynamic = db.Queryable().Select().ToList();
+
+ var viewModel = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId ,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select().ToList();
+
+ var newDynamic = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select((o, i, c) => new { orderName = o.Name, cusName=c.Name }).ToList();
+
+ var newClass = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select((o, i, c) => new ViewOrder { Name=o.Name, CustomName=c.Name }).ToList();
+
+
+ var oneClass = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select((o, i, c) => c).ToList();
+
+ var twoClass = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select((o, i, c) => new { o,i}).ToList();
+
+ List> ListDic = db.Queryable((o, i, c) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId,
+ JoinType.Left, o.CustomId == c.Id
+ ))
+ .Select().ToList().Select(it => it.ToDictionary(x => x.Key, x => x.Value)).ToList();
+ Console.WriteLine("#### ReturnType End ####");
+ }
+
+ private static void Subquery()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Subquery Start ####");
+ var db = GetInstance();
+
+ var list = db.Queryable().Take(10).Select(it => new
+ {
+ customName=SqlFunc.Subqueryable().Where("it.CustomId=id").Select(s=>s.Name),
+ customName2 = SqlFunc.Subqueryable().Where("it.CustomId = id").Where(s => true).Select(s => s.Name)
+ }).ToList();
+
+ var list1 = db.Queryable().Select(it => new
+ {
+ id = SqlFunc.Subqueryable().Where(s => s.Id == 1).Sum(s => s.Id) * 1
+ }).ToList();
+
+ var list2 = db.Queryable().Where(it =>
+ SqlFunc.Subqueryable()
+ .LeftJoin((i,z)=>i.ItemId==z.ItemId)
+ .InnerJoin((i,z,y) => i.ItemId == z.ItemId)
+ .InnerJoin((i,z,y,h) => i.ItemId == z.ItemId)
+ .InnerJoin((i, z, y, h, n) => i.ItemId == z.ItemId)
+ .Where((i, z) => i.ItemId == z.ItemId)
+ .Any()
+ ).ToList();
+
+ var list3 = db.Queryable().Select(it => new
+ {
+ customName = SqlFunc.Subqueryable().Where(s=>s.Id==it.CustomId).GroupBy(s=>s.Name).Having(s=>SqlFunc.AggregateCount(s.Id)>0).Select(s => s.Name)
+ }).ToList();
+
+
+ var exp = Expressionable.Create().And(s => s.Id==1).ToExpression();
+ var list4 = db.Queryable().Select(it => new
+ {
+ customName = SqlFunc.Subqueryable().Where(exp).Where(exp).GroupBy(s => s.Name).Having(s => SqlFunc.AggregateCount(s.Id) > 0).Select(s => s.Name)
+ }).ToList();
+
+
+ var list5 = db.Queryable().Where(it =>
+ SqlFunc.Subqueryable()
+ .LeftJoin((i, y) => i.ItemId == y.ItemId)
+ .InnerJoin((i, z) => i.ItemId == z.ItemId)
+ .Where(i => i.ItemId == 1)
+ .Any()
+ ).ToList();
+ Console.WriteLine("#### Subquery End ####");
+ }
+
+ private static void SqlFuncTest()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### SqlFunc Start ####");
+ var db = GetInstance();
+ var index= db.Queryable().Select(it => SqlFunc.CharIndex("a", "cccacc")).First();
+ var list = db.Queryable().Select(it =>new ViewOrder()
+ {
+
+ Id = SqlFunc.AggregateSum(SqlFunc.IF(it.Id > 0).Return(1).End(0))
+ }).ToList();
+ var list2 = db.Queryable().Where(it=>it.CreateTime.Date==it.CreateTime).Select(it => new
+ {
+ date = it.CreateTime.Date,
+ datetime = DateTime.Now.Date
+ }).ToList();
+ Console.WriteLine("#### SqlFunc End ####");
+ }
+
+ private static void Mapper()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Mapper Start ####");
+ var db = GetInstance();
+ //Creater Table
+ db.CodeFirst.InitTables(typeof(Tree));
+ db.DbMaintenance.TruncateTable("tree");
+ db.Insertable(new Tree() { Id = 1, Name = "root" }).ExecuteCommand();
+ db.Insertable(new Tree() { Id = 11, Name = "child1",ParentId=1 }).ExecuteCommand();
+ db.Insertable(new Tree() { Id = 12, Name = "child2",ParentId=1 }).ExecuteCommand();
+ db.Insertable(new Tree() { Id = 2, Name = "root" }).ExecuteCommand();
+ db.Insertable(new Tree() { Id = 22, Name = "child3", ParentId = 2 }).ExecuteCommand();
+
+ // Same property name mapping,Both entities have parentId
+ var list = db.Queryable().Mapper(it => it.Parent, it => it.ParentId).ToList();
+
+
+ //If both entities have parentId, I don't want to associate with parentId.
+ var list1 =db.Queryable()
+ //parent=(select * from parent where id=it.parentid)
+ .Mapper(it=>it.Parent,it=>it.ParentId, it=>it.Parent.Id)
+ //Child=(select * from parent where ParentId=it.id)
+ .Mapper(it => it.Child, it => it.Id, it => it.Parent.ParentId)
+ .ToList();
+
+
+ db.Insertable(new Tree() { Id = 222, Name = "child11", ParentId = 11 }).ExecuteCommand();
+ var tree = db.Queryable().ToTree(it => it.Child, it => it.ParentId, 0);
+ var allchilds= db.Queryable().ToChildList(it => it.ParentId, 0);
+ var allchilds1 = db.Queryable().ToChildList(it => it.ParentId, 1);
+ var allchilds2= db.Queryable().ToChildList(it => it.ParentId, 2);
+ var parentList = db.Queryable().ToParentList(it => it.ParentId, 22);
+ var parentList2 = db.Queryable().ToParentList(it => it.ParentId, 222);
+ var parentList3 = db.Queryable().ToParentList(it => it.ParentId, 2);
+
+ //one to one
+ var list2 = db.Queryable().Mapper(it => it.Order, it => it.OrderId).ToList();
+
+ //one to many
+ var list3 = db.Queryable().Mapper(it => it.Items, it => it.Items.First().OrderId).ToList();
+
+ //many to many
+ db.CodeFirst.InitTables();
+
+ db.Insertable(new A() { Name = "A" }).ExecuteCommand();
+ db.Insertable(new B() { Name = "B" }).ExecuteCommand();
+ db.Insertable(new ABMapping() { AId = 1, BId = 1 }).ExecuteCommand();
+
+ var list4 = db.Queryable()
+ .Mapper(it => it.A, it => it.AId)
+ .Mapper(it => it.B, it => it.BId).ToList();
+
+ //Manual mode
+ var result = db.Queryable().Take(10).Select().Mapper((itemModel, cache) =>
+ {
+ var allItems = cache.Get(orderList => {
+ var allIds = orderList.Select(it => it.Id).ToList();
+ return db.Queryable().Where(it => allIds.Contains(it.OrderId)).ToList();//Execute only once
+ });
+ itemModel.Items = allItems.Where(it => it.OrderId==itemModel.Id).ToList();//Every time it's executed
+ }).ToList();
+
+ Console.WriteLine("#### End Start ####");
+ }
+
+ private static void NoEntity()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### No Entity Start ####");
+ var db = GetInstance();
+
+ var list = db.Queryable().AS("order ").Where("id=id", new { id = 1 }).ToList();
+
+ var list2 = db.Queryable("o").AS("order").AddJoinInfo("OrderDetail", "i", "o.id=i.OrderId").Where("id=id", new { id = 1 }).Select("o.*").ToList();
+ Console.WriteLine("#### No Entity End ####");
+ }
+
+ private static void JoinTable()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Join Table Start ####");
+ var db = GetInstance();
+
+ //Simple join
+ var list = db.Queryable((o, i, c) => o.Id == i.OrderId&&c.Id == o.CustomId)
+ .Select()
+ .ToList();
+
+ // //Join table
+ // var list2 = db.Queryable((o, i, c) => new JoinQueryInfos(
+ // JoinType.Left, o.Id == i.OrderId,
+ // JoinType.Left, c.Id == o.CustomId
+ // ))
+ //.Select().ToList();
+
+ //Join queryable
+ var query1 = db.Queryable((o, i) => new JoinQueryInfos(
+ JoinType.Left, o.Id == i.OrderId
+ ))
+ .Where(o => o.Name == "jack");
+
+ var query2 = db.Queryable();
+ var list3=db.Queryable(query1, query2,JoinType.Left, (p1, p2) => p1.CustomId == p2.Id).Select().ToList();
+
+
+ var query3 = db.Union(
+ db.Queryable().Where(it => it.Name.Contains("a")),
+ db.Queryable().Where(it => it.Name.Contains("b"))
+ ).ToList();
+
+
+
+ //var query4 = db.Queryable(
+ // db.Queryable().Where(it => it.Name.Contains("a")),
+ // db.Queryable().Where(it => it.CreateTime>DateTime.Now),
+ // db.Queryable().Where(it => it.Name.Contains("b")),
+ // JoinType.Left, (o, i, c) => o.Id==i.OrderId,
+ // JoinType.Left,(o,i,c)=>o.CustomId==c.Id
+
+ // ).Select(o=>o).ToList();
+
+
+ //var query5 = db.Queryable()
+ // .InnerJoin((o, cus) => o.CustomId == cus.Id)
+ // .InnerJoin((o, cus, oritem) => o.Id == oritem.OrderId)
+ // .Where((o) => o.Id == 1)
+ // .Select((o, cus) => new ViewOrder { Id=o.Id, CustomName = cus.Name })
+ // .ToList();
+
+ //var query6 = db.Queryable(db.Queryable()).LeftJoin((m, i) => m.Id == i.OrderId)
+ // .ToList();
+
+
+ //var query7 = db.Queryable(db.Queryable().Select().MergeTable()).LeftJoin((m, i) => m.Id == i.OrderId)
+ // .ToList();
+
+
+ //var query8 = db.Queryable()
+ // .LeftJoin(db.Queryable().Where(it=>it.Id==1),(o,i)=>o.CustomId==i.Id)
+ // .LeftJoin(db.Queryable().Where(it=>it.OrderId==2),(o,i,item)=>item.OrderId==o.Id)
+ // .LeftJoin(db.Queryable().Where(it => it.Id >0), (o, i, item, od) => od.Id == o.Id)
+ // .Select(o => o).ToList();
+
+ Console.WriteLine("#### Join Table End ####");
+ }
+
+ private static void QueryConditions()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Query Conditions Start ####");
+
+ SqlSugarClient db = GetInstance();
+
+ /*** By expression***/
+
+ //id=@id
+ var list = db.Queryable().Where(it => it.Id == 1).ToList();
+ //id=@id or name like '%'+@name+'%'
+ var list2 = db.Queryable().Where(it => it.Id == 1 || it.Name.Contains("jack")).ToList();
+
+
+ //Create expression
+ var exp = Expressionable.Create()
+ .And(it => it.Id == 1)
+ .Or(it => it.Name.Contains("jack")).ToExpression();
+ var list3 = db.Queryable().Where(exp).ToList();
+
+
+ /*** By sql***/
+
+ //id=@id
+ var list4 = db.Queryable().Where("id=@id", new { id = 1 }).ToList();
+ //id=@id or name like '%'+@name+'%'
+ var list5 = db.Queryable().Where("id=@id or name like '%'+@name+'%' ", new { id = 1, name = "jack" }).ToList();
+
+
+
+ /*** By dynamic***/
+
+ //id=1
+ var conModels = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+ var student = db.Queryable().Where(conModels).ToList();
+
+ //Complex use case
+ List Order = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Like, FieldValue = "1" });// id like '%1%'
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNullOrEmpty });
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.In, FieldValue = "1,2,3" });
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NotIn, FieldValue = "1,2,3" });
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NoEqual, FieldValue = "1,2,3" });
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNot, FieldValue = null });// id is not null
+
+ conModels.Add(new ConditionalCollections()
+ {
+ ConditionalList = new List>()// (id=1 or id=2 and id=1)
+ {
+ //new KeyValuePair( WhereType.And ,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" }),
+ new KeyValuePair (WhereType.Or,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" }),
+ new KeyValuePair ( WhereType.And,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" })
+ }
+ });
+ var list6 = db.Queryable().Where(conModels).ToList();
+
+ /*** Conditional builder ***/
+
+ // use whereif
+ string name = "";
+ int id = 1;
+ var query = db.Queryable()
+ .WhereIF(!string.IsNullOrEmpty(name), it => it.Name.Contains(name))
+ .WhereIF(id > 0, it => it.Id == id).ToList();
+ //clone new Queryable
+ var query2 = db.Queryable().Where(it => it.Id == 1);
+ var list7 = query2.Clone().Where(it => it.Name == "jack").ToList();//id=1 and name = jack
+ var list8 = query2.Clone().Where(it => it.Name == "tom").ToList();//id=1 and name = tom
+
+ Console.WriteLine("#### Condition Screening End ####");
+
+
+
+ }
+
+ private static void Async()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Async Start ####");
+
+ SqlSugarClient db = GetInstance();
+ var task1 = db.Queryable().FirstAsync();
+ task1.Wait();
+ var task2 = db.Queryable().Where(it => it.Id == 1).ToListAsync();
+
+
+ task2.Wait();
+
+ Console.WriteLine("#### Async End ####");
+ }
+
+ private static SqlSugarClient GetInstance()
+ {
+ return new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = SqlSugar.DbType.Custom,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo2_Updateable.cs b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo2_Updateable.cs
new file mode 100644
index 000000000..f32584fd8
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo2_Updateable.cs
@@ -0,0 +1,118 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo2_Updateable
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Updateable Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Custom,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+
+
+
+ /*** 1.entity or List ***/
+
+ var updateObj = new Order() { Id = 1, Name = "order1" };
+ //var updateObjs = new List {
+ // new Order() { Id = 11, Name = "order11" },
+ // new Order() { Id = 12, Name = "order12" }
+ //};
+
+ //update all columns by primary key
+ var result = db.Updateable(updateObj).ExecuteCommand();//update single
+ //var result2 = db.Updateable(updateObjs).ExecuteCommand();//update List
+
+ //Ignore Name and Price
+ var result3 = db.Updateable(updateObj).IgnoreColumns(it => new { it.CreateTime, it.Price }).ExecuteCommand();
+
+ //only update Name and CreateTime
+ var result4 = db.Updateable(updateObj).UpdateColumns(it => new { it.Name, it.CreateTime }).ExecuteCommand();
+
+ //If there is no primary key
+ var result5 = db.Updateable(updateObj).WhereColumns(it => new { it.Id }).ExecuteCommand();//update single by id
+ //var result6 = db.Updateable(updateObjs).WhereColumns(it => new { it.Id }).ExecuteCommand();//update List by id
+
+ //Re set value
+ //var result66 = db.Updateable(new List { updateObj }).ReSetValue(it => it.Id = 112).IgnoreColumns(it => new { it.CreateTime, it.Price }).ExecuteCommand();
+
+
+
+ /*** 2.by expression ***/
+
+ //update name,createtime
+ var result7 = db.Updateable(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
+ var result71 = db.Updateable().SetColumns(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
+ //only update name
+ var result8 = db.Updateable(it => it.Name == "Name" + "1").Where(it => it.Id == 1).ExecuteCommand();
+ var result81 = db.Updateable().SetColumns(it => it.Name == "Name" + "1").Where(it => it.Id == 1).ExecuteCommand();
+ //
+
+
+
+
+ /*** 3.by Dictionary ***/
+ var dt = new Dictionary();
+ dt.Add("id", 1);
+ dt.Add("name", "abc");
+ dt.Add("createTime", DateTime.Now);
+ var dtList = new List>();
+ dtList.Add(dt);
+
+
+ // var t666 = db.Updateable(dtList).AS("[Order]").WhereColumns("id").ExecuteCommand();
+
+
+
+ /*** 4.Other instructions ***/
+
+ var caseValue = "1";
+ //Do not update NULL columns
+ db.Updateable(updateObj).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand();
+
+ //if 1 update name else if 2 update name,createtime
+ db.Updateable(updateObj)
+ .UpdateColumnsIF(caseValue == "1", it => new { it.Name })
+ .UpdateColumnsIF(caseValue == "2", it => new { it.Name, it.CreateTime })
+ .ExecuteCommand();
+ //Use Lock
+ db.Updateable(updateObj).With(SqlWith.UpdLock).ExecuteCommand();
+
+ //Where Sql
+ //db.Updateable(updateObj).Where("id=@x", new { x = "1" }).ExecuteCommand();
+
+
+ var levelCode = "123213123131321";
+ db.Updateable(a => a.Name == "a")
+ .Where(a => SqlFunc.StartsWith(a.Name, levelCode))
+ .AddQueue();
+ db.SaveQueues();
+
+ //var dataTable = db.Queryable().Select("id,name,1 as price").Take(2).ToDataTable();
+ //db.Fastest().BulkUpdate("Order", dataTable,new string[] {"id" },new string[] {"name" });
+ Console.WriteLine("#### Updateable End ####");
+ }
+
+ }
+}
\ No newline at end of file
diff --git a/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo3_Insertable.cs b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo3_Insertable.cs
new file mode 100644
index 000000000..b5ac40e31
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSeverTest/CustomDbTest/Demo3_Insertable.cs
@@ -0,0 +1,326 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo3_Insertable
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Insertable Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Custom,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+
+ var insertObj = new Order() { Id = 1, Name = "order1", Price = 0 };
+ //var insertObjs = new List {
+ // new Order() { Id = 11, Name = "XX", Price=0 },
+ // new Order() { Id = 12, Name = "XX2" , Price=0}
+ //};
+
+ //var x=db.Insertable(insertObjs).RemoveDataCache().IgnoreColumns(it=>it.CreateTime).UseParameter().ExecuteCommand();
+
+ //Ignore CreateTime
+ db.Insertable(insertObj).IgnoreColumns(it => new { it.CreateTime }).ExecuteReturnIdentity();//get identity
+ db.Insertable(insertObj).IgnoreColumns("CreateTime").ExecuteReturnIdentity();
+
+ //Only insert Name and Price
+ db.Insertable(insertObj).InsertColumns(it => new { it.Name, it.Price }).ExecuteReturnIdentity();
+ db.Insertable(insertObj).InsertColumns("Name", "Price").ExecuteReturnIdentity();
+
+ //ignore null columns
+ // db.Insertable(insertObjs).ExecuteCommand();//get change row count
+
+ //Use Lock
+ db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteCommand();
+
+ //insertObjs = new List {
+ // new Order() { Id = 11, Name = "order11", Price=1 },
+ // new Order() { Id = 12, Name = "order12" , Price=20, CreateTime=DateTime.Now, CustomId=1}
+ //};
+ //db.Insertable(insertObjs).UseSqlServer().ExecuteBulkCopy();
+ var dt = db.Queryable().Take(5).ToDataTable();
+ dt.TableName = "Order";
+ //db.Insertable(dt).UseSqlServer().ExecuteBulkCopy();
+ // db.CodeFirst.InitTables();
+ // db.CodeFirst.InitTables();
+ // db.DbMaintenance.TruncateTable("RootTable0");
+ // db.DbMaintenance.TruncateTable("TwoItem");
+ // db.DbMaintenance.TruncateTable("TwoItem2");
+ // db.DbMaintenance.TruncateTable("TwoItem3");
+ // db.DbMaintenance.TruncateTable("ThreeItem2");
+ // Console.WriteLine("SubInsert Start");
+
+ // db.Insertable(new Order()
+ // {
+ // Name = "订单 1",
+ // CustomId = 1,
+ // Price = 100,
+ // CreateTime = DateTime.Now,
+ // Id = 0,
+ // Items = new List() {
+ // new OrderItem(){
+ // CreateTime=DateTime.Now,
+ // OrderId=0,
+ // Price=1,
+ // ItemId=1
+ // },
+ // new OrderItem(){
+ // CreateTime=DateTime.Now,
+ // OrderId=0,
+ // Price=2,
+ // ItemId=2
+ // }
+ // }
+ // })
+ // .AddSubList(it => it.Items.First().OrderId).ExecuteCommand();
+
+
+
+ // db.Insertable(new List() {
+ // new RootTable0()
+ // {
+ // Name="aa",
+ // TwoItem2=new TwoItem2() {
+ // Id="1",
+ // ThreeItem2=new List(){
+ // new ThreeItem2(){ Name="a", TwoItem2Id="1" },
+ // new ThreeItem2(){ Id=2, Name="a2", TwoItem2Id="2" }
+ // }
+ // },
+ // TwoItem=new TwoItem()
+ // {
+ // Name ="itema" ,
+ // RootId=2
+ // },
+ // TwoItem3=new List(){
+ // new TwoItem3(){ Id=0, Name="a",Desc="" },
+
+ // }
+ // },
+ // new RootTable0()
+ // {
+ // Name="bb",
+ // TwoItem2=new TwoItem2() {
+ // Id="2"
+ // },
+ // TwoItem=new TwoItem()
+ // {
+ // Name ="itemb" ,
+ // RootId=2,
+
+ // },
+ // TwoItem3=new List(){
+ // new TwoItem3(){ Id=1, Name="b",Desc="" },
+ // new TwoItem3(){ Id=2, Name="b1",Desc="1" },
+ // }
+ // }
+ // })
+ //.AddSubList(it => it.TwoItem.RootId)
+ //.AddSubList(it => new SubInsertTree()
+ //{
+ // Expression = it.TwoItem2.RootId,
+ // ChildExpression = new List() {
+ // new SubInsertTree(){
+ // Expression=it.TwoItem2.ThreeItem2.First().TwoItem2Id
+ // }
+ // }
+ //})
+ //.AddSubList(it => it.TwoItem3)
+ //.ExecuteCommand();
+
+ // SubNoIdentity(db);
+ // SubIdentity(db);
+
+
+
+
+ //db.Fastest().BulkCopy(insertObjs);
+
+
+ //var dataTable= db.Queryable().Select("id,name,Price").Take(2).ToDataTable();
+ //int result= db.Fastest().BulkCopy("order", dataTable);
+ Console.WriteLine("#### Insertable End ####");
+
+ }
+
+ private static void SubNoIdentity(SqlSugarClient db)
+ {
+ db.CodeFirst.InitTables();
+ db.DbMaintenance.TruncateTable("Country");
+ db.DbMaintenance.TruncateTable("Province");
+ db.DbMaintenance.TruncateTable("City");
+ db.Insertable(new List()
+ {
+ new Country(){
+ Id=1,
+ Name="中国",
+ Provinces=new List