Update Demo

Src/Asp.Net/MySqlTest/App.config

@@ -1,6 +1,6 @@
-<?xml version="1.0" encoding="utf-8" ?>
+<?xml version="1.0" encoding="utf-8"?>
 <configuration>
     <startup> 
-        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
+        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5"/>
     </startup>
-</configuration>
+</configuration>

Src/Asp.Net/MySqlTest/Demo/Demo0_SqlSugarClient.cs

@@ -0,0 +1,273 @@
+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();
+            CustomAttribute();
+        }
+
+        private static void SqlSugarClient()
+        {
+            //Create db
+            Console.WriteLine("#### SqlSugarClient Start ####");
+            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+            {
+                DbType = DbType.MySql,
+                ConnectionString = Config.ConnectionString,
+                InitKeyType = InitKeyType.Attribute,
+                IsAutoCloseConnection = true,
+                AopEvents = new AopEvents
+                {
+                    OnLogExecuting = (sql, p) =>
+                    {
+                        Console.WriteLine(sql);
+                        Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+                    }
+                }
+            });
+
+            //if no exist create datebase SQLSUGAR4XTEST (bin/database/)
+            db.DbMaintenance.CreateDatabase();
+
+            //Use db
+            var dt = db.Ado.GetDataTable("select 1");
+
+            //create table OrderDetail
+            db.CodeFirst.InitTables(typeof(OrderItem));
+
+            db.Insertable(new OrderItem() { OrderId = 1, Price = 0 }).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<Order, OrderItem, Custom>();//Create Tables
+            ;
+            var orderDb = context.OrderDb;
+
+            //Select
+            var data1 = orderDb.GetById(1);
+            var data2 = orderDb.GetList();
+            var data3 = orderDb.GetList(it => it.Id == 1);
+            var data4 = orderDb.GetSingle(it => it.Id == 1);
+            var p = new PageModel() { PageIndex = 1, PageSize = 2 };
+            var data5 = orderDb.GetPageList(it => it.Name == "xx", p);
+            Console.Write(p.PageCount);
+            var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc);
+            Console.Write(p.PageCount);
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+            var data7 = orderDb.GetPageList(conModels, p, it => it.Name, OrderByType.Asc);
+            orderDb.AsQueryable().Where(x => x.Id == 1).ToList();
+
+            //Insert
+            orderDb.Insert(insertObj);
+            orderDb.InsertRange(InsertObjs);
+            var id = orderDb.InsertReturnIdentity(insertObj);
+            orderDb.AsInsertable(insertObj).ExecuteCommand();
+
+
+            //Delete
+            orderDb.Delete(insertObj);
+            orderDb.DeleteById(1);
+            orderDb.DeleteById(new int[] { 1, 2 });
+            orderDb.Delete(it => it.Id == 1);
+            orderDb.AsDeleteable().Where(it => it.Id == 1).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.MySql,
+                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<MyCustomAttributeTable>();//Create Table
+
+            db.Insertable(new MyCustomAttributeTable() { Id = Guid.NewGuid().ToString(), Name = "Name" }).ExecuteCommand();
+            var list = db.Queryable<MyCustomAttributeTable>().ToList();
+
+            Console.WriteLine("#### Custom Attribute End ####");
+        }
+
+
+        private static void SingletonPattern()
+        {
+            Console.WriteLine("");
+            Console.WriteLine("#### Singleton Pattern Start ####");
+            Console.WriteLine("Db_Id:" + singleDb.ContextID);
+            Console.WriteLine("Db_Id:" + singleDb.ContextID);
+            var task = new Task(() =>
+            {
+                Console.WriteLine("Task DbId:" + singleDb.ContextID);
+                new Task(() =>
+                {
+                    Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+                    Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+
+                }).Start();
+                Console.WriteLine("Task DbId:" + singleDb.ContextID);
+            });
+            task.Start();
+            task.Wait();
+            System.Threading.Thread.Sleep(500);
+            Console.WriteLine(string.Join(",", singleDb.TempItems.Keys));
+
+            Console.WriteLine("#### Singleton Pattern end ####");
+        }
+
+        static SqlSugarClient singleDb = new SqlSugarClient(
+            new ConnectionConfig()
+            {
+                ConfigId = 1,
+                DbType = DbType.MySql,
+                ConnectionString = Config.ConnectionString,
+                InitKeyType = InitKeyType.Attribute,
+                IsAutoCloseConnection = true,
+                AopEvents = new AopEvents()
+                {
+                    OnLogExecuting = (sql, p) => { Console.WriteLine(sql); }
+                }
+            });
+
+
+        private static void DistributedTransactionExample()
+        {
+            //see SqlServerTest
+        }
+    }
+
+    /// <summary>
+    /// DbContext Example 1
+    /// </summary>
+    public class DbContext
+    {
+
+        public SqlSugarClient Db;
+        public DbContext()
+        {
+            Db = new SqlSugarClient(new ConnectionConfig()
+            {
+                ConnectionString = Config.ConnectionString,
+                DbType = DbType.MySql,
+                IsAutoCloseConnection = true,
+                InitKeyType = InitKeyType.Attribute,
+                AopEvents = new AopEvents()
+                {
+                    OnLogExecuting = (sql, p) =>
+                    {
+                        Console.WriteLine(sql);
+                    }
+                }
+            });
+        }
+        public SimpleClient<Order> OrderDb => new SimpleClient<Order>(Db);
+        public SimpleClient<OrderItem> OrderItemDb => new SimpleClient<OrderItem>(Db);
+    }
+
+
+    public class OrderDal : DbContext<Order>
+    {
+
+    }
+    /// <summary>
+    /// DbContext  Example 2
+    /// </summary>
+    /// <typeparam name="T"></typeparam>
+    public class DbContext<T> where T : class, new()
+    {
+
+        public SqlSugarClient Db;
+        public DbContext()
+        {
+            Db = new SqlSugarClient(new ConnectionConfig()
+            {
+                ConnectionString = Config.ConnectionString,
+                DbType = DbType.MySql,
+                IsAutoCloseConnection = true,
+                InitKeyType = InitKeyType.Attribute,
+                AopEvents = new AopEvents()
+                {
+                    OnLogExecuting = (sql, p) =>
+                    {
+                        Console.WriteLine(sql);
+                    }
+                }
+            });
+        }
+        public SimpleClient<T> CurrentDb => new SimpleClient<T>(Db);
+        public virtual T GetById(int id)
+        {
+            return CurrentDb.GetById(id);
+        }
+        public virtual List<T> GetList()
+        {
+            return CurrentDb.GetList();
+        }
+        public virtual bool Delete(int id)
+        {
+            return CurrentDb.DeleteById(id);
+        }
+    }
+
+}

