diff --git a/Src/Asp.Net/KdbndpTest/App.config b/Src/Asp.Net/KdbndpTest/App.config
new file mode 100644
index 000000000..731f6de6c
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/Src/Asp.Net/KdbndpTest/Config.cs b/Src/Asp.Net/KdbndpTest/Config.cs
new file mode 100644
index 000000000..de97dcde9
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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 = "Server=59.108.228.18;Port=55001;UID=system;PWD=123456;database=test";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString2 = ConnectionString;
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString3 = ConnectionString;
+ }
+}
diff --git a/Src/Asp.Net/KdbndpTest/Demo/Demo0_SqlSugarClient.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo0_SqlSugarClient.cs
new file mode 100644
index 000000000..3ce678e21
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/Demo/Demo0_SqlSugarClient.cs
@@ -0,0 +1,422 @@
+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.Kdbndp,
+ 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.Kdbndp,
+ 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.Open();
+ //If no exist create datebase
+ db.DbMaintenance.CreateDatabase();
+
+ //Use db query
+ var dt = db.Ado.GetDataTable("select 1");
+
+ //Create tables
+ db.CodeFirst.InitTables(typeof(OrderItem),typeof(Order));
+ var id = db.Insertable(new Order() { Name = "order1", CustomId = 1, Price = 0, CreateTime = DateTime.Now }).ExecuteReturnIdentity();
+
+ //Insert data
+ db.Insertable(new OrderItem() { OrderId = id, Price = 0, CreateTime=DateTime.Now }).ExecuteCommand();
+ Console.WriteLine("#### SqlSugarClient End ####");
+
+ }
+
+ private static void DbContext()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### DbContext Start ####");
+ var insertObj = new Order { Name = "jack", CreateTime = DateTime.Now };
+ var InsertObjs = new Order[] { insertObj };
+
+ DbContext context = new DbContext();
+
+ context.Db.CodeFirst.InitTables();//Create Tables
+ ;
+ var orderDb = context.OrderDb;
+
+ //Select
+ var data1 = orderDb.GetById(1);
+ var data2 = orderDb.GetList();
+ var data3 = orderDb.GetList(it => it.Id == 1);
+ var data4 = orderDb.GetSingle(it => it.Id == 1);
+ var p = new PageModel() { PageIndex = 1, PageSize = 2 };
+ var data5 = orderDb.GetPageList(it => it.Name == "xx", p);
+ Console.Write(p.TotalCount);
+ var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc);
+ Console.Write(p.TotalCount);
+ List conModels = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1", 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.Kdbndp,
+ IsAutoCloseConnection = true,
+ InitKeyType = InitKeyType.Attribute,
+ ConfigureExternalServices = new ConfigureExternalServices()
+ {
+ EntityService = (property, column) =>
+ {
+
+ var attributes = property.GetCustomAttributes(true);//get all attributes
+
+ if (attributes.Any(it => it is KeyAttribute))// by attribute set primarykey
+ {
+ column.IsPrimarykey = true;
+ }
+ },
+ EntityNameService = (type, entity) =>
+ {
+ var attributes = type.GetCustomAttributes(true);
+ if (attributes.Any(it => it is TableAttribute))
+ {
+ entity.DbTableName = (attributes.First(it => it is TableAttribute) as TableAttribute).Name;
+ }
+ }
+ }
+ });
+ db.CodeFirst.InitTables();//Create Table
+
+ db.Insertable(new AttributeTable() { Id = Guid.NewGuid().ToString(), Name = "Name" }).ExecuteCommand();
+ var list = db.Queryable().ToList();
+
+ Console.WriteLine("#### Custom Attribute End ####");
+ }
+
+
+ private static void SingletonPattern()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Singleton Pattern Start ####");
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ var task = new Task(() =>
+ {
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ new Task(() =>
+ {
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+
+ }).Start();
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ });
+ task.Start();
+ task.Wait();
+ System.Threading.Thread.Sleep(500);
+ Console.WriteLine(string.Join(",", singleDb.TempItems.Keys));
+
+ Console.WriteLine("#### Singleton Pattern end ####");
+ }
+
+ static SqlSugarScope singleDb = new SqlSugarScope(
+ new ConnectionConfig()
+ {
+ ConfigId = 1,
+ DbType = DbType.Kdbndp,
+ 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.Kdbndp, ConnectionString=Config.ConnectionString,InitKeyType=InitKeyType.Attribute,IsAutoCloseConnection=true },
+ new ConnectionConfig(){ ConfigId="2", DbType=DbType.Kdbndp, ConnectionString=Config.ConnectionString2 ,InitKeyType=InitKeyType.Attribute ,IsAutoCloseConnection=true}
+ });
+
+ var db1 = db.Ado.Connection.Database;
+ //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");
+ var db2 = db.Ado.Connection.Database;
+ 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());
+
+ if (db2 == db1)
+ {
+ return;
+ }
+
+ // 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(async () =>
+ {
+
+ db.ChangeDatabase("1");//use db1
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ throw new Exception("");
+
+ });
+ result2.Wait();
+ if (result2.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());
+ }
+
+ }
+ }
+
+ ///
+ /// DbContext Example 1
+ ///
+ public class DbContext
+ {
+
+ public SqlSugarClient Db;
+ public DbContext()
+ {
+ Db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.Kdbndp,
+ 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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo1_Queryable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo1_Queryable.cs
new file mode 100644
index 000000000..2d8b4866d
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Contains("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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo2_Updateable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo2_Updateable.cs
new file mode 100644
index 000000000..3731fc498
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo3_Insertable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo3_Insertable.cs
new file mode 100644
index 000000000..665a51202
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo4_Deleteable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo4_Deleteable.cs
new file mode 100644
index 000000000..676919e46
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo5_SqlQueryable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo5_SqlQueryable.cs
new file mode 100644
index 000000000..fb9791aa1
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/Demo/Demo5_SqlQueryable.cs
@@ -0,0 +1,37 @@
+
+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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo6_Queue.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo6_Queue.cs
new file mode 100644
index 000000000..2f91097a1
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo7_Ado.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo7_Ado.cs
new file mode 100644
index 000000000..d443890e3
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo8_Saveable.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo8_Saveable.cs
new file mode 100644
index 000000000..eac041ca1
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Demo9_EntityMain.cs b/Src/Asp.Net/KdbndpTest/Demo/Demo9_EntityMain.cs
new file mode 100644
index 000000000..fb96f70ba
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/DemoA_DbMain.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoA_DbMain.cs
new file mode 100644
index 000000000..40ebc9e4c
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/DemoB_Aop.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoB_Aop.cs
new file mode 100644
index 000000000..b13a1ec02
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/DemoD_DbFirst.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoD_DbFirst.cs
new file mode 100644
index 000000000..c2d44df30
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/Demo/DemoD_DbFirst.cs
@@ -0,0 +1,75 @@
+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.Kdbndp,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true
+ });
+
+ 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/KdbndpTest/Demo/DemoE_CodeFirst.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoE_CodeFirst.cs
new file mode 100644
index 000000000..e5c40a4ba
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/Demo/DemoE_CodeFirst.cs
@@ -0,0 +1,67 @@
+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.Kdbndp,
+ 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();
+ db.Aop.OnLogExecuting=(sql,p)=>Console.WriteLine(sql);
+ db.CurrentConnectionConfig.MoreSettings = new ConnMoreSettings()
+ {
+ IsAutoToUpper = false
+ };
+ if (db.DbMaintenance.IsAnyTable("CodeFirstNoUpper4",false))
+ {
+ db.DbMaintenance.DropTable();
+ }
+ db.CodeFirst.InitTables();
+ db.CodeFirst.InitTables();
+ db.Insertable(new CodeFirstNoUpper4() { Id = Guid.NewGuid() + "", Name = "a" }).ExecuteCommand();
+ var list2 = db.Queryable().Where(it => it.Id != null).ToList();
+ db.Updateable(list2).ExecuteCommand();
+ db.Deleteable(list2).ExecuteCommand();
+ db.Updateable(list2.First()).ExecuteCommand();
+ db.Deleteable().Where(it => it.Id != null).ExecuteCommand();
+ db.Updateable().SetColumns(it => it.Name == "a").Where(it => it.Id != null).ExecuteCommand();
+ db.Updateable().SetColumns(it => new CodeFirstNoUpper4()
+ {
+ Name = "a"
+ }).Where(it => it.Id != null).ExecuteCommand();
+ Console.WriteLine("#### CodeFirst end ####");
+ }
+ }
+ public class CodeFirstNoUpper4
+ {
+ [SugarColumn(IsPrimaryKey = true)]
+ public string Id { get; set; }
+ public string Name { get; set; }
+ }
+ 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/KdbndpTest/Demo/DemoF_Utilities.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoF_Utilities.cs
new file mode 100644
index 000000000..c7851c805
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/DemoG_SimpleClient.cs b/Src/Asp.Net/KdbndpTest/Demo/DemoG_SimpleClient.cs
new file mode 100644
index 000000000..fa8ba05d5
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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/KdbndpTest/Demo/Democ_GobalFilter.cs b/Src/Asp.Net/KdbndpTest/Demo/Democ_GobalFilter.cs
new file mode 100644
index 000000000..cdec7892b
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp, 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/KdbndpTest/KdbndpTest.csproj b/Src/Asp.Net/KdbndpTest/KdbndpTest.csproj
new file mode 100644
index 000000000..883d4b04e
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/KdbndpTest.csproj
@@ -0,0 +1,132 @@
+
+
+
+
+ Debug
+ AnyCPU
+ {162F8A11-7D32-4B5F-B379-3D19CD1D6E63}
+ Exe
+ KdbndpTest
+ KdbndpTest
+ v4.6.1
+ 512
+ true
+ true
+
+
+ AnyCPU
+ true
+ full
+ false
+ bin\Debug\
+ DEBUG;TRACE
+ prompt
+ 4
+
+
+ AnyCPU
+ pdbonly
+ true
+ bin\Release\
+ TRACE
+ prompt
+ 4
+
+
+
+ False
+ dll\Kdbndp.dll
+
+
+
+ False
+ dll\System.Buffers.dll
+
+
+
+
+ False
+ dll\System.Memory.dll
+
+
+ dll\System.Numerics.Vectors.dll
+
+
+ False
+ dll\System.Runtime.CompilerServices.Unsafe.dll
+
+
+ False
+ dll\System.Threading.Tasks.Extensions.dll
+
+
+ False
+ dll\System.ValueTuple.dll
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {489bb790-226c-4fad-8d1e-51d72a7ff8e5}
+ SqlSugar
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/Kdbndp.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/Kdbndp.dll
new file mode 100644
index 000000000..e7b1abb5c
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/Kdbndp.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Buffers.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Buffers.dll
new file mode 100644
index 000000000..f2d83c514
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Buffers.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Memory.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Memory.dll
new file mode 100644
index 000000000..461719979
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Memory.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Numerics.Vectors.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Numerics.Vectors.dll
new file mode 100644
index 000000000..08659724d
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Numerics.Vectors.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Runtime.CompilerServices.Unsafe.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Runtime.CompilerServices.Unsafe.dll
new file mode 100644
index 000000000..c5ba4e404
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Runtime.CompilerServices.Unsafe.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Threading.Tasks.Extensions.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Threading.Tasks.Extensions.dll
new file mode 100644
index 000000000..eeec92852
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.Threading.Tasks.Extensions.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.ValueTuple.dll b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.ValueTuple.dll
new file mode 100644
index 000000000..4ce28fdea
Binary files /dev/null and b/Src/Asp.Net/KdbndpTest/Kdbndp_dll/System.ValueTuple.dll differ
diff --git a/Src/Asp.Net/KdbndpTest/Models/AttributeTable.cs b/Src/Asp.Net/KdbndpTest/Models/AttributeTable.cs
new file mode 100644
index 000000000..c1a43ad12
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/CarType.cs b/Src/Asp.Net/KdbndpTest/Models/CarType.cs
new file mode 100644
index 000000000..00dc12710
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/Custom.cs b/Src/Asp.Net/KdbndpTest/Models/Custom.cs
new file mode 100644
index 000000000..3b8871c57
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/EntityMapper.cs b/Src/Asp.Net/KdbndpTest/Models/EntityMapper.cs
new file mode 100644
index 000000000..b597012fb
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/Mapper.cs b/Src/Asp.Net/KdbndpTest/Models/Mapper.cs
new file mode 100644
index 000000000..8d7991d6c
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/MyCustomAttributeTable.cs b/Src/Asp.Net/KdbndpTest/Models/MyCustomAttributeTable.cs
new file mode 100644
index 000000000..11359d062
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/Order.cs b/Src/Asp.Net/KdbndpTest/Models/Order.cs
new file mode 100644
index 000000000..d7ff068b8
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/OrderItem.cs b/Src/Asp.Net/KdbndpTest/Models/OrderItem.cs
new file mode 100644
index 000000000..ae3262c7c
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/TestTree.cs b/Src/Asp.Net/KdbndpTest/Models/TestTree.cs
new file mode 100644
index 000000000..b8250828a
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/Tree.cs b/Src/Asp.Net/KdbndpTest/Models/Tree.cs
new file mode 100644
index 000000000..d2878de64
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Models/ViewOrder.cs b/Src/Asp.Net/KdbndpTest/Models/ViewOrder.cs
new file mode 100644
index 000000000..fcd465747
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Program.cs b/Src/Asp.Net/KdbndpTest/Program.cs
new file mode 100644
index 000000000..72832d0a2
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/Properties/AssemblyInfo.cs b/Src/Asp.Net/KdbndpTest/Properties/AssemblyInfo.cs
new file mode 100644
index 000000000..eed47de37
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/Properties/AssemblyInfo.cs
@@ -0,0 +1,36 @@
+using System.Reflection;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+// 有关程序集的一般信息由以下
+// 控制。更改这些特性值可修改
+// 与程序集关联的信息。
+[assembly: AssemblyTitle("KdbndpTest")]
+[assembly: AssemblyDescription("")]
+[assembly: AssemblyConfiguration("")]
+[assembly: AssemblyCompany("微软中国")]
+[assembly: AssemblyProduct("KdbndpTest")]
+[assembly: AssemblyCopyright("Copyright © 微软中国 2023")]
+[assembly: AssemblyTrademark("")]
+[assembly: AssemblyCulture("")]
+
+// 将 ComVisible 设置为 false 会使此程序集中的类型
+//对 COM 组件不可见。如果需要从 COM 访问此程序集中的类型
+//请将此类型的 ComVisible 特性设置为 true。
+[assembly: ComVisible(false)]
+
+// 如果此项目向 COM 公开，则下列 GUID 用于类型库的 ID
+[assembly: Guid("162f8a11-7d32-4b5f-b379-3d19cd1d6e63")]
+
+// 程序集的版本信息由下列四个值组成:
+//
+// 主版本
+// 次版本
+// 生成号
+// 修订号
+//
+//可以指定所有这些值，也可以使用“生成号”和“修订号”的默认值
+//通过使用 "*"，如下所示:
+// [assembly: AssemblyVersion("1.0.*")]
+[assembly: AssemblyVersion("1.0.0.0")]
+[assembly: AssemblyFileVersion("1.0.0.0")]
diff --git a/Src/Asp.Net/KdbndpTest/UnitTest/Main.cs b/Src/Asp.Net/KdbndpTest/UnitTest/Main.cs
new file mode 100644
index 000000000..7e18ee93a
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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.DbMaintenance.TruncateTable();
+ Db.DbMaintenance.TruncateTable();
+ }
+ public static void Init()
+ {
+ Bulk();
+ CodeFirst();
+ Updateable();
+ Json();
+ Ado();
+ Queryable();
+ QueryableAsync();
+ Thread();
+ Thread2();
+ Thread3();
+ }
+ }
+}
diff --git a/Src/Asp.Net/KdbndpTest/UnitTest/UAdo.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UAdo.cs
new file mode 100644
index 000000000..49788f35a
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/UnitTest/UBulkCopy.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UBulkCopy.cs
new file mode 100644
index 000000000..8c36ce3db
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/UnitTest/UBulkCopy.cs
@@ -0,0 +1,117 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+ public partial class NewUnitTest
+ {
+ public static void Bulk()
+ {
+ Db.CodeFirst.InitTables();
+ Db.DbMaintenance.TruncateTable();
+ var data1 = new UnitIdentity1()
+ {
+ Name = "a",
+ Id=1
+ };
+ var data2 = new UnitIdentity1()
+ {
+ Name = "b",
+ Id = 2
+ };
+ var data3 = new UnitIdentity1()
+ {
+ Name = "c",
+ Id = 3
+ };
+ Db.Fastest().BulkCopy(new List() {
+ data1
+ });
+ var list=Db.Queryable().ToList();
+ if (list.Count != 1 || data1.Name != list.First().Name)
+ {
+ throw new Exception("unit Bulk");
+ }
+
+ Db.Fastest().BulkCopy(new List() {
+ data2,
+ data3
+ });
+ list = Db.Queryable().ToList();
+ if (list.Count != 3 || !list.Any(it=>it.Name=="c"))
+ {
+ throw new Exception("unit Bulk");
+ }
+ Db.Fastest().BulkUpdate(new List() {
+ new UnitIdentity1(){
+ Id=1,
+ Name="222"
+ },
+ new UnitIdentity1(){
+ Id=2,
+ Name="111"
+ }
+ });
+ list = Db.Queryable().ToList();
+ if (list.First(it=>it.Id==1).Name!="222")
+ {
+ throw new Exception("unit Bulk");
+ }
+ if (list.First(it => it.Id == 2).Name != "111")
+ {
+ throw new Exception("unit Bulk");
+ }
+ if (list.First(it => it.Id == 3).Name != "c")
+ {
+ throw new Exception("unit Bulk");
+ }
+ Db.CodeFirst.InitTables();
+ Db.DbMaintenance.TruncateTable();
+ var count = Db.Fastest().AS("UnitIdentity111").BulkCopy(new List {
+ new UnitIdentity111111111(){ Id=1, Name="jack" }
+ });
+ if (count == 0)
+ {
+ throw new Exception("unit Bulk");
+ }
+ count = Db.Fastest().AS("UnitIdentity111").BulkUpdate(new List {
+ new UnitIdentity111111111(){ Id=1, Name="jack" }
+ });
+ if (count == 0)
+ {
+ throw new Exception("unit Bulk");
+ }
+ Db.CodeFirst.InitTables();
+ Db.Fastest().BulkUpdate(new List {
+ new UnitTable001(){ Id=1, table="a" }
+ });
+ }
+ }
+
+ public class UnitTable001
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey = true)]
+ public int Id { get; set; }
+ public string table { get; set; }
+ }
+
+ public class UnitIdentity111
+ {
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+ public class UnitIdentity111111111
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey = true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+ public class UnitIdentity1
+ {
+ [SqlSugar.SugarColumn(IsPrimaryKey =true)]
+ public int Id { get; set; }
+ public string Name { get; set; }
+ }
+}
diff --git a/Src/Asp.Net/KdbndpTest/UnitTest/UCodeFirst.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UCodeFirst.cs
new file mode 100644
index 000000000..099832be8
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/UnitTest/UInsert3.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UInsert3.cs
new file mode 100644
index 000000000..47e83ccb8
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/UnitTest/UInsert3.cs
@@ -0,0 +1,95 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Data.SqlTypes;
+using System.Linq;
+using System.Security.Principal;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+ internal class UInsert3
+ {
+ public static void Init()
+ {
+ var db = NewUnitTest.Db;
+ db.Insertable(new Order() { Name = "a" }).ExecuteCommand();
+
+ db.Insertable(new List() {
+ new Order() { Name = "a" },
+ new Order() { Name = "a" }
+ }).ExecuteCommand();
+
+ db.Insertable(new ORDER() { Name = "a" }).ExecuteCommand();
+ db.Updateable(new Order()
+ {
+ CustomId = 1,
+ CreateTime = DateTime.Now,
+ Id = 1,
+ Price = 1,
+ Name = "a"
+ }).ExecuteCommand();
+ db.Updateable(new List(){ new Order()
+ {
+ CustomId = 1,
+ CreateTime = DateTime.Now,
+ Id = 1,
+ Price = 1,
+ Name = "a"
+ },
+ new Order()
+ {
+ CustomId = 1,
+ CreateTime = DateTime.Now,
+ Id = 1,
+ Price = 1,
+ Name = "a"
+ } }).ExecuteCommand();
+
+
+ db.Updateable().SetColumns(it => new Order()
+ {
+ CustomId = 1,
+ Price = 1,
+ Name = "a"
+ }, true).Where(it => it.Id == 1).ExecuteCommand();
+
+ db.Updateable().SetColumns(it => new ORDER()
+ {
+ CustomId = 1,
+ Price = 1,
+ Name = "a"
+ }, true).Where(it => it.Id == 1).ExecuteCommand();
+ }
+ public class Order
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ ///
+ /// 姓名
+ ///
+ public string Name { get; set; }
+ public decimal Price { get; set; }
+ [SugarColumn(InsertServerTime =true,UpdateServerTime =true)]
+ public DateTime CreateTime { get; set; }
+ [SugarColumn(IsNullable = true)]
+ public int CustomId { get; set; }
+ }
+
+ public class ORDER
+ {
+ [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+ public int Id { get; set; }
+ ///
+ /// 姓名
+ ///
+ public string Name { get; set; }
+ public decimal Price { get; set; }
+ [SugarColumn(InsertSql = "'2020-1-1'",UpdateSql = "'2022-1-1'")]
+ public DateTime CreateTime { get; set; }
+ [SugarColumn(IsNullable = true)]
+ public int CustomId { get; set; }
+ }
+ }
+}
diff --git a/Src/Asp.Net/KdbndpTest/UnitTest/UJson.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UJson.cs
new file mode 100644
index 000000000..a7fd05df8
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/UnitTest/UQueryable.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UQueryable.cs
new file mode 100644
index 000000000..9fdc0766d
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/UnitTest/UQueryableAsync.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UQueryableAsync.cs
new file mode 100644
index 000000000..7ebce71e8
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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/KdbndpTest/UnitTest/UThread.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UThread.cs
new file mode 100644
index 000000000..cfb77905e
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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.Kdbndp,
+ 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 SqlSugarScope ssDb => new SqlSugarScope(new ConnectionConfig()
+ {
+ DbType = DbType.Kdbndp,
+ 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.Kdbndp,
+ 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 SqlSugarScope singleAndSsDb = new SqlSugarScope(new ConnectionConfig()
+ {
+ DbType = DbType.Kdbndp,
+ 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/KdbndpTest/UnitTest/UThread2.cs b/Src/Asp.Net/KdbndpTest/UnitTest/UThread2.cs
new file mode 100644
index 000000000..5fe4c12dd
--- /dev/null
+++ b/Src/Asp.Net/KdbndpTest/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