diff --git a/Src/Asp.Net/DmTest/App.config b/Src/Asp.Net/DmTest/App.config
new file mode 100644
index 000000000..8e1564635
--- /dev/null
+++ b/Src/Asp.Net/DmTest/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/Src/Asp.Net/DmTest/Config.cs b/Src/Asp.Net/DmTest/Config.cs
new file mode 100644
index 000000000..ea24f40bd
--- /dev/null
+++ b/Src/Asp.Net/DmTest/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
+ /// 设置好数据库名不需要你去手动建库
+ ///
+ public class Config
+ {
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString = "PORT=5236;DATABASE=DAMENG;HOST=localhost;PASSWORD=SYSDBA;USER ID=SYSDBA";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString2 = "PORT=5236;DATABASE=DAMENG;HOST=localhost;PASSWORD=SYSDBA;USER ID=SYSDBA";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString3 = "PORT=5236;DATABASE=DAMENG;HOST=localhost;PASSWORD=SYSDBA;USER ID=SYSDBA";
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo0_SqlSugarClient.cs b/Src/Asp.Net/DmTest/Demo/Demo0_SqlSugarClient.cs
new file mode 100644
index 000000000..8ed1c8415
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo0_SqlSugarClient.cs
@@ -0,0 +1,416 @@
+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.Dm,
+ 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.Dm,
+ 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.PageCount);
+ var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc);
+ Console.Write(p.PageCount);
+ List conModels = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1", FieldValueConvertFunc=it=>Convert.ToInt32(it) });//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.Dm,
+ 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 SqlSugarClient singleDb = new SqlSugarClient(
+ new ConnectionConfig()
+ {
+ ConfigId = 1,
+ DbType = DbType.Dm,
+ 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.Dm, ConnectionString=Config.ConnectionString,InitKeyType=InitKeyType.Attribute,IsAutoCloseConnection=true },
+ new ConnectionConfig(){ ConfigId="2", DbType=DbType.Dm, 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");
+
+ var result2 = db.UseTranAsync(() =>
+ {
+
+ 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("");
+
+ });
+ result2.Wait();
+ if (result.IsSuccess == false)
+ {
+ 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());
+ }
+
+ Console.WriteLine("#### Distributed TransactionExample End ####");
+ }
+ }
+
+ ///
+ /// DbContext Example 1
+ ///
+ public class DbContext
+ {
+
+ public SqlSugarClient Db;
+ public DbContext()
+ {
+ Db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.Dm,
+ 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.Dm,
+ 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.Net/DmTest/Demo/Demo1_Queryable.cs b/Src/Asp.Net/DmTest/Demo/Demo1_Queryable.cs
new file mode 100644
index 000000000..d14fa8bf7
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo1_Queryable.cs
@@ -0,0 +1,341 @@
+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();
+ }
+
+ private static void EasyExamples()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Examples Start ####");
+ var db = GetInstance();
+ var dbTime = db.GetDate();
+ var getAll = db.Queryable().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();
+ Console.WriteLine("#### Examples End ####");
+ }
+
+ private static void ReturnType()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### ReturnType Start ####");
+ var db = GetInstance();
+ List list = db.Queryable().ToList();
+
+ 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 list2 = db.Queryable().Where(it => SqlFunc.Subqueryable().Where(i => i.OrderId == it.Id).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();
+
+ 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();
+ //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();
+
+ 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" , FieldValueConvertFunc=it=>Convert.ToInt32(it) });//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", FieldValueConvertFunc = it => Convert.ToInt32(it) });//id=1
+ //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Like, FieldValue = "1", FieldValueConvertFunc = it => Convert.ToInt32(it) });// 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" , FieldValueConvertFunc = it => Convert.ToInt32(it) }),
+ new KeyValuePair ( WhereType.And,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" ,FieldValueConvertFunc = it => Convert.ToInt32(it)})
+ }
+ });
+ 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.Dm,
+ 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.Net/DmTest/Demo/Demo2_Updateable.cs b/Src/Asp.Net/DmTest/Demo/Demo2_Updateable.cs
new file mode 100644
index 000000000..b213283d8
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo2_Updateable.cs
@@ -0,0 +1,107 @@
+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.Dm,
+ 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
+
+
+
+
+ /*** 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").Where(it => it.Id == 1).ExecuteCommand();
+ var result81 = db.Updateable().SetColumns(it => it.Name == "Name" ).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 t66 = db.Updateable(dt).AS("order").WhereColumns("id").ExecuteCommand();
+ 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();
+
+ Console.WriteLine("#### Updateable End ####");
+ }
+
+ }
+}
\ No newline at end of file
diff --git a/Src/Asp.Net/DmTest/Demo/Demo3_Insertable.cs b/Src/Asp.Net/DmTest/Demo/Demo3_Insertable.cs
new file mode 100644
index 000000000..715dc433b
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo3_Insertable.cs
@@ -0,0 +1,56 @@
+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.Dm,
+ 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 updateObjs = new List {
+ new Order() { Id = 11, Name = "order11", Price=0 },
+ new Order() { Id = 12, Name = "order12" , Price=0}
+ };
+
+ //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(updateObjs).ExecuteCommand();//get change row count
+
+ //Use Lock
+ db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteCommand();
+
+ Console.WriteLine("#### Insertable End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo4_Deleteable.cs b/Src/Asp.Net/DmTest/Demo/Demo4_Deleteable.cs
new file mode 100644
index 000000000..1a380b214
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo4_Deleteable.cs
@@ -0,0 +1,48 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo4_Deleteable
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Deleteable Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+ //by entity
+ db.Deleteable().Where(new Order() { Id = 1111 }).ExecuteCommand();
+
+ //by primary key
+ db.Deleteable().In(1111).ExecuteCommand();
+
+ //by primary key array
+ db.Deleteable().In(new int[] { 1111, 2222 }).ExecuteCommand();
+
+ //by expression
+ db.Deleteable().Where(it => it.Id == 11111).ExecuteCommand();
+
+ Console.WriteLine("#### Deleteable End ####");
+
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo5_SqlQueryable.cs b/Src/Asp.Net/DmTest/Demo/Demo5_SqlQueryable.cs
new file mode 100644
index 000000000..82a6c0394
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo5_SqlQueryable.cs
@@ -0,0 +1,36 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo5_SqlQueryable
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### SqlQueryable Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true
+ });
+
+ int total = 0;
+ var list = db.SqlQueryable("select * from \"ORDER\"").ToPageList(1, 2, ref total);
+
+
+ //by expression
+ var list2 = db.SqlQueryable("select * from \"ORDER\"").Where(it => it.Id == 1).ToPageList(1, 2);
+ //by sql
+ var list3 = db.SqlQueryable("select * from \"ORDER\"").Where("id=@id", new { id = 1 }).ToPageList(1, 2);
+
+ Console.WriteLine("#### SqlQueryable End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo6_Queue.cs b/Src/Asp.Net/DmTest/Demo/Demo6_Queue.cs
new file mode 100644
index 000000000..3f54ff514
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo6_Queue.cs
@@ -0,0 +1,52 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo6_Queue
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Queue Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+ db.Insertable(new Order() { Name = "a" }).AddQueue();
+ db.Insertable(new Order() { Name = "b" }).AddQueue();
+ db.SaveQueues();
+
+
+ db.Insertable(new Order() { Name = "a" }).AddQueue();
+ db.Insertable(new Order() { Name = "b" }).AddQueue();
+ db.Insertable(new Order() { Name = "c" }).AddQueue();
+ db.Insertable(new Order() { Name = "d" }).AddQueue();
+ var ar = db.SaveQueuesAsync();
+ ar.Wait();
+
+ db.Queryable().AddQueue();
+ db.Queryable().AddQueue();
+ db.AddQueue("select * from \"ORDER\" where id=@id", new { id = 10000 });
+ var result2 = db.SaveQueues();
+
+ Console.WriteLine("#### Queue End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo7_Ado.cs b/Src/Asp.Net/DmTest/Demo/Demo7_Ado.cs
new file mode 100644
index 000000000..84278dd58
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo7_Ado.cs
@@ -0,0 +1,57 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo7_Ado
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Ado Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+ //sql
+ var dt = db.Ado.GetDataTable("select * from \"ORDER\" where @id>0 or name=@name", new List(){
+ new SugarParameter("@id",1),
+ new SugarParameter("@name","2")
+ });
+
+ //sql
+ var dt2 = db.Ado.GetDataTable("select * from \"ORDER\" where @id>0 or name=@name", new { id = 1, name = "2" });
+
+ //Stored Procedure
+ //var dt3 = db.Ado.UseStoredProcedure().GetDataTable("sp_school", new { name = "张三", age = 0 });
+ //var nameP = new SugarParameter("@name", "张三");
+ //var ageP = new SugarParameter("@age", null, true);//isOutput=true
+ //var dt4 = db.Ado.UseStoredProcedure().GetDataTable("sp_school", nameP, ageP);
+
+
+
+ //There are many methods to under db.ado
+ var list= db.Ado.SqlQuery("select * from \"ORDER\" ");
+ var intValue=db.Ado.SqlQuerySingle("select 1");
+ db.Ado.ExecuteCommand("delete from \"ORDER\" where id>1000");
+ //db.Ado.xxx
+ Console.WriteLine("#### Ado End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo8_Saveable.cs b/Src/Asp.Net/DmTest/Demo/Demo8_Saveable.cs
new file mode 100644
index 000000000..256348255
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo8_Saveable.cs
@@ -0,0 +1,48 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo8_Saveable
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Saveable Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+
+
+ //insert or update
+ db.Saveable(new Order() { Id=1, Name="jack" }).ExecuteReturnEntity();
+
+
+ //insert or update
+ db.Saveable(new Order() { Id = 1000, Name = "jack", CreateTime=DateTime.Now })
+ .InsertColumns(it => new { it.Name,it.CreateTime, it.Price})//if insert into name,CreateTime,Price
+ .UpdateColumns(it => new { it.Name, it.CreateTime })//if update set name CreateTime
+ .ExecuteReturnEntity();
+
+ Console.WriteLine("");
+ Console.WriteLine("#### Saveable End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Demo9_EntityMain.cs b/Src/Asp.Net/DmTest/Demo/Demo9_EntityMain.cs
new file mode 100644
index 000000000..91008aab0
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Demo9_EntityMain.cs
@@ -0,0 +1,46 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Demo9_EntityMain
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### EntityMain Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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 entityInfo = db.EntityMaintenance.GetEntityInfo();
+ foreach (var column in entityInfo.Columns)
+ {
+ Console.WriteLine(column.DbColumnName);
+ }
+
+ var dbColumnsName = db.EntityMaintenance.GetDbColumnName("Name");
+
+ var dbTableName = db.EntityMaintenance.GetTableName();
+
+ //more https://github.com/sunkaixuan/SqlSugar/wiki/9.EntityMain
+ Console.WriteLine("#### EntityMain End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoA_DbMain.cs b/Src/Asp.Net/DmTest/Demo/DemoA_DbMain.cs
new file mode 100644
index 000000000..539c6a6ea
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoA_DbMain.cs
@@ -0,0 +1,42 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class DemoA_DbMain
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### DbMain Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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 tables = db.DbMaintenance.GetTableInfoList();
+ foreach (var table in tables)
+ {
+ Console.WriteLine(table.Description);
+ }
+ //more https://github.com/sunkaixuan/SqlSugar/wiki/a.DbMain
+ Console.WriteLine("#### DbMain End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoB_Aop.cs b/Src/Asp.Net/DmTest/Demo/DemoB_Aop.cs
new file mode 100644
index 000000000..07b37808c
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoB_Aop.cs
@@ -0,0 +1,68 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class DemoB_Aop
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Aop Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true
+ });
+ db.Aop.OnLogExecuted = (sql, pars) => //SQL executed event
+ {
+ Console.WriteLine("OnLogExecuted"+sql);
+ };
+ db.Aop.OnLogExecuting = (sql, pars) => //SQL executing event (pre-execution)
+ {
+ Console.WriteLine("OnLogExecuting" + sql);
+ };
+ db.Aop.OnError = (exp) =>//SQL execution error event
+ {
+ //exp.sql
+ };
+ db.Aop.OnExecutingChangeSql = (sql, pars) => //SQL executing event (pre-execution,SQL script can be modified)
+ {
+ return new KeyValuePair(sql, pars);
+ };
+ db.Aop.OnDiffLogEvent = it =>//Get data changes
+ {
+ var editBeforeData = it.BeforeData;
+ var editAfterData = it.AfterData;
+ var sql = it.Sql;
+ var parameter = it.Parameters;
+ var businessData = it.BusinessData;
+ var time = it.Time;
+ var diffType = it.DiffType;//enum insert 、update and delete
+ Console.WriteLine(businessData);
+ Console.WriteLine(editBeforeData[0].Columns[1].Value);
+ Console.WriteLine("to");
+ Console.WriteLine(editAfterData[0].Columns[1].Value);
+ //Write logic
+ };
+
+
+ db.Queryable().ToList();
+ db.Queryable().ToList();
+
+ //OnDiffLogEvent
+ var data = db.Queryable().First();
+ data.Name = "changeName";
+ db.Updateable(data).EnableDiffLogEvent("--update Order--").ExecuteCommand();
+
+ Console.WriteLine("#### Aop End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoD_DbFirst.cs b/Src/Asp.Net/DmTest/Demo/DemoD_DbFirst.cs
new file mode 100644
index 000000000..c7a987341
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoD_DbFirst.cs
@@ -0,0 +1,78 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ public class DemoD_DbFirst
+ {
+ public static void Init()
+ {
+ Console.WriteLine();
+ Console.WriteLine("#### DbFirst Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ MoreSettings=new ConnMoreSettings() {
+ PgSqlIsAutoToLower=false
+ }
+ });
+
+ db.DbFirst.CreateClassFile("c:\\Demo\\1", "Models");
+
+
+ db.DbFirst.Where("Student").CreateClassFile("c:\\Demo\\2", "Models");
+
+
+ db.DbFirst.Where(it => it.ToLower().StartsWith("view")).CreateClassFile("c:\\Demo\\3", "Models");
+
+
+ db.DbFirst.Where(it => it.ToLower().StartsWith("view")).CreateClassFile("c:\\Demo\\4", "Models");
+
+
+ db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\5", "Models");
+
+
+ db.DbFirst.IsCreateDefaultValue().CreateClassFile("c:\\Demo\\6", "Demo.Models");
+
+
+ db.DbFirst. SettingClassTemplate(old => { return old;})
+ .SettingNamespaceTemplate(old =>{ return old;})
+ .SettingPropertyDescriptionTemplate(old =>
+ {
+ return @" ///
+ /// Desc_New:{PropertyDescription}
+ /// Default_New:{DefaultValue}
+ /// Nullable_New:{IsNullable}
+ /// ";
+ })
+ .SettingPropertyTemplate(old =>{return old;})
+ .SettingConstructorTemplate(old =>{return old; })
+ .CreateClassFile("c:\\Demo\\7");
+
+
+
+ foreach (var item in db.DbMaintenance.GetTableInfoList())
+ {
+ string entityName = item.Name.ToUpper();/*Format class name*/
+ db.MappingTables.Add(entityName , item.Name);
+ foreach (var col in db.DbMaintenance.GetColumnInfosByTableName(item.Name))
+ {
+ db.MappingColumns.Add(col.DbColumnName.ToUpper() /*Format class property name*/, col.DbColumnName, entityName);
+ }
+ }
+ db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\8", "Models");
+
+
+ //Use Razor Template
+ //db.DbFirst.UseRazorAnalysis(RazorFirst.DefaultRazorClassTemplate).CreateClassFile("");
+
+ Console.WriteLine("#### DbFirst End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoE_CodeFirst.cs b/Src/Asp.Net/DmTest/Demo/DemoE_CodeFirst.cs
new file mode 100644
index 000000000..cea14d83b
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoE_CodeFirst.cs
@@ -0,0 +1,40 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ public class DemoE_CodeFirst
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### CodeFirst Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString3,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true
+ });
+ // db.DbMaintenance.CreateDatabase();
+ db.CodeFirst.InitTables(typeof(CodeFirstTable1));//Create CodeFirstTable1
+ db.Insertable(new CodeFirstTable1() { Name = "a", Text="a" }).ExecuteCommand();
+ var list = db.Queryable().ToList();
+ Console.WriteLine("#### CodeFirst end ####");
+ }
+ }
+
+ public class CodeFirstTable1
+ {
+ [SugarColumn(IsIdentity = true, IsPrimaryKey = true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ [SugarColumn(ColumnDataType = "varchar(255)")]//custom
+ public string Text { get; set; }
+ [SugarColumn(IsNullable = true)]
+ public DateTime CreateTime { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoF_Utilities.cs b/Src/Asp.Net/DmTest/Demo/DemoF_Utilities.cs
new file mode 100644
index 000000000..0bc041963
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoF_Utilities.cs
@@ -0,0 +1,46 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class DemoF_Utilities
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Utilities Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+
+
+ List ids = Enumerable.Range(1, 100).ToList();
+ db.Utilities.PageEach(ids, 10, list =>
+ {
+ Console.WriteLine(string.Join("," ,list));
+ });
+
+ var list2= db.Utilities.DataTableToList(db.Ado.GetDataTable("select * from \"ORDER\""));
+
+ //more https://github.com/sunkaixuan/SqlSugar/wiki/f.Utilities
+ Console.WriteLine("#### Utilities End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/DemoG_SimpleClient.cs b/Src/Asp.Net/DmTest/Demo/DemoG_SimpleClient.cs
new file mode 100644
index 000000000..cbd6f6036
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/DemoG_SimpleClient.cs
@@ -0,0 +1,36 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class DemoG_SimpleClient
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### SimpleClient Start ####");
+
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+
+ Console.WriteLine("#### SimpleClient End ####");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Demo/Democ_GobalFilter.cs b/Src/Asp.Net/DmTest/Demo/Democ_GobalFilter.cs
new file mode 100644
index 000000000..f0c8e89ee
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Demo/Democ_GobalFilter.cs
@@ -0,0 +1,77 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ public class DemoC_GobalFilter
+ {
+ public static void Init()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Filter Start ####");
+ var db = GetInstance();
+
+
+ var sql = db.Queryable().ToSql();
+ //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE isDelete=0
+ Console.WriteLine(sql);
+
+
+ var sql2 = db.Queryable((main,ot)=> main.Id==ot.OrderId).ToSql();
+ //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` main ,[OrderDetail] ot WHERE ( [main].[Id] = [ot].[OrderId] ) AND main.isDelete=0
+ Console.WriteLine(sql2);
+
+
+ var sql3 = db.Queryable().Filter("Myfilter").ToSql();// Myfilter+Gobal
+ //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE Name='jack' AND isDelete=0
+ Console.WriteLine(sql3);
+
+ var sql4 = db.Queryable().Filter("Myfilter",isDisabledGobalFilter:true).ToSql();//only Myfilter
+ //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE Name='jack'
+ Console.WriteLine(sql4);
+ Console.WriteLine("#### Filter End ####");
+ }
+
+
+ public static SqlSugarClient GetInstance()
+ {
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { DbType = DbType.Dm, ConnectionString = Config.ConnectionString, IsAutoCloseConnection = true });
+
+ //single table query gobal filter
+ db.QueryFilter.Add(new SqlFilterItem()
+ {
+ FilterValue = filterDb =>
+ {
+ //Writable logic
+ return new SqlFilterResult() { Sql = " isDelete=0" };//Global string perform best
+ }
+ });
+
+ //Multi-table query gobal filter
+ db.QueryFilter.Add(new SqlFilterItem()
+ {
+ FilterValue = filterDb =>
+ {
+ //Writable logic
+ return new SqlFilterResult() { Sql = " main.isDelete=0" };
+ },
+ IsJoinQuery=true
+ });
+
+ //Specific filters
+ db.QueryFilter.Add(new SqlFilterItem()
+ {
+ FilterName= "Myfilter",
+ FilterValue = filterDb =>
+ {
+ //Writable logic
+ return new SqlFilterResult() { Sql = "Name='jack'" };
+ }
+ });
+ return db;
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/DmTest.csproj b/Src/Asp.Net/DmTest/DmTest.csproj
new file mode 100644
index 000000000..34b0c90ae
--- /dev/null
+++ b/Src/Asp.Net/DmTest/DmTest.csproj
@@ -0,0 +1,101 @@
+
+
+
+
+ Debug
+ AnyCPU
+ {68A45CBA-AD64-429C-9AF4-FE78658B73D5}
+ Exe
+ DmTest
+ DmTest
+ v4.5
+ 512
+ true
+
+
+ AnyCPU
+ true
+ full
+ false
+ bin\Debug\
+ DEBUG;TRACE
+ prompt
+ 4
+
+
+ AnyCPU
+ pdbonly
+ true
+ bin\Release\
+ TRACE
+ prompt
+ 4
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {489bb790-226c-4fad-8d1e-51d72a7ff8e5}
+ SqlSugar
+
+
+
+
\ No newline at end of file
diff --git a/Src/Asp.Net/DmTest/Models/AttributeTable.cs b/Src/Asp.Net/DmTest/Models/AttributeTable.cs
new file mode 100644
index 000000000..c1a43ad12
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/AttributeTable.cs
@@ -0,0 +1,20 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ [Table("MyAttributeTable")]
+ //[SugarTable("CustomAttributeTable")]
+ public class AttributeTable
+ {
+
+ [Key]
+ //[SugarColumn(IsPrimaryKey =true)]
+ public string Id { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/CarType.cs b/Src/Asp.Net/DmTest/Models/CarType.cs
new file mode 100644
index 000000000..00dc12710
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/CarType.cs
@@ -0,0 +1,7 @@
+namespace OrmTest
+{
+ public class CarType
+ {
+ public bool State { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/Src/Asp.Net/DmTest/Models/Custom.cs b/Src/Asp.Net/DmTest/Models/Custom.cs
new file mode 100644
index 000000000..3b8871c57
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/Custom.cs
@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Custom
+ {
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/EntityMapper.cs b/Src/Asp.Net/DmTest/Models/EntityMapper.cs
new file mode 100644
index 000000000..b597012fb
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/EntityMapper.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+namespace OrmTest
+{
+ [SugarTable("MyEntityMapper")]
+ public class EntityMapper
+ {
+ [SugarColumn(ColumnName ="MyName")]
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/Mapper.cs b/Src/Asp.Net/DmTest/Models/Mapper.cs
new file mode 100644
index 000000000..8d7991d6c
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/Mapper.cs
@@ -0,0 +1,54 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ [SugarTable("OrderDetail")]
+ public class OrderItemInfo
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int ItemId { get; set; }
+ public int OrderId { get; set; }
+ public decimal? Price { get; set; }
+ [SqlSugar.SugarColumn(IsNullable = true)]
+ public DateTime? CreateTime { get; set; }
+ [SugarColumn(IsIgnore = true)]
+ public Order Order { get; set; }
+ }
+ [SugarTable("Order")]
+ public class OrderInfo
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ [SugarColumn(IsIgnore = true)]
+ public List Items { get; set; }
+ }
+ public class ABMapping
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int AId { get; set; }
+ public int BId { get; set; }
+ [SugarColumn(IsIgnore = true)]
+ public A A { get; set; }
+ [SugarColumn(IsIgnore = true)]
+ public B B { get; set; }
+
+ }
+ public class A
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+ public class B
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/MyCustomAttributeTable.cs b/Src/Asp.Net/DmTest/Models/MyCustomAttributeTable.cs
new file mode 100644
index 000000000..11359d062
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/MyCustomAttributeTable.cs
@@ -0,0 +1,20 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ [Table("CustomAttributeTable")]
+ //[SugarTable("CustomAttributeTable")]
+ public class MyCustomAttributeTable
+ {
+
+ [Key]
+ //[SugarColumn(IsPrimaryKey =true)]
+ public string Id { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/Order.cs b/Src/Asp.Net/DmTest/Models/Order.cs
new file mode 100644
index 000000000..d7ff068b8
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/Order.cs
@@ -0,0 +1,24 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+
+ public class Order
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+
+ public string Name { get; set; }
+ public decimal Price { get; set; }
+ [SugarColumn(IsNullable = true)]
+ public DateTime CreateTime { get; set; }
+ [SugarColumn(IsNullable =true)]
+ public int CustomId { get; set; }
+ [SugarColumn(IsIgnore = true)]
+ public List Items { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/OrderItem.cs b/Src/Asp.Net/DmTest/Models/OrderItem.cs
new file mode 100644
index 000000000..ae3262c7c
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/OrderItem.cs
@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ [SqlSugar.SugarTable("OrderDetail")]
+ public class OrderItem
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey =true, IsIdentity =true)]
+ public int ItemId { get; set; }
+ public int OrderId { get; set; }
+ public decimal? Price { get; set; }
+ [SqlSugar.SugarColumn(IsNullable = true)]
+ public DateTime? CreateTime { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/Student.cs b/Src/Asp.Net/DmTest/Models/Student.cs
new file mode 100644
index 000000000..1cee79460
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/Student.cs
@@ -0,0 +1,7 @@
+namespace OrmTest
+{
+ public class Student
+ {
+ public int Id { get; set; }
+ }
+}
\ No newline at end of file
diff --git a/Src/Asp.Net/DmTest/Models/TestTree.cs b/Src/Asp.Net/DmTest/Models/TestTree.cs
new file mode 100644
index 000000000..b8250828a
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/TestTree.cs
@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class TestTree
+ {
+ [SqlSugar.SugarColumn(ColumnDataType = "hierarchyid")]
+ public string TreeId { get; set; }
+ [SqlSugar.SugarColumn(ColumnDataType = "Geography")]
+ public string GId { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/Tree.cs b/Src/Asp.Net/DmTest/Models/Tree.cs
new file mode 100644
index 000000000..d2878de64
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/Tree.cs
@@ -0,0 +1,20 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class Tree
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey =true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ public int ParentId { get; set; }
+ [SqlSugar.SugarColumn(IsIgnore = true)]
+ public Tree Parent { get; set; }
+ [SqlSugar.SugarColumn(IsIgnore = true)]
+ public List Child { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Models/ViewOrder.cs b/Src/Asp.Net/DmTest/Models/ViewOrder.cs
new file mode 100644
index 000000000..fcd465747
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Models/ViewOrder.cs
@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class ViewOrder:Order
+ {
+ public string CustomName { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Program.cs b/Src/Asp.Net/DmTest/Program.cs
new file mode 100644
index 000000000..72832d0a2
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Program.cs
@@ -0,0 +1,40 @@
+using System;
+
+namespace OrmTest
+{
+ class Program
+ {
+ static void Main(string[] args)
+ {
+ //Demo
+ Demo0_SqlSugarClient.Init();
+ Demo1_Queryable.Init();
+ Demo2_Updateable.Init();
+ Demo3_Insertable.Init();
+ Demo4_Deleteable.Init();
+ Demo5_SqlQueryable.Init();
+ Demo6_Queue.Init();
+ Demo7_Ado.Init();
+ Demo8_Saveable.Init();
+ Demo9_EntityMain.Init();
+ DemoA_DbMain.Init();
+ DemoB_Aop.Init();
+ DemoC_GobalFilter.Init();
+ DemoD_DbFirst.Init(); ;
+ DemoE_CodeFirst.Init();
+ DemoF_Utilities.Init();
+ DemoG_SimpleClient.Init();
+
+ //Unit test
+ //NewUnitTest.Init();
+
+ //Rest Data
+ NewUnitTest.RestData();
+
+ Console.WriteLine("all successfully.");
+ Console.ReadKey();
+ }
+
+
+ }
+}
diff --git a/Src/Asp.Net/DmTest/Properties/AssemblyInfo.cs b/Src/Asp.Net/DmTest/Properties/AssemblyInfo.cs
new file mode 100644
index 000000000..61ddd725d
--- /dev/null
+++ b/Src/Asp.Net/DmTest/Properties/AssemblyInfo.cs
@@ -0,0 +1,36 @@
+using System.Reflection;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+// General Information about an assembly is controlled through the following
+// set of attributes. Change these attribute values to modify the information
+// associated with an assembly.
+[assembly: AssemblyTitle("DmTest")]
+[assembly: AssemblyDescription("")]
+[assembly: AssemblyConfiguration("")]
+[assembly: AssemblyCompany("")]
+[assembly: AssemblyProduct("DmTest")]
+[assembly: AssemblyCopyright("Copyright © 2020")]
+[assembly: AssemblyTrademark("")]
+[assembly: AssemblyCulture("")]
+
+// Setting ComVisible to false makes the types in this assembly not visible
+// to COM components. If you need to access a type in this assembly from
+// COM, set the ComVisible attribute to true on that type.
+[assembly: ComVisible(false)]
+
+// The following GUID is for the ID of the typelib if this project is exposed to COM
+[assembly: Guid("68a45cba-ad64-429c-9af4-fe78658b73d5")]
+
+// Version information for an assembly consists of the following four values:
+//
+// Major Version
+// Minor Version
+// Build Number
+// Revision
+//
+// You can specify all the values or you can default the Build and Revision Numbers
+// by using the '*' as shown below:
+// [assembly: AssemblyVersion("1.0.*")]
+[assembly: AssemblyVersion("1.0.0.0")]
+[assembly: AssemblyFileVersion("1.0.0.0")]
diff --git a/Src/Asp.Net/DmTest/UnitTest/Main.cs b/Src/Asp.Net/DmTest/UnitTest/Main.cs
new file mode 100644
index 000000000..0c39ced0e
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/Main.cs
@@ -0,0 +1,46 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static SqlSugarClient Db=> new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+
+ public static void RestData()
+ {
+ Db.Deleteable().ExecuteCommand();
+ Db.Deleteable().ExecuteCommand();
+ }
+ public static void Init()
+ {
+ Save();
+ CodeFirst();
+ Updateable();
+ Json();
+ Ado();
+ Queryable();
+ QueryableAsync();
+ Thread();
+ Thread2();
+ Thread3();
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UAdo.cs b/Src/Asp.Net/DmTest/UnitTest/UAdo.cs
new file mode 100644
index 000000000..49788f35a
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UAdo.cs
@@ -0,0 +1,57 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void Ado()
+ {
+
+ var task1 = Db.Ado.GetScalarAsync("select 1");
+ task1.Wait();
+ UValidate.Check(1, task1.Result, "ado");
+
+ var task2 = Db.Ado.GetIntAsync("select 2");
+ task2.Wait();
+ UValidate.Check(2, task2.Result, "ado");
+
+
+ var task3 = Db.Ado.GetLongAsync("select 3");
+ task3.Wait();
+ UValidate.Check(3, task3.Result, "ado");
+
+
+ var task4 = Db.Ado.GetDataTableAsync("select 4 as id");
+ task4.Wait();
+ UValidate.Check(4, task4.Result.Rows[0]["id"], "ado");
+
+
+ var task5 = Db.Ado.GetInt("select @id as id",new { id=5});
+ UValidate.Check(5, task5, "ado");
+
+
+
+ var task6 = Db.Ado.SqlQuery("select @id as id", new { id = 5 });
+ UValidate.Check(5, task6[0].id, "ado");
+
+
+ var task7 = Db.Ado.SqlQueryAsync("select @id as id", new { id = 7 });
+ task7.Wait();
+ UValidate.Check(7, task7.Result[0].id, "ado");
+
+
+ var task8 = Db.Ado.SqlQueryAsync("select 8 as id");
+ task8.Wait();
+ UValidate.Check(8, task8.Result[0].id, "ado");
+
+ var task9=Db.Ado.SqlQuery(@"select * from ""order"";select * from OrderDetail");
+
+ var task10 = Db.Ado.SqlQueryAsync(@"select * from ""order"";select * from OrderDetail");
+ task10.Wait();
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UCodeFirst.cs b/Src/Asp.Net/DmTest/UnitTest/UCodeFirst.cs
new file mode 100644
index 000000000..099832be8
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UCodeFirst.cs
@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void CodeFirst()
+ {
+ if (Db.DbMaintenance.IsAnyTable("UnitCodeTest1", false))
+ Db.DbMaintenance.DropTable("UnitCodeTest1");
+ Db.CodeFirst.InitTables();
+ }
+ public class UnitCodeTest1
+ {
+ [SqlSugar.SugarColumn(IndexGroupNameList = new string[] { "group1" })]
+ public int Id { get; set; }
+ [SqlSugar.SugarColumn(DefaultValue= "now()", IndexGroupNameList =new string[] {"group1" } )]
+ public DateTime? CreateDate { get; set; }
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UJson.cs b/Src/Asp.Net/DmTest/UnitTest/UJson.cs
new file mode 100644
index 000000000..a7fd05df8
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UJson.cs
@@ -0,0 +1,34 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+
+ public static void Json()
+ {
+ Db.CodeFirst.InitTables();
+ Db.DbMaintenance.TruncateTable();
+ Db.Insertable(new UnitJsonTest() { Order = new Order { Id = 1, Name = "order1" } }).ExecuteCommand();
+ var list = Db.Queryable().ToList();
+ UValidate.Check("order1", list.First().Order.Name, "Json");
+ Db.Updateable(new UnitJsonTest() { Id = Db.Queryable().First().Id, Order = new Order { Id = 2, Name = "order2" } }).ExecuteCommand();
+ list= Db.Queryable().ToList();
+ UValidate.Check("order2", list.First().Order.Name, "Json");
+ var list2 = Db.Queryable().ToList();
+ }
+ }
+
+
+ public class UnitJsonTest
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ [SqlSugar.SugarColumn(ColumnDataType = "varchar(4000)", IsJson = true)]
+ public Order Order { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UQueryable.cs b/Src/Asp.Net/DmTest/UnitTest/UQueryable.cs
new file mode 100644
index 000000000..9fdc0766d
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UQueryable.cs
@@ -0,0 +1,323 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void Queryable()
+ {
+
+ var pageindex = 1;
+ var pagesize = 10;
+ var total = 0;
+ var totalPage = 0;
+ var list = Db.Queryable().ToPageList(pageindex, pagesize, ref total, ref totalPage);
+
+ //Db.CodeFirst.InitTables(typeof(CarType));
+ //Db.Updateable()
+ // .SetColumns(it => new CarType { State = SqlSugar.SqlFunc.IIF(it.State == true, false, true) }).Where(it => true)
+ // .ExecuteCommand();
+
+ //Db.CodeFirst.InitTables(typeof(TestTree));
+ //Db.DbMaintenance.TruncateTable();
+ //Db.Ado.ExecuteCommand("insert testtree values(hierarchyid::GetRoot(),geography :: STGeomFromText ('POINT(55.9271035250276 -3.29431266523898)',4326),'name')");
+ //var list2 = Db.Queryable().ToList();
+
+ Db.CodeFirst.InitTables();
+ Db.Queryable().Where(it => it.Id.HasValue).ToList();
+
+ Db.Queryable().Where(it => SqlSugar.SqlFunc.Equals(it.CreateTime.Date, it.CreateTime.Date)).ToList();
+
+ var sql = Db.Queryable().Select(it => new UnitSelectTest()
+ {
+
+ DcNull = it.Dc,
+ Dc = it.Int
+ }).ToSql().Key;
+ UValidate.Check(sql, "SELECT \"dc\" AS \"dcnull\" , \"int\" AS \"dc\" FROM \"unitselecttest\"", "Queryable");
+
+ sql = Db.Updateable(new UnitSelectTest2()).ToSql().Key;
+ UValidate.Check(sql, @"UPDATE ""unitselecttest2"" SET
+ ""dc""=@Dc,""intnull""=@IntNull WHERE ""int""=@Int", "Queryable");
+
+ sql = Db.Queryable().IgnoreColumns(it => it.CreateTime).ToSql().Key;
+ UValidate.Check(sql, "SELECT \"id\",\"name\",\"price\",\"customid\" FROM \"order\" ", "Queryable");
+ sql = Db.Queryable().IgnoreColumns(it => new { it.Id, it.Name }).ToSql().Key;
+ UValidate.Check(sql, "SELECT \"price\",\"createtime\",\"customid\" FROM \"order\" ", "Queryable");
+ sql = Db.Queryable().IgnoreColumns("id").ToSql().Key;
+ UValidate.Check(sql, "SELECT \"name\",\"price\",\"createtime\",\"customid\" FROM \"order\" ", "Queryable");
+
+ var cts = IEnumerbleContains.Data();
+ var list2=Db.Queryable()
+ .Where(p => /*ids.*/cts.Select(c => c.Id).Contains(p.Id)).ToList();
+
+ var cts2 = IEnumerbleContains.Data().ToList(); ;
+ var list3 = Db.Queryable()
+ .Where(p => /*ids.*/cts2.Select(c => c.Id).Contains(p.Id)).ToList();
+
+
+ var list4 = Db.Queryable()
+ .Where(p => new List { 1, 2, 3 }.Where(b => b > 1).Contains(p.Id)).ToList();
+
+ Db.CodeFirst.InitTables();
+ var list5 = Db.Queryable().Where(it => SqlSugar.SqlFunc.ToString(it.Date.Value.Year) == "1").ToList();
+ var list6 = Db.Queryable().Where(it => it.Date.Value.Year == 1).ToList();
+ var list7 = Db.Queryable().Where(it => it.Date.Value.Date == DateTime.Now.Date).ToList();
+
+
+ SaleOrder saleOrderInfo = new SaleOrder();
+ Db.CodeFirst.InitTables();
+ var result = Db.GetSimpleClient().Update(o => new SaleOrder()
+ {
+ OrderStatus = 1,
+ CheckMan = saleOrderInfo.CheckMan,
+ CheckTime = DateTime.Now
+ }, o => o.OrderSn == saleOrderInfo.OrderSn && o.OrderStatus != 1);
+ }
+
+ public static class IEnumerbleContains
+ {
+ public static IEnumerable Data()
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ yield return new Order
+ {
+ Id = i,
+ };
+ }
+ }
+ }
+ [SugarTable("UnitSaleOrder")]
+ public class SaleOrder
+ {
+ public SaleOrder()
+ {
+ SaleDate = DateTime.Now;
+ Team = 1;
+ AddTime = DateTime.Now;
+ OrderStatus = 0;
+ Points = 0;
+ PayPoints = 0;
+ PointsExchangeMoney = decimal.Zero;
+ IsPushMessage = false;
+ CostAmount = decimal.Zero;
+ OrderAmount = decimal.Zero;
+ RealOrderAmount = decimal.Zero;
+ AccountsDueAmount = decimal.Zero;
+ SettleType = 0;
+ IsPushMessage = false;
+ }
+
+ ///
+ /// 订单号
+ ///
+ public string OrderSn { get; set; }
+
+ ///
+ /// 客户编号
+ ///
+ public string CustomerNo { get; set; }
+
+
+ ///
+ /// 收货人姓名
+ ///
+ public string CustomerName { get; set; }
+
+ ///
+ /// 成本总金额
+ ///
+ public decimal CostAmount { get; set; }
+
+ ///
+ /// 订单总金额
+ ///
+ public decimal OrderAmount { get; set; }
+
+ ///
+ /// 实收金额（整单优惠后）
+ ///
+ public decimal RealOrderAmount { get; set; }
+
+ ///
+ /// 销货日期
+ ///
+ public DateTime SaleDate { get; set; }
+
+ ///
+ /// 下单时间
+ ///
+ public DateTime AddTime { get; set; }
+
+ ///
+ /// 媒体资源投放ID
+ ///
+ public string IndustryCode { get; set; }
+
+ public string IndustryName { get; set; }
+
+ ///
+ /// 备注
+ ///
+ public string Remark { get; set; }
+
+ ///
+ /// 班组
+ ///
+ public int Team { get; set; }
+
+ ///
+ /// 销售员编号
+ ///
+ public string SellerNo { get; set; }
+
+ ///
+ /// 销售员姓名
+ ///
+ public string SellerName { get; set; }
+
+ ///
+ /// 操作人ID
+ ///
+ public virtual string HandlerCode { get; set; }
+
+ ///
+ /// 操作者
+ ///
+ public string Handler { get; set; }
+
+ ///
+ /// 发货仓库代号
+ ///
+ public string StoreCode { get; set; }
+
+ ///
+ /// 发货仓库名称
+ ///
+ public string StoreName { get; set; }
+
+ ///
+ /// 销货店铺渠道代号
+ ///
+ public string ShopChannelCode { get; set; }
+
+ ///
+ /// 销货店铺渠道名称
+ ///
+ public string ShopChannelName { get; set; }
+
+ ///
+ /// 订单产品数
+ ///
+ public int GoodsNum { get; set; }
+
+ ///
+ /// 礼品数量
+ ///
+ public int GiftNum { get; set; }
+
+ ///
+ /// 对应预订单号
+ ///
+ public string CustomerOrderSn { get; set; }
+
+ ///
+ /// 订单赠送积分
+ ///
+ public int Points { get; set; }
+
+ ///
+ /// 应收款金额
+ ///
+ public decimal AccountsDueAmount { get; set; }
+
+ ///
+ /// 来自预约单号
+ ///
+ public string ReserationOrderSn { get; set; }
+
+
+ ///
+ /// 订单状态 0为未审核 1为已审核
+ ///
+ public int OrderStatus { get; set; }
+
+ ///
+ /// 审核人
+ ///
+ public string CheckMan { get; set; }
+
+ ///
+ /// 审核时间
+ ///
+ public DateTime? CheckTime { get; set; }
+
+ ///
+ /// 结算类型 0为非金工石（零售） 1为金工石
+ ///
+ public int SettleType { get; set; }
+
+ ///
+ /// 使用积分
+ ///
+ public int PayPoints { get; set; }
+
+ ///
+ /// 积分抵现金额
+ ///
+ public decimal PointsExchangeMoney { get; set; }
+
+ ///
+ /// 是否已推送微信消息
+ ///
+ public bool IsPushMessage { get; set; }
+
+ }
+
+ public class SaleOrderBaseInfo
+ {
+ public int GoodsNum { get; set; }
+
+ public int GiftNum { get; set; }
+
+ public decimal OrderAmount { get; set; }
+
+ }
+
+
+ public class UnitTest3
+ {
+ public DateTime? Date { get; set; }
+ }
+
+
+ public class UnitSelectTest2
+ {
+ [SqlSugar.SugarColumn(IsOnlyIgnoreUpdate = true)]
+ public decimal? DcNull { get; set; }
+ public decimal Dc { get; set; }
+ public int? IntNull { get; set; }
+ [SqlSugar.SugarColumn(IsPrimaryKey = true)]
+ public decimal Int { get; set; }
+ }
+
+ public class UnitSelectTest
+ {
+ public decimal? DcNull { get; set; }
+ public decimal Dc { get; set; }
+ public int? IntNull { get; set; }
+ public decimal Int { get; set; }
+ }
+
+ public class UnitGuidTable
+ {
+ public Guid? Id { get; set; }
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UQueryableAsync.cs b/Src/Asp.Net/DmTest/UnitTest/UQueryableAsync.cs
new file mode 100644
index 000000000..7ebce71e8
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UQueryableAsync.cs
@@ -0,0 +1,43 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void QueryableAsync()
+ {
+ q1();
+ q2();
+ q3();
+ }
+
+ private static void q1()
+ {
+ RefAsync total = 0;
+ var count = Db.Queryable().Count();
+ Task t = Db.Queryable().ToPageListAsync(1, 2, total);
+ t.Wait();
+ UValidate.Check(count, total.Value, "QueryableAsync");
+ }
+ private static void q2()
+ {
+ RefAsync total = 0;
+ var count = Db.Queryable().Count();
+ Task t = Db.Queryable().ToDataTablePageAsync(1, 2, total);
+ t.Wait();
+ UValidate.Check(count, total.Value, "QueryableAsync");
+ }
+ private static void q3()
+ {
+ RefAsync total = 0;
+ var count = Db.Queryable().Count();
+ Task t = Db.Queryable().ToJsonPageAsync(1, 2, total);
+ t.Wait();
+ UValidate.Check(count, total.Value, "QueryableAsync");
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/USave.cs b/Src/Asp.Net/DmTest/UnitTest/USave.cs
new file mode 100644
index 000000000..98a05561d
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/USave.cs
@@ -0,0 +1,95 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void Save()
+ {
+ Db.CodeFirst.InitTables();
+ Db.DbMaintenance.TruncateTable();
+ Db.Saveable(new UnitSysMenu() { ID="aa", ButtonList="", CreateName="a", CreateTime=DateTime.Now, ImageUrl="", IsDel=true, MenuCode="a", NavigateUrl="a", UpdateName="", Remark="", UpdateTime=DateTime.Now }).ExecuteReturnEntity();
+ }
+ }
+ public class BaseEntity
+ {
+ ///
+ /// ID
+ ///
+ [SugarColumn(IsPrimaryKey = true, ColumnDescription = "ID", Length = 32)]
+ public string ID { get; set; }
+ ///
+ /// 删除标记
+ ///
+ [ SugarColumn(ColumnDescription = "删除标记")]
+ public bool IsDel { get; set; }
+ ///
+ /// 排序字段
+ ///
+ [SugarColumn(ColumnDescription = "排序字段", IsIdentity = true)]
+ public int SortIndex { get; set; }
+ ///
+ /// 添加操作员
+ ///
+ [ SugarColumn(ColumnDescription = "添加操作员", Length = 10, IsNullable = true)]
+ public string CreateName { get; set; }
+ ///
+ /// 添加时间
+ ///
+ [ SugarColumn(ColumnDescription = "添加时间", IsNullable = true)]
+ public DateTime? CreateTime { get; set; }
+ ///
+ /// 修改操作员
+ ///
+ [ SugarColumn(ColumnDescription = "修改操作员", Length = 10, IsNullable = true)]
+ public string UpdateName { get; set; }
+ ///
+ /// 修改时间
+ ///
+ [ SugarColumn(ColumnDescription = "修改时间", IsNullable = true)]
+ public DateTime? UpdateTime { get; set; }
+ ///
+ /// 备注
+ ///
+ [SugarColumn(ColumnDescription = "备注", Length = 150, IsNullable = true)]
+ public string Remark { get; set; }
+ }
+ public class UnitSysMenu : BaseEntity
+ {
+ public UnitSysMenu()
+ {
+ }
+ ///
+ /// 菜单图标
+ ///
+ [SqlSugar.SugarColumn(Length = 150, ColumnDescription = "菜单图标")]
+
+ public string ImageUrl { get; set; }
+ ///
+ /// 菜单编码
+ ///
+ [SqlSugar.SugarColumn(Length = 50, ColumnDescription = "菜单编码")]
+ public string MenuCode { get; set; }
+ ///
+ /// 菜单地址
+ ///
+ [ SqlSugar.SugarColumn(Length = 200, IsNullable = true, ColumnDescription = "菜单地址")]
+ public string NavigateUrl { get; set; }
+ ///
+ /// 菜单功能
+ ///
+ [SqlSugar.SugarColumn(IsIgnore = true)]
+ public string ButtonList { get; set; }
+
+ ///
+ /// 排序字段
+ ///
+ [SugarColumn(ColumnDescription = "排序字段", IsIdentity = true)]
+ public int SortIndex { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UThread.cs b/Src/Asp.Net/DmTest/UnitTest/UThread.cs
new file mode 100644
index 000000000..76b653667
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UThread.cs
@@ -0,0 +1,378 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+
+ public static SqlSugarClient simpleDb => new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+ public static SqlSugarClient ssDb => new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ IsShardSameThread = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+ public static SqlSugarClient singleDb = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ 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)));
+ }
+ }
+ });
+ public static SqlSugarClient singleAndSsDb = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = DbType.Dm,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ IsShardSameThread = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+ public static void Thread()
+ {
+ Simple();
+ IsShardSameThread();
+ Single();
+ SingleAndIsShardSameThread();
+ SimpleAsync();
+ IsShardSameThreadAsync();
+ SingleAsync();
+ SingleAndIsShardSameThreadAsync();
+
+ }
+
+ private static void Simple()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAndIsShardSameThread()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void Single()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void IsShardSameThread()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+
+
+ private static void SimpleAsync()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); ;
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAndIsShardSameThreadAsync()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleAndSsDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAsync()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ singleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void IsShardSameThreadAsync()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ Db.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UThread2.cs b/Src/Asp.Net/DmTest/UnitTest/UThread2.cs
new file mode 100644
index 000000000..5fe4c12dd
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UThread2.cs
@@ -0,0 +1,316 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+
+ public static void Thread2()
+ {
+ Simple2();
+ IsShardSameThread2();
+ Single2();
+ SingleAndIsShardSameThread2();
+ SimpleAsync2();
+ IsShardSameThreadAsync2();
+ SingleAsync2();
+ SingleAndIsShardSameThreadAsync2();
+
+ }
+
+ private static void Simple2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAndIsShardSameThread2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void Single2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void IsShardSameThread2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToList();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+
+
+ private static void SimpleAsync2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait(); ;
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAndIsShardSameThreadAsync2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void SingleAsync2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+
+ private static void IsShardSameThreadAsync2()
+ {
+ var t1 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(1);
+ }
+
+ });
+ var t2 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(10);
+ }
+
+ });
+ var t3 = new Task(() =>
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ simpleDb.Queryable().Take(10).ToListAsync().Wait();
+ System.Threading.Thread.Sleep(6);
+ }
+
+ });
+ t1.Start();
+ t2.Start();
+ t3.Start();
+
+ Task.WaitAll(t1, t2, t3);
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UThread3.cs b/Src/Asp.Net/DmTest/UnitTest/UThread3.cs
new file mode 100644
index 000000000..9e0e644c4
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UThread3.cs
@@ -0,0 +1,117 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+
+ public static void Thread3()
+ {
+ Console.WriteLine("Thread3");
+ SimpleAsync3().Wait();
+ IsShardSameThreadAsync3().Wait();
+ SingleAsync3().Wait();
+ SingleAndIsShardSameThreadAsync3().Wait();
+
+ }
+
+
+
+ private static async Task SimpleAsync3()
+ {
+
+ for (int i = 0; i < 100; i++)
+ {
+ await simpleDb.Queryable().Take(10).ToListAsync();
+ }
+
+ for (int i = 0; i < 100; i++)
+ {
+ await simpleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+ }
+
+ List orders = new List();
+ for (int i = 0; i < 100; i++)
+ {
+ orders = await simpleDb.Queryable().Take(10).ToListAsync();
+ }
+ if (orders.Count > 0)
+ {
+ Console.WriteLine("async is ok");
+ }
+ }
+
+ private static async Task SingleAndIsShardSameThreadAsync3()
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ await singleAndSsDb.Queryable().Take(10).ToListAsync();
+ }
+
+ for (int i = 0; i < 100; i++)
+ {
+ await singleAndSsDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+ }
+ List orders = new List();
+ for (int i = 0; i < 100; i++)
+ {
+ orders = await singleAndSsDb.Queryable().Take(10).ToListAsync();
+ }
+ if (orders.Count > 0)
+ {
+ Console.WriteLine("async is ok");
+ }
+ }
+
+ private static async Task SingleAsync3()
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ await singleDb.Queryable().Take(10).ToListAsync();
+ }
+
+ for (int i = 0; i < 100; i++)
+ {
+ await singleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+ }
+
+ List orders = new List();
+ for (int i = 0; i < 100; i++)
+ {
+ orders = await singleDb.Queryable().Take(10).ToListAsync();
+ }
+ if (orders.Count > 0)
+ {
+ Console.WriteLine("async is ok");
+ }
+ }
+
+ private static async Task IsShardSameThreadAsync3()
+ {
+ for (int i = 0; i < 100; i++)
+ {
+ await ssDb.Queryable().Take(10).ToListAsync();
+ }
+
+ for (int i = 0; i < 100; i++)
+ {
+ await ssDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+ }
+
+ List orders = new List();
+ for (int i = 0; i < 100; i++)
+ {
+ orders = await ssDb.Queryable().Take(10).ToListAsync();
+ }
+ if (orders.Count > 0)
+ {
+ Console.WriteLine("async is ok");
+ }
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/UValidate.cs b/Src/Asp.Net/DmTest/UnitTest/UValidate.cs
new file mode 100644
index 000000000..bc2b97fc2
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/UValidate.cs
@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public class UValidate
+ {
+ public static void Check(object a, object b, object name)
+ {
+ if (a?.ToString()?.Trim() != b?.ToString()?.Trim())
+ {
+ throw new Exception(name + " error");
+ }
+ }
+ }
+}
diff --git a/Src/Asp.Net/DmTest/UnitTest/Updateable.cs b/Src/Asp.Net/DmTest/UnitTest/Updateable.cs
new file mode 100644
index 000000000..3c2863c90
--- /dev/null
+++ b/Src/Asp.Net/DmTest/UnitTest/Updateable.cs
@@ -0,0 +1,211 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void Updateable()
+ {
+ Db.CodeFirst.InitTables(typeof(UnitUser));
+ Db.DbMaintenance.TruncateTable();
+ Db.Insertable(new UnitUser() { USER_ID=1,USER_ACCOUNT = "a", USER_PWD = "b", USER_NAME = "c", PWD_LASTCHTIME = DateTime.Now, PWD_ERRORCOUNT = 1, PWD_LASTERRTIME = DateTime.Now }).ExecuteCommand();
+ Db.Updateable(new UnitUser() { USER_ID=1, PWD_LASTERRTIME = null }).WhereColumns(it=> new{ it.PWD_ERRORCOUNT, it.PWD_LASTERRTIME }).ExecuteCommand();
+ Db.CodeFirst.InitTables(typeof(UnitBoolTest));
+ var x = new UnitBoolTest();
+ //Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = !it.BoolValue }).Where(it=>it.Id==1).ExecuteCommand();
+ //Db.Updateable().SetColumns(it => it.BoolValue == !it.BoolValue ).Where(it=>it.Id==1).ExecuteCommand();
+ Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = x.BoolValue }).Where(it => it.Id == 1).ExecuteCommand();
+ Db.Updateable().SetColumns(it => it.BoolValue == x.BoolValue).Where(it => it.Id == 1).ExecuteCommand();
+ Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = !x.BoolValue }).Where(it => it.Id == 1).ExecuteCommand();
+ //Db.Updateable