Src/Asp.Net/MySqlTest/Demo/Demo1_Queryable.cs

@@ -0,0 +1,310 @@
+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<Order>().ToList();
+            var getOrderBy = db.Queryable<Order>().OrderBy(it => it.Name,OrderByType.Desc).ToList();
+            var getOrderBy2 = db.Queryable<Order>().OrderBy(it => it.Id).OrderBy(it => it.Name, OrderByType.Desc).ToList();
+            var getOrderBy3 = db.Queryable<Order>().OrderBy(it =>new { it.Name,it.Id}).ToList();
+            var getRandom = db.Queryable<Order>().OrderBy(it => SqlFunc.GetRandom()).First();
+            var getByPrimaryKey = db.Queryable<Order>().InSingle(2);
+            var getSingleOrDefault = db.Queryable<Order>().Where(it => it.Id == 1).Single();
+            var getFirstOrDefault = db.Queryable<Order>().First();
+            var getByWhere = db.Queryable<Order>().Where(it => it.Id == 1 || it.Name == "a").ToList();
+            var getByWhere2 = db.Queryable<Order>().Where(it => it.Id == DateTime.Now.Year).ToList();
+            var getByFuns = db.Queryable<Order>().Where(it => SqlFunc.IsNullOrEmpty(it.Name)).ToList();
+            Console.WriteLine("#### Examples End ####");
+        }
+
+        private static void ReturnType()
+        {
+            Console.WriteLine("");
+            Console.WriteLine("#### ReturnType Start ####");
+            var db = GetInstance();
+            List<Order> list = db.Queryable<Order>().ToList();
+
+            Order item = db.Queryable<Order>().First(it => it.Id == 1);
+
+            DataTable dataTable = db.Queryable<Order>().Select(it => it.Id).ToDataTable();
+
+            var json = db.Queryable<Order>().ToJson();
+
+            List<int> listInt = db.Queryable<Order>().Select(it => it.Id).ToList();
+
+            var dynamic = db.Queryable<Order>().Select<dynamic>().ToList();
+
+            var viewModel = db.Queryable<Order, OrderItem, Custom>((o, i, c) => new JoinQueryInfos(
+                    JoinType.Left, o.Id == i.OrderId  ,
+                    JoinType.Left, o.CustomId == c.Id 
+                ))
+                .Select<ViewOrder>().ToList();
+
+            var newDynamic = db.Queryable<Order, OrderItem, Custom>((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<Order, OrderItem, Custom>((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<Order, OrderItem, Custom>((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<Order, OrderItem, Custom>((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<Dictionary<string, object>> ListDic = db.Queryable<Order, OrderItem, Custom>((o, i, c) => new JoinQueryInfos(
+                  JoinType.Left, o.Id == i.OrderId,
+                  JoinType.Left, o.CustomId == c.Id
+                ))
+                .Select<ExpandoObject>().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<Order>().Take(10).Select(it => new
+            {
+                customName=SqlFunc.Subqueryable<Custom>().Where("it.CustomId=id").Select(s=>s.Name),
+                customName2 = SqlFunc.Subqueryable<Custom>().Where("it.CustomId = id").Where(s => true).Select(s => s.Name)
+            }).ToList();
+
+            var list2 = db.Queryable<Order>().Where(it => SqlFunc.Subqueryable<OrderItem>().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<Order>().Select(it => SqlFunc.CharIndex("a", "cccacc")).First();
+
+            Console.WriteLine("#### SqlFunc  End ####");
+        }
+
+        private static void Mapper()
+        {
+            Console.WriteLine("");
+            Console.WriteLine("#### Mapper Start ####");
+            var db = GetInstance();
+            //Creater Table
+            db.CodeFirst.InitTables(typeof(Tree));
+            db.DbMaintenance.TruncateTable("tree");
+            db.Insertable(new Tree() { Id = 1, Name = "root" }).ExecuteCommand();
+            db.Insertable(new Tree() { Id = 11, Name = "child1",ParentId=1 }).ExecuteCommand();
+            db.Insertable(new Tree() { Id = 12, Name = "child2",ParentId=1 }).ExecuteCommand();
+            db.Insertable(new Tree() { Id = 2, Name = "root" }).ExecuteCommand();
+            db.Insertable(new Tree() { Id = 22, Name = "child3", ParentId = 2 }).ExecuteCommand();
+
+            var list=db.Queryable<Tree>()
+                                     //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();
+
+
+            Console.WriteLine("#### End Start ####");
+        }
+
+        private static void NoEntity()
+        {
+            Console.WriteLine("");
+            Console.WriteLine("#### No Entity Start ####");
+            var db = GetInstance();
+
+            var list = db.Queryable<dynamic>().AS("`order` ").Where("id=id", new { id = 1 }).ToList();
+
+            var list2 = db.Queryable<dynamic>("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<Order, OrderItem, Custom>((o, i, c) => o.Id == i.OrderId&&c.Id == o.CustomId)
+                         .Select<ViewOrder>()
+                         .ToList();
+
+            //Join table
+            var list2 = db.Queryable<Order, OrderItem, Custom>((o, i, c) => new JoinQueryInfos(
+             JoinType.Left, o.Id == i.OrderId,
+             JoinType.Left, c.Id == o.CustomId
+            ))
+           .Select<ViewOrder>().ToList();
+
+            //Join queryable
+            var query1 = db.Queryable<Order, OrderItem>((o, i) => new JoinQueryInfos(
+              JoinType.Left, o.Id == i.OrderId
+            ))
+            .Where(o => o.Name == "jack");
+
+            var query2 = db.Queryable<Custom>();
+            var list3=db.Queryable(query1, query2,JoinType.Left, (p1, p2) => p1.CustomId == p2.Id).Select<ViewOrder>().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<Order>().Where(it => it.Id == 1).ToList();
+            //id=@id or name like '%'+@name+'%'
+            var list2 = db.Queryable<Order>().Where(it => it.Id == 1 || it.Name.Contains("jack")).ToList();
+
+
+            //Create expression 
+            var exp = Expressionable.Create<Order>()
+                            .And(it => it.Id == 1)
+                            .Or(it => it.Name.Contains("jack")).ToExpression();
+            var list3 = db.Queryable<Order>().Where(exp).ToList();
+
+
+            /*** By sql***/
+
+            //id=@id
+            var list4 = db.Queryable<Order>().Where("id=@id", new { id = 1 }).ToList();
+            //id=@id or name like '%'+@name+'%'
+            var list5 = db.Queryable<Order>().Where("id=@id or name like '%'||@name||'%' ", new { id = 1, name = "jack" }).ToList();
+
+
+
+            /*** By dynamic***/
+
+            //id=1
+            var conModels = new List<IConditionalModel>();
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+            var student = db.Queryable<Order>().Where(conModels).ToList();
+
+            //Complex use case
+            List<IConditionalModel> Order = new List<IConditionalModel>();
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" });//id=1
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Like, FieldValue = "1" });// id like '%1%'
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNullOrEmpty });
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.In, FieldValue = "1,2,3" });
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NotIn, FieldValue = "1,2,3" });
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NoEqual, FieldValue = "1,2,3" });
+            conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNot, FieldValue = null });// id is not null
+
+            conModels.Add(new ConditionalCollections()
+            {
+                ConditionalList = new List<KeyValuePair<WhereType, SqlSugar.ConditionalModel>>()//  (id=1 or id=2 and id=1)
+            {
+                //new  KeyValuePair<WhereType, ConditionalModel>( WhereType.And ,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" }),
+                new  KeyValuePair<WhereType, ConditionalModel> (WhereType.Or,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" }),
+                new  KeyValuePair<WhereType, ConditionalModel> ( WhereType.And,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" })
+            }
+            });
+            var list6 = db.Queryable<Order>().Where(conModels).ToList();
+
+            /*** Conditional builder ***/
+
+            // use whereif
+            string name = "";
+            int id = 1;
+            var query = db.Queryable<Order>()
+                            .WhereIF(!string.IsNullOrEmpty(name), it => it.Name.Contains(name))
+                            .WhereIF(id > 0, it => it.Id == id).ToList();
+            //clone new Queryable
+            var query2 = db.Queryable<Order>().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<Order>().FirstAsync();
+            task1.Wait();
+            var task2 = db.Queryable<Order>().Where(it => it.Id == 1).ToListAsync();
+
+        
+            task2.Wait();
+
+            Console.WriteLine("#### Async End ####");
+        }
+
+        private static SqlSugarClient GetInstance()
+        {
+            return new SqlSugarClient(new ConnectionConfig()
+            {
+                DbType = SqlSugar.DbType.MySql,
+                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)));
+                    }
+                }
+            });
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+                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<Order> {
+                 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<Class>
+
+            //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<Class> by id
+
+
+
+
+            /*** 2.by expression ***/
+
+            //update  name,createtime
+            var result7 = db.Updateable<Order>(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
+            var result71 = db.Updateable<Order>().SetColumns(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
+            //only update name
+            var result8 = db.Updateable<Order>(it => it.Name == "Name" + 1).Where(it => it.Id == 1).ExecuteCommand();
+            var result81 = db.Updateable<Order>().SetColumns(it => it.Name == "Name" + 1).Where(it => it.Id == 1).ExecuteCommand();
+            //
+
+
+
+
+            /*** 3.by Dictionary ***/
+            var dt = new Dictionary<string, object>();
+            dt.Add("id", 1);
+            dt.Add("name", null);
+            dt.Add("createTime", DateTime.Now);
+            var dtList = new List<Dictionary<string, object>>();
+            dtList.Add(dt);
+
+            var t66 = db.Updateable(dt).AS("student").WhereColumns("id").ExecuteCommand();
+            var t666 = db.Updateable(dtList).AS("student").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 ####");
+        }
+
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+                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" };
+            var updateObjs = new List<Order> {
+                 new Order() { Id = 11, Name = "order11" },
+                 new Order() { Id = 12, Name = "order12" }
+            };
+
+            //Ignore  Price
+            db.Insertable(insertObj).IgnoreColumns(it => new { it.Price }).ExecuteReturnIdentity();//get identity
+            db.Insertable(insertObj).IgnoreColumns("Name", "TestId").ExecuteReturnIdentity();
+
+            //Only  insert  Name and Price
+            db.Insertable(insertObj).InsertColumns(it => new { it.Name, it.Price }).ExecuteReturnIdentity();
+            db.Insertable(insertObj).InsertColumns("Name", "SchoolId").ExecuteReturnIdentity();
+
+            //ignore null columns
+            db.Insertable(insertObj).IgnoreColumns(ignoreNullColumn: true).ExecuteCommand();//get change row count
+
+            //Use Lock
+            db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteCommand();
+
+            Console.WriteLine("#### Insertable End ####");
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+                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<Order>().Where(new Order() { Id = 1 }).ExecuteCommand();
+
+            //by primary key
+            db.Deleteable<Order>().In(1).ExecuteCommand();
+
+            //by primary key array
+            db.Deleteable<Order>().In(new int[] { 1, 2 }).ExecuteCommand();
+
+            //by expression
+            db.Deleteable<Order>().Where(it => it.Id == 1).ExecuteCommand();
+
+            Console.WriteLine("#### Deleteable End ####");
+
+        }
+    }
+}

Src/Asp.Net/MySqlTest/Demo/Demo5_SqlQueryable.cs

@@ -0,0 +1,37 @@
+using OrmTest.Models;
+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.MySql,
+                ConnectionString = Config.ConnectionString,
+                InitKeyType = InitKeyType.Attribute,
+                IsAutoCloseConnection = true
+            });
+
+            int total = 0;
+            var list = db.SqlQueryable<Student>("select * from student").ToPageList(1, 2, ref total);
+
+
+            //by expression
+            var list2 = db.SqlQueryable<Student>("select * from student").Where(it => it.Id == 1).ToPageList(1, 2);
+            //by sql
+            var list3 = db.SqlQueryable<Student>("select * from student").Where("id=@id", new { id = 1 }).ToPageList(1, 2);
+
+            Console.WriteLine("#### SqlQueryable End ####");
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+                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<Order>(new Order() { Name = "a" }).AddQueue();
+            db.Insertable<Order>(new Order() { Name = "b" }).AddQueue();
+            db.SaveQueues();
+
+
+            db.Insertable<Order>(new Order() { Name = "a" }).AddQueue();
+            db.Insertable<Order>(new Order() { Name = "b" }).AddQueue();
+            db.Insertable<Order>(new Order() { Name = "c" }).AddQueue();
+            db.Insertable<Order>(new Order() { Name = "d" }).AddQueue();
+            var ar = db.SaveQueuesAsync();
+            ar.Wait();
+
+            db.Queryable<Order>().AddQueue();
+            db.Queryable<Order>().AddQueue();
+      //      db.AddQueue("select * from [Order] where id=@id", new { id = 10000 });
+            var result2 = db.SaveQueues<Order, Order, Order>();
+
+            Console.WriteLine("#### Queue End ####");
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+                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 @"           /// <summary>
+                          /// Desc_New:{PropertyDescription}
+                          /// Default_New:{DefaultValue}
+                                /// Nullable_New:{IsNullable}
+                                /// </summary>";
+                        })
+                        .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 ####");
+        }
+    }
+}

Src/Asp.Net/MySqlTest/Demo/DemoE_CodeFirst.cs

@@ -0,0 +1,40 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+    public class DemoE_CodeFirst
+    {
+        public static void Init()
+        {
+            Console.WriteLine("");
+            Console.WriteLine("#### CodeFirst Start ####");
+            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+            {
+                DbType = DbType.MySql,
+                ConnectionString =Config.ConnectionString,
+                InitKeyType = InitKeyType.Attribute,
+                IsAutoCloseConnection = true
+            });
+            db.DbMaintenance.CreateDatabase();//default bin/database
+            db.CodeFirst.InitTables(typeof(CodeFirstTable1));//Create CodeFirstTable1 
+            db.Insertable(new CodeFirstTable1() { Name = "a", Text="a" }).ExecuteCommand();
+            var list = db.Queryable<CodeFirstTable1>().ToList();
+            Console.WriteLine("#### CodeFirst end ####");
+        }
+    }
+
+    public class CodeFirstTable1
+    {
+        [SugarColumn(IsIdentity = true, IsPrimaryKey = true)]
+        public int Id { get; set; }
+        public string Name { get; set; }
+        [SugarColumn(ColumnDataType = "Nvarchar(255)")]//custom
+        public string Text { get; set; }
+        [SugarColumn(IsNullable = true)]
+        public DateTime CreateTime { get; set; }
+    }
+}

Src/Asp.Net/MySqlTest/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<Order>().ToSql();
+            //SELECT [Id],[Name],[Price],[CreateTime] FROM [Order]  WHERE  isDelete=0 
+            Console.WriteLine(sql);
+
+
+            var sql2 = db.Queryable<Order,OrderItem>((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<Order>().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<Order>().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.MySql, 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;
+        }
+    }
+}

Src/Asp.Net/MySqlTest/Models/CarType.cs

@@ -0,0 +1,7 @@
+namespace OrmTest
+{
+    public class CarType
+    {
+        public bool State { get;  set; }
+    }
+}

Src/Asp.Net/MySqlTest/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; }
+    }
+}

Src/Asp.Net/MySqlTest/Models/Mappers.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<Tree> Child { get; set; }
+    }
+}

Src/Asp.Net/MySqlTest/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; }
+    }
+}

Src/Asp.Net/MySqlTest/Models/Order.cs

@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace OrmTest
+{
+
+    public class Order
+    {
+        [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+        public int Id { get; set; }
+
+        public string Name { get; set; }
+        public decimal Price { get; set; }
+        [SqlSugar.SugarColumn(IsNullable = true)]
+        public DateTime CreateTime { get; set; }
+        [SqlSugar.SugarColumn(IsNullable =true)]
+        public int CustomId { get; set; }
+    }
+}

Src/Asp.Net/MySqlTest/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; }
+    }
+}

Src/Asp.Net/MySqlTest/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; }
+    }
+}

Src/Asp.Net/MySqlTest/MySqlTest.csproj

@@ -9,9 +9,10 @@
     <AppDesignerFolder>Properties</AppDesignerFolder>
     <RootNamespace>MySqlTest</RootNamespace>
     <AssemblyName>MySqlTest</AssemblyName>
-    <TargetFrameworkVersion>v4.5.2</TargetFrameworkVersion>
+    <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
     <FileAlignment>512</FileAlignment>
     <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
+    <TargetFrameworkProfile />
   </PropertyGroup>
   <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
     <PlatformTarget>AnyCPU</PlatformTarget>
@@ -38,6 +39,7 @@
       <HintPath>..\SqlServerTest\OtherDll\SyntacticSugar.dll</HintPath>
     </Reference>
     <Reference Include="System" />
+    <Reference Include="System.ComponentModel.DataAnnotations" />
     <Reference Include="System.Core" />
     <Reference Include="System.Xml.Linq" />
     <Reference Include="System.Data.DataSetExtensions" />
@@ -48,52 +50,80 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Config.cs" />
-    <Compile Include="Demos\1_Query.cs" />
-    <Compile Include="Demos\2_Update.cs" />
-    <Compile Include="Demos\3_Insert.cs" />
-    <Compile Include="Demos\4_Delete.cs" />
-    <Compile Include="Demos\5_CodeFirst.cs" />
-    <Compile Include="Demos\5_DbFirst.cs" />
-    <Compile Include="Demos\6_ComplexModel.cs" />
-    <Compile Include="Demos\7_Filter.cs" />
-    <Compile Include="Demos\8_JoinSql.cs" />
-    <Compile Include="Demos\A_MasterSlave.cs" />
-    <Compile Include="Demos\DemoBase.cs" />
-    <Compile Include="Demos\H_Queue.cs" />
-    <Compile Include="Demos\J_Encode.cs" />
-    <Compile Include="Models\DataTestInfo.cs" />
-    <Compile Include="Models\DataTestInfo2.cs" />
-    <Compile Include="Models\Enum.cs" />
-    <Compile Include="Models\School.cs" />
-    <Compile Include="Models\Student.cs" />
-    <Compile Include="Models\ViewModelStudent.cs" />
-    <Compile Include="PerformanceTesting\PerformanceBase.cs" />
-    <Compile Include="PerformanceTesting\SqlSugarPerformance.cs" />
+    <Compile Include="Demo\Demo0_SqlSugarClient.cs" />
+    <Compile Include="Demo\Demo1_Queryable.cs" />
+    <Compile Include="Demo\Demo2_Updateable.cs" />
+    <Compile Include="Demo\Demo3_Insertable.cs" />
+    <Compile Include="Demo\Demo4_Deleteable.cs" />
+    <Compile Include="Demo\Demo5_SqlQueryable.cs" />
+    <Compile Include="Demo\Demo6_Queue.cs" />
+    <Compile Include="Demo\Democ_GobalFilter.cs" />
+    <Compile Include="Demo\DemoD_DbFirst.cs" />
+    <Compile Include="Demo\DemoE_CodeFirst.cs" />
+    <Compile Include="Models\CarType.cs" />
+    <Compile Include="Models\Custom.cs" />
+    <Compile Include="Models\Mappers.cs" />
+    <Compile Include="Models\MyCustomAttributeTable.cs" />
+    <Compile Include="Models\Order.cs" />
+    <Compile Include="Models\OrderItem.cs" />
+    <Compile Include="Models\ViewOrder.cs" />
+    <Compile Include="OldTests\Demos\1_Query.cs" />
+    <Compile Include="OldTests\Demos\2_Update.cs" />
+    <Compile Include="OldTests\Demos\3_Insert.cs" />
+    <Compile Include="OldTests\Demos\4_Delete.cs" />
+    <Compile Include="OldTests\Demos\5_CodeFirst.cs" />
+    <Compile Include="OldTests\Demos\5_DbFirst.cs" />
+    <Compile Include="OldTests\Demos\6_ComplexModel.cs" />
+    <Compile Include="OldTests\Demos\7_Filter.cs" />
+    <Compile Include="OldTests\Demos\8_JoinSql.cs" />
+    <Compile Include="OldTests\Demos\A_MasterSlave.cs" />
+    <Compile Include="OldTests\Demos\DemoBase.cs" />
+    <Compile Include="OldTests\Demos\H_Queue.cs" />
+    <Compile Include="OldTests\Demos\J_Encode.cs" />
+    <Compile Include="OldTests\Models\DataTestInfo.cs" />
+    <Compile Include="OldTests\Models\DataTestInfo2.cs" />
+    <Compile Include="OldTests\Models\Enum.cs" />
+    <Compile Include="OldTests\Models\School.cs" />
+    <Compile Include="OldTests\Models\Student.cs" />
+    <Compile Include="OldTests\Models\ViewModelStudent.cs" />
+    <Compile Include="OldTests\OldTestMain.cs" />
+    <Compile Include="OldTests\PerformanceTesting\PerformanceBase.cs" />
+    <Compile Include="OldTests\PerformanceTesting\SqlSugarPerformance.cs" />
     <Compile Include="Program.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
-    <Compile Include="T4\SugarTemplate1.cs" />
-    <Compile Include="T4\SugarTemplate2.cs">
+    <Compile Include="OldTests\T4\SugarTemplate1.cs" />
+    <Compile Include="OldTests\T4\SugarTemplate2.cs">
       <DependentUpon>SugarTemplate.tt</DependentUpon>
       <AutoGen>True</AutoGen>
       <DesignTime>True</DesignTime>
     </Compile>
-    <Compile Include="UnitTest\DataTest.cs" />
-    <Compile Include="UnitTest\Delete.cs" />
-    <Compile Include="UnitTest\ExpressionTest\Field.cs" />
-    <Compile Include="UnitTest\ExpressionTest\Method.cs" />
-    <Compile Include="UnitTest\ExpressionTest\Select.cs" />
-    <Compile Include="UnitTest\ExpressionTest\Where.cs" />
-    <Compile Include="UnitTest\Insert.cs" />
-    <Compile Include="UnitTest\Mapping .cs" />
-    <Compile Include="UnitTest\Query\JoinQuery.cs" />
-    <Compile Include="UnitTest\Query\SelectQuery.cs" />
-    <Compile Include="UnitTest\Query\SingleQuery.cs" />
-    <Compile Include="UnitTest\Setting\Attribute.cs" />
-    <Compile Include="UnitTest\Setting\AutoClose.cs" />
-    <Compile Include="UnitTest\Setting\MapColumn.cs" />
-    <Compile Include="UnitTest\Setting\MapTable.cs" />
-    <Compile Include="UnitTest\UnitTestBase.cs" />
-    <Compile Include="UnitTest\Update.cs" />
+    <Compile Include="OldTests\UnitTest\DataTest.cs" />
+    <Compile Include="OldTests\UnitTest\Delete.cs" />
+    <Compile Include="OldTests\UnitTest\ExpressionTest\Field.cs" />
+    <Compile Include="OldTests\UnitTest\ExpressionTest\Method.cs" />
+    <Compile Include="OldTests\UnitTest\ExpressionTest\Select.cs" />
+    <Compile Include="OldTests\UnitTest\ExpressionTest\Where.cs" />
+    <Compile Include="OldTests\UnitTest\Insert.cs" />
+    <Compile Include="OldTests\UnitTest\Mapping .cs" />
+    <Compile Include="OldTests\UnitTest\Query\JoinQuery.cs" />
+    <Compile Include="OldTests\UnitTest\Query\SelectQuery.cs" />
+    <Compile Include="OldTests\UnitTest\Query\SingleQuery.cs" />
+    <Compile Include="OldTests\UnitTest\Setting\Attribute.cs" />
+    <Compile Include="OldTests\UnitTest\Setting\AutoClose.cs" />
+    <Compile Include="OldTests\UnitTest\Setting\MapColumn.cs" />
+    <Compile Include="OldTests\UnitTest\Setting\MapTable.cs" />
+    <Compile Include="OldTests\UnitTest\UnitTestBase.cs" />
+    <Compile Include="OldTests\UnitTest\Update.cs" />
+    <Compile Include="UnitTest\Main.cs" />
+    <Compile Include="UnitTest\UAdo.cs" />
+    <Compile Include="UnitTest\UJson.cs" />
+    <Compile Include="UnitTest\Updateable.cs" />
+    <Compile Include="UnitTest\UQueryable.cs" />
+    <Compile Include="UnitTest\UQueryableAsync.cs" />
+    <Compile Include="UnitTest\UThread.cs" />
+    <Compile Include="UnitTest\UThread2.cs" />
+    <Compile Include="UnitTest\UThread3.cs" />
+    <Compile Include="UnitTest\UValidate.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="App.config" />
@@ -105,9 +135,9 @@
     </ProjectReference>
   </ItemGroup>
   <ItemGroup>
-    <Content Include="DataBase\sqlsugar4xtest.sql" />
-    <Content Include="OtherDll\SyntacticSugar.dll" />
-    <Content Include="T4\SugarTemplate.tt">
+    <Content Include="OldTests\DataBase\sqlsugar4xtest.sql" />
+    <Content Include="OldTests\OtherDll\SyntacticSugar.dll" />
+    <Content Include="OldTests\T4\SugarTemplate.tt">
       <Generator>TextTemplatingFileGenerator</Generator>
       <LastGenOutput>SugarTemplate2.cs</LastGenOutput>
     </Content>

Src/Asp.Net/MySqlTest/OldTests/OldTestMain.cs

@@ -0,0 +1,49 @@
+using OrmTest;
+using OrmTest.UnitTest;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MySqlTest
+{
+    public  class OldTestMain
+    {
+        public static void Init() {
+
+
+            ////    /***Unit Test***/
+            new Field(1).Init();
+            new Where(1).Init();
+            new Method(1).Init();
+            new JoinQuery(1).Init();
+            new SingleQuery(1).Init();
+            new SelectQuery(1).Init();
+            new AutoClose(1).Init();
+            new Insert(1).Init();
+            new Delete(1).Init();
+            new Update(1).Init();
+            new Mapping(1).Init();
+            new DataTest(1).Init();
+
+            //    /***Performance Test***/
+            //    new SqlSugarPerformance(100).Select();
+
+            /***Demo***/
+            OrmTest.Demo.Query.Init();
+            OrmTest.Demo.Insert.Init();
+            OrmTest.Demo.Delete.Init();
+            OrmTest.Demo.Update.Init();
+            OrmTest.Demo.DbFirst.Init();
+            OrmTest.Demo.JoinSql.Init();
+            OrmTest.Demo.Filter.Init();
+            OrmTest.Demo.ComplexModel.Init();
+            OrmTest.Demo.CodeFirst.Init(); ;
+            OrmTest.Demo.MasterSlave.Init(); ;
+            OrmTest.Demo.Queue.Init(); ;
+            OrmTest.Demo.Encode.Init();
+        }
+
+    }
+}

Src/Asp.Net/MySqlTest/OldTests/PerformanceTesting/SqlSugarPerformance.cs

@@ -19,7 +19,7 @@ namespace OrmTest.PerformanceTesting
             SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
             {
                 ConnectionString = Config.ConnectionString,
-                DbType = DbType.SqlServer,
+                DbType = DbType.MySql,
                 IsAutoCloseConnection = false
             });
             db.IgnoreColumns.Add("TestId", "Student");

Src/Asp.Net/MySqlTest/OldTests/UnitTest/Setting/MapColumn.cs

@@ -11,7 +11,7 @@ namespace OrmTest.UnitTest
     {
         public SqlSugarClient GetInstance()
         {
-            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { ConnectionString = Config.ConnectionString, DbType = DbType.SqlServer });
+            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { ConnectionString = Config.ConnectionString, DbType = DbType.MySql });
             return db;
         }
     }

Src/Asp.Net/MySqlTest/OldTests/UnitTest/Setting/MapTable.cs

@@ -21,7 +21,7 @@ namespace OrmTest.UnitTest
         }
         public SqlSugarClient GetInstance()
         {
-            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { ConnectionString = Config.ConnectionString, DbType = DbType.SqlServer, IsAutoCloseConnection = true });
+            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { ConnectionString = Config.ConnectionString, DbType = DbType.MySql, IsAutoCloseConnection = true });
             return db;
         }
     }

Src/Asp.Net/MySqlTest/Program.cs

@@ -1,15 +1,6 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Reflection;
-using System.Text;
-using System.Threading.Tasks;
-using System.Linq.Expressions;
-using SqlSugar;
-using OrmTest.Models;
-using System.Data.SqlClient;
+using OrmTest.PerformanceTesting;
 using OrmTest.UnitTest;
-using OrmTest.PerformanceTesting;
+using System;
 
 namespace OrmTest
 {
@@ -17,36 +8,25 @@ namespace OrmTest
     {
         static void Main(string[] args)
         {
-            ////    /***Unit Test***/
-            new Field(1).Init();
-            new Where(1).Init();
-            new Method(1).Init();
-            new JoinQuery(1).Init();
-            new SingleQuery(1).Init();
-            new SelectQuery(1).Init();
-            new AutoClose(1).Init();
-            new Insert(1).Init();
-            new Delete(1).Init();
-            new Update(1).Init();
-            new Mapping(1).Init();
-            new DataTest(1).Init();
+            // OldTestMain.Init();
 
-            //    /***Performance Test***/
-            //    new SqlSugarPerformance(100).Select();
+            //Demo
+            Demo0_SqlSugarClient.Init();
+            Demo1_Queryable.Init();
+            Demo2_Updateable.Init();
+            Democ_GobalFilter.Init();
+            DemoD_DbFirst.Init();
+            DemoE_CodeFirst.Init();
+            Demo5_SqlQueryable.Init();
+            Demo6_Queue.Init();
 
-            /***Demo***/
-            OrmTest.Demo.Query.Init();
-            OrmTest.Demo.Insert.Init();
-            OrmTest.Demo.Delete.Init();
-            OrmTest.Demo.Update.Init();
-            OrmTest.Demo.DbFirst.Init();
-            OrmTest.Demo.JoinSql.Init();
-            OrmTest.Demo.Filter.Init();
-            OrmTest.Demo.ComplexModel.Init();
-            OrmTest.Demo.CodeFirst.Init();;
-            OrmTest.Demo.MasterSlave.Init(); ;
-            OrmTest.Demo.Queue.Init(); ;
-            OrmTest.Demo.Encode.Init();
+            //Unit test
+            NewUnitTest.Init();
+
+            Console.WriteLine("all successfully.");
+            Console.ReadKey();
         }
+
+ 
     }
 }

Src/Asp.Net/MySqlTest/T4/SugarTemplate2.cs

@@ -1 +0,0 @@
-

Src/Asp.Net/MySqlTest/UnitTest/Main.cs

@@ -0,0 +1,38 @@
+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.MySql,
+            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 Init()
+        {
+            Updateable();
+            Json();
+            Ado();
+            Queryable();
+            QueryableAsync();
+            Thread();
+            Thread2();
+            Thread3();
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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<dynamic>("select @id as id", new { id = 5 });
+            UValidate.Check(5, task6[0].id, "ado");
+
+
+            var task7 = Db.Ado.SqlQueryAsync<dynamic>("select @id as id", new { id = 7 });
+            task7.Wait();
+            UValidate.Check(7, task7.Result[0].id, "ado");
+
+
+            var task8 = Db.Ado.SqlQueryAsync<dynamic>("select 8 as id");
+            task8.Wait();
+            UValidate.Check(8, task8.Result[0].id, "ado");
+
+            var task9=Db.Ado.SqlQuery<Order, OrderItem>("select * from `order` ;select * from OrderDetail");
+
+            var task10 = Db.Ado.SqlQueryAsync<Order, OrderItem>("select * from `order`;select * from OrderDetail");
+            task10.Wait();
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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<JsonTest>();
+            Db.DbMaintenance.TruncateTable<JsonTest>();
+            Db.Insertable(new JsonTest() { Order = new Order { Id = 1, Name = "order1" } }).ExecuteCommand();
+            var list = Db.Queryable<JsonTest>().ToList();
+            UValidate.Check("order1", list.First().Order.Name, "Json");
+            Db.Updateable(new JsonTest() { Id = 1, Order = new Order { Id = 2, Name = "order2" } }).ExecuteCommand();
+            list= Db.Queryable<JsonTest>().ToList();
+            UValidate.Check("order2", list.First().Order.Name, "Json");
+            var list2 = Db.Queryable<JsonTest>().ToList();
+        }
+    }
+
+
+    public class JsonTest
+    {
+        [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
+        public int Id { get; set; }
+        [SqlSugar.SugarColumn(ColumnDataType = "varchar(4000)", IsJson = true)]
+        public Order Order { get; set; }
+    }
+}

Src/Asp.Net/MySqlTest/UnitTest/UQueryable.cs

@@ -0,0 +1,26 @@
+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<Order>().ToPageList(pageindex, pagesize, ref total, ref totalPage);
+
+            Db.CodeFirst.InitTables(typeof(CarType));
+            Db.Updateable<CarType>()
+                  .SetColumns(it => new CarType { State =SqlSugar.SqlFunc.IIF(it.State==true,false,true) }).Where(it=>true)
+               .ExecuteCommand();
+
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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<int> total = 0;
+            var count = Db.Queryable<Order>().Count();
+            Task t = Db.Queryable<Order>().ToPageListAsync(1, 2, total);
+            t.Wait();
+            UValidate.Check(count, total.Value, "QueryableAsync");
+        }
+        private static void q2()
+        {
+            RefAsync<int> total = 0;
+            var count = Db.Queryable<Order>().Count();
+            Task t = Db.Queryable<Order>().ToDataTablePageAsync(1, 2, total);
+            t.Wait();
+            UValidate.Check(count, total.Value, "QueryableAsync");
+        }
+        private static void q3()
+        {
+            RefAsync<int> total = 0;
+            var count = Db.Queryable<Order>().Count();
+            Task t = Db.Queryable<Order>().ToJsonPageAsync(1, 2, total);
+            t.Wait();
+            UValidate.Check(count, total.Value, "QueryableAsync");
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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.MySql,
+            ConnectionString = Config.ConnectionString,
+            InitKeyType = InitKeyType.Attribute,
+            IsAutoCloseConnection = true,
+            AopEvents = new AopEvents
+            {
+                OnLogExecuting = (sql, p) =>
+                {
+                    Console.WriteLine(sql);
+                    Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+                }
+            }
+        });
+        public static SqlSugarClient ssDb => new SqlSugarClient(new ConnectionConfig()
+        {
+            DbType = DbType.MySql,
+            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.MySql,
+            ConnectionString = Config.ConnectionString,
+            InitKeyType = InitKeyType.Attribute,
+            IsAutoCloseConnection = true,
+            AopEvents = new AopEvents
+            {
+                OnLogExecuting = (sql, p) =>
+                {
+                    Console.WriteLine(sql);
+                    Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+                }
+            }
+        });
+        public static SqlSugarClient singleAndSsDb = new SqlSugarClient(new ConnectionConfig()
+        {
+            DbType = DbType.MySql,
+            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);
+        }
+    }
+}

Src/Asp.Net/MySqlTest/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<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToList();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait(); ;
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().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<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(6);
+                }
+
+            });
+            t1.Start();
+            t2.Start();
+            t3.Start();
+
+            Task.WaitAll(t1, t2, t3);
+        }
+
+        private static void IsShardSameThreadAsync2()
+        {
+            var t1 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(1);
+                }
+
+            });
+            var t2 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(10);
+                }
+
+            });
+            var t3 = new Task(() =>
+            {
+                for (int i = 0; i < 100; i++)
+                {
+                    simpleDb.Queryable<Order>().Take(10).ToListAsync().Wait();
+                    System.Threading.Thread.Sleep(6);
+                }
+
+            });
+            t1.Start();
+            t2.Start();
+            t3.Start();
+
+            Task.WaitAll(t1, t2, t3);
+        }
+    }
+}

Src/Asp.Net/MySqlTest/UnitTest/UThread3.cs

@@ -0,0 +1,117 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+    public partial class NewUnitTest
+    {
+
+        public static void Thread3()
+        {
+            Console.WriteLine("Thread3");
+            SimpleAsync3();
+            IsShardSameThreadAsync3();
+            SingleAsync3();
+            SingleAndIsShardSameThreadAsync3();
+
+        }
+
+
+
+        private static async Task SimpleAsync3()
+        {
+
+            for (int i = 0; i < 100; i++)
+            {
+                await simpleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await simpleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await simpleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task SingleAndIsShardSameThreadAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await singleAndSsDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await singleAndSsDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await singleAndSsDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task SingleAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await singleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await singleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await singleDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+
+        private static async Task IsShardSameThreadAsync3()
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await ssDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+
+            for (int i = 0; i < 100; i++)
+            {
+                await ssDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync();
+            }
+
+            List<Order> orders = new List<Order>();
+            for (int i = 0; i < 100; i++)
+            {
+                orders = await ssDb.Queryable<Order>().Take(10).ToListAsync();
+            }
+            if (orders.Count > 0)
+            {
+                Console.WriteLine("async is ok");
+            }
+        }
+    }
+}

Src/Asp.Net/MySqlTest/UnitTest/UValidate.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+    public class UValidate
+    {
+        public static void Check(object a, object b, object name)
+        {
+            if (a?.ToString() != b?.ToString())
+            {
+                throw new Exception(name + " error");
+            }
+        }
+    }
+}

Src/Asp.Net/MySqlTest/UnitTest/Updateable.cs

@@ -0,0 +1,90 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace OrmTest
+{
+    public partial class NewUnitTest
+    {
+        public static void Updateable()
+        {
+            Db.CodeFirst.InitTables(typeof(SYS_USER));
+            Db.DbMaintenance.TruncateTable<SYS_USER>();
+            Db.Insertable(new SYS_USER() { USER_ID=1,USER_ACCOUNT = "a", USER_PWD = "b", USER_NAME = "c", PWD_LASTCHTIME = DateTime.Now, PWD_ERRORCOUNT = 1, PWD_LASTERRTIME = DateTime.Now }).ExecuteCommand();
+            Db.Updateable(new SYS_USER() { USER_ID=1, PWD_LASTERRTIME = null }).WhereColumns(it=> new{ it.PWD_ERRORCOUNT, it.PWD_LASTERRTIME }).ExecuteCommand();
+            
+        }
+    }
+    /// <summary>
+    /// 普通用户表
+    /// </summary>
+    [Serializable]
+    public class SYS_USER 
+    {
+        private System.Int64? _USER_ID;
+        /// <summary>
+        /// GUID主键
+        /// </summary>
+        [SugarColumn(IsPrimaryKey = true, IsIdentity = false)]
+        public System.Int64? USER_ID { get { return this._USER_ID; } set { this._USER_ID = value; } }
+
+        private System.String _USER_ACCOUNT;
+        /// <summary>
+        /// 用户账号，不可重名，即使是假删除了，亦不可重复
+        /// </summary>
+        public System.String USER_ACCOUNT { get { return this._USER_ACCOUNT; } set { this._USER_ACCOUNT = value; } }
+
+        private System.String _USER_PWD;
+        /// <summary>
+        /// 用户密码
+        /// </summary>
+        public System.String USER_PWD
+        {
+            get { return this._USER_PWD; }
+            set { this._USER_PWD = value; }
+        }
+        /// <summary>
+        /// 不允许用户密码序列化，可以反序列化
+        /// </summary>
+        /// <returns></returns>
+        public bool ShouldSerializeUSER_PWD()
+        {
+            return false;
+        }
+
+        private System.String _USER_NAME;
+        /// <summary>
+        /// 用户姓名
+        /// </summary>
+
+        public System.String USER_NAME { get { return this._USER_NAME; } set { this._USER_NAME = value; } }
+
+        private System.Int32 _USER_STATUS;
+        /// <summary>
+        /// 用户状体：10正常；20锁定；99已删除
+        /// </summary>
+        public System.Int32 USER_STATUS { get { return this._USER_STATUS; } set { this._USER_STATUS = value; } }
+
+        private System.DateTime _PWD_LASTCHTIME;
+        /// <summary>
+        /// 最后一次密码更新时间
+        /// </summary>
+        public System.DateTime PWD_LASTCHTIME { get { return this._PWD_LASTCHTIME; } set { this._PWD_LASTCHTIME = value; } }
+
+        private System.Int32? _PWD_ERRORCOUNT;
+        /// <summary>
+        /// 密码错误次数，达到定义的次数就锁定
+        /// </summary>
+		public System.Int32? PWD_ERRORCOUNT { get { return this._PWD_ERRORCOUNT; } set { this._PWD_ERRORCOUNT = value ?? 0; } }
+
+        private System.DateTime? _PWD_LASTERRTIME = null;
+        /// <summary>
+        /// 密码最后一次错误时间，满足定义的时间差之后，可自动解锁，如20分钟后自动解锁，亦作为累次错误次数的时间差比对基础
+        /// 允许为空
+        /// </summary>
+        public System.DateTime? PWD_LASTERRTIME { get { return this._PWD_LASTERRTIME; } set { this._PWD_LASTERRTIME = value; } }
+    }
+}