diff --git a/Src/Asp.Net/SqlSugar/Infrastructure/InstanceFactory.cs b/Src/Asp.Net/SqlSugar/Infrastructure/InstanceFactory.cs index a88dd08ef..39d61ace2 100644 --- a/Src/Asp.Net/SqlSugar/Infrastructure/InstanceFactory.cs +++ b/Src/Asp.Net/SqlSugar/Infrastructure/InstanceFactory.cs @@ -229,6 +229,10 @@ namespace SqlSugar { return new PostgreSQLInserttable(); } + else if (currentConnectionConfig.DbType == DbType.Kdbndp) + { + return new KdbndpInserttable(); + } else { return new InsertableProvider(); diff --git a/Src/Asp.Net/SqlSugar/Infrastructure/KdbndpInserttable.cs b/Src/Asp.Net/SqlSugar/Infrastructure/KdbndpInserttable.cs new file mode 100644 index 000000000..7bcd447c6 --- /dev/null +++ b/Src/Asp.Net/SqlSugar/Infrastructure/KdbndpInserttable.cs @@ -0,0 +1,6 @@ +namespace SqlSugar +{ + internal class KdbndpInserttable : InsertableProvider where T : class, new() + { + } +} \ No newline at end of file diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest.cs new file mode 100644 index 000000000..785b23863 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest.cs @@ -0,0 +1,227 @@ +//using SqlSugar; +//using System; +//using System.Collections.Generic; +//using System.ComponentModel.DataAnnotations; +//using System.Linq; +//using System.Text; +//using System.Threading.Tasks; + +//namespace OrmTest.Test +//{ +// public class BugTest +// { +// public static void Init() +// { +// SqlSugarClient Db = new SqlSugarClient(new ConnectionConfig() +// { +// ConnectionString = @"PORT=5433;DATABASE=x;HOST=localhost;PASSWORD=haosql;USER ID=postgres", +// DbType = DbType.Kdbndp, +// IsAutoCloseConnection = true, +// //MoreSettings = new ConnMoreSettings() +// //{ +// // PgSqlIsAutoToLower = true //我们这里需要设置为false +// //}, +// InitKeyType = InitKeyType.Attribute, +// }); +// //调式代码 用来打印SQL +// Db.Aop.OnLogExecuting = (sql, pars) => +// { +// // Debug.WriteLine(sql); +// }; + +// var 查询成功 = Db.Queryable() +// .Where(x => x.Enable == true) //不加 ture ，也会出错 +// .ToList(); + + +// var Dbfirst情况使用Mapper_Menu_Id为大写自动转成小写 = Db.Queryable() +// .Where(x => x.Enable == true) +// .Mapper(x => x.orderList, x => x.Menu_Id) //初始化数据库失败42703: 字段 "menu_id" 不存在 +// .ToList(); +// } +// } +// public class Sys_RoleAuth +// { +// /// +// /// +// /// +// [Key] +// [Display(Name = "")] +// [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] +// public int Auth_Id { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// public int Role_Id { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// public int User_Id { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// [SugarColumn(IsNullable = false)] +// public int Menu_Id { get; set; } + +// /// +// ///用户权限 +// /// +// [Display(Name = "用户权限")] +// [SugarColumn(IsNullable = false, IsJson = true, ColumnDataType = "json")] +// public List AuthValue { get; set; } = new List(); + +// /// +// /// +// /// +// [Display(Name = "")] +// [MaxLength(100)] +// public string Creator { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// public DateTime CreateDate { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// [MaxLength(100)] +// public string Modifier { get; set; } + +// /// +// /// +// /// +// [Display(Name = "")] +// public DateTime ModifyDate { get; set; } +// } +// public class Sys_Actions +// { +// public int Action_Id { get; set; } +// public int Menu_Id { get; set; } +// public string Text { get; set; } +// public string Value { get; set; } +// } +// public class Sys_Menu +// { +// /// +// ///ID +// /// +// [Key] +// [Display(Name = "ID")] +// [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] +// public int Menu_Id { get; set; } + +// /// +// ///父级ID +// /// +// [Display(Name = "父级ID")] +// [SugarColumn(IsNullable = false)] +// public int ParentId { get; set; } + + +// /// +// ///菜单名称 +// /// +// [Display(Name = "菜单名称")] +// [MaxLength(50)] +// [SugarColumn(IsNullable = false)] +// public string MenuName { get; set; } + +// /// +// /// +// /// +// [Display(Name = "TableName")] +// [MaxLength(200)] +// public string TableName { get; set; } + +// /// +// /// +// /// +// [Display(Name = "Url")] +// [MaxLength(10000)] +// public string Url { get; set; } + +// /// +// ///权限 +// /// +// [Display(Name = "权限")] +// [MaxLength(-1)] +// [SugarColumn(IsNullable = false, IsJson = true, ColumnDataType = "json")] +// public List Auth { get; set; } = new List(); + +// /// +// /// +// /// +// [Display(Name = "Description")] +// [MaxLength(200)] +// public string Description { get; set; } + + +// /// +// ///图标 +// /// +// [Display(Name = "图标")] +// [MaxLength(50)] +// public string Icon { get; set; } + +// /// +// ///排序号 +// /// +// [Display(Name = "排序号")] +// public int OrderNo { get; set; } + +// /// +// ///创建人 +// /// +// [Display(Name = "创建人")] +// [MaxLength(50)] +// public string Creator { get; set; } + +// /// +// ///创建时间 +// /// +// [Display(Name = "创建时间")] +// public DateTime? CreateDate { get; set; } = DateTime.Now; + +// /// +// /// +// /// +// [Display(Name = "Modifier")] +// [MaxLength(50)] +// public string Modifier { get; set; } + +// /// +// /// +// /// +// [Display(Name = "ModifyDate")] +// public DateTime? ModifyDate { get; set; } + +// /// +// ///是否启用 +// /// +// [Display(Name = "是否启用")] +// public bool Enable { get; set; } + +// [SugarColumn(IsIgnore = true)] +// public List orderList { get; set; } +// } + +// public class Order +// { +// [Key] +// [Display(Name = "ID")] +// [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] +// public int Id { get; set; } + +// public int Menu_Id { get; set; } +// } + +//} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest2.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest2.cs new file mode 100644 index 000000000..37e35be83 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest2.cs @@ -0,0 +1,53 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.ComponentModel.DataAnnotations; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest.Test +{ + public class BugTest + { + public static void Init() + { + SqlSugarClient Db = new SqlSugarClient(new ConnectionConfig() + { + ConnectionString = @"PORT=5433;DATABASE=x;HOST=localhost;PASSWORD=haosql;USER ID=postgres", + DbType = DbType.Kdbndp, + IsAutoCloseConnection = true, + //MoreSettings = new ConnMoreSettings() + //{ + // PgSqlIsAutoToLower = true //我们这里需要设置为false + //}, + InitKeyType = InitKeyType.Attribute, + }); + //调式代码 用来打印SQL + Db.Aop.OnLogExecuting = (sql, pars) => + { + // Debug.WriteLine(sql); + }; + + Db.CodeFirst.InitTables(typeof(My12311x1)); + + var id = Db.Insertable(new My12311x1 { Menu_Id = new int[] { 1, 2 } }).ExecuteReturnIdentity(); + var list = Db.Queryable().InSingle(id); + list.Menu_Id = new int[] { 3 }; + Db.Updateable(list).ExecuteCommand(); + list = Db.Queryable().InSingle(id); + } + } + + public class My12311x1 + { + [Key] + [Display(Name = "ID")] + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + + [SugarColumn(ColumnDataType = "int []", IsArray = true)] + public int[] Menu_Id { get; set; } + } + +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest3.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest3.cs new file mode 100644 index 000000000..1ee77a4c9 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Bugs/BugTest3.cs @@ -0,0 +1,46 @@ +//using SqlSugar; +//using System; +//using System.Collections.Generic; +//using System.ComponentModel.DataAnnotations; +//using System.Linq; +//using System.Text; +//using System.Threading.Tasks; + +//namespace OrmTest.Test +//{ +// public class BugTest +// { +// public static void Init() +// { +// SqlSugarClient Db = new SqlSugarClient(new ConnectionConfig() +// { +// ConnectionString = @"PORT=5433;DATABASE=x;HOST=localhost;PASSWORD=haosql;USER ID=postgres", +// DbType = DbType.Kdbndp, +// IsAutoCloseConnection = true, + +// InitKeyType = InitKeyType.Attribute, +// }); +// //调式代码 用来打印SQL +// Db.Aop.OnLogExecuting = (sql, pars) => +// { +// Console.WriteLine(sql); +// }; + +// Db.CodeFirst.InitTables(typeof(testmmmm121)); + +// var id = Db.Insertable(new testmmmm121 { name = "a", isok = true }).ExecuteReturnIdentity(); +// var list = Db.Queryable().InSingle(id); +// var x = Db.Queryable().Where(it => !it.isok).ToList(); + +// } +// } + +// public class testmmmm121 +// { +// [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] +// public int id { get; set; } +// public string name { get; set; } +// public bool isok { get; set; } +// } + +//} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Config.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Config.cs new file mode 100644 index 000000000..989744704 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Config.cs @@ -0,0 +1,31 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + /// + /// Setting up the database name does not require you to create the database + /// 设置好数据库名不需要你去手动建库 + /// + public class Config + { + /// + /// Account have permission to create database + /// 用有建库权限的数据库账号 + /// + public static string ConnectionString = "Server=127.0.0.1;Port=54321;UID=SYSTEM;PWD=system;database=SQLSUGAR4XTEST1"; + /// + /// Account have permission to create database + /// 用有建库权限的数据库账号 + /// + public static string ConnectionString2 = "Server=127.0.0.1;Port=54321;UID=SYSTEM;PWD=system;database=SQLSUGAR4XTEST2"; + /// + /// Account have permission to create database + /// 用有建库权限的数据库账号 + /// + public static string ConnectionString3 = "Server=127.0.0.1;Port=54321;UID=SYSTEM;PWD=system;database=SQLSUGAR4XTEST3"; + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo0_SqlSugarClient.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo0_SqlSugarClient.cs new file mode 100644 index 000000000..45cfa3f97 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo0_SqlSugarClient.cs @@ -0,0 +1,416 @@ +using System; +using System.Collections.Generic; +using System.ComponentModel.DataAnnotations; +using System.ComponentModel.DataAnnotations.Schema; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using SqlSugar; +namespace OrmTest +{ + public class Demo0_SqlSugarClient + { + + public static void Init() + { + SqlSugarClient();//Create db + DbContext();//Optimizing SqlSugarClient usage + SingletonPattern();//Singleten Pattern + DistributedTransactionExample(); + MasterSlave();//Read-write separation + CustomAttribute(); + } + + private static void MasterSlave() + { + Console.WriteLine(""); + Console.WriteLine("#### MasterSlave Start ####"); + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + ConnectionString = Config.ConnectionString,//Master Connection + DbType = DbType.Kdbndp, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + SlaveConnectionConfigs = new List() { + new SlaveConnectionConfig() { HitRate=10, ConnectionString=Config.ConnectionString2 } , + new SlaveConnectionConfig() { HitRate=10, ConnectionString=Config.ConnectionString2 } + } + }); + db.Aop.OnLogExecuted = (s, p) => + { + Console.WriteLine(db.Ado.Connection.ConnectionString); + }; + Console.WriteLine("Master:"); + db.Insertable(new Order() { Name = "abc", CustomId = 1, CreateTime = DateTime.Now }).ExecuteCommand(); + Console.WriteLine("Slave:"); + db.Queryable().First(); + Console.WriteLine("#### MasterSlave End ####"); + } + + private static void SqlSugarClient() + { + //Create db + Console.WriteLine("#### SqlSugarClient Start ####"); + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + db.Open(); + //If no exist create datebase + db.DbMaintenance.CreateDatabase(); + + //Use db query + var dt = db.Ado.GetDataTable("select 1"); + + //Create tables + db.CodeFirst.InitTables(typeof(OrderItem),typeof(Order)); + var id = db.Insertable(new Order() { Name = "order1", CustomId = 1, Price = 0, CreateTime = DateTime.Now }).ExecuteReturnIdentity(); + + //Insert data + db.Insertable(new OrderItem() { OrderId = id, Price = 0, CreateTime=DateTime.Now }).ExecuteCommand(); + Console.WriteLine("#### SqlSugarClient End ####"); + + } + + private static void DbContext() + { + Console.WriteLine(""); + Console.WriteLine("#### DbContext Start ####"); + var insertObj = new Order { Name = "jack", CreateTime = DateTime.Now }; + var InsertObjs = new Order[] { insertObj }; + + DbContext context = new DbContext(); + + context.Db.CodeFirst.InitTables();//Create Tables + ; + var orderDb = context.OrderDb; + + //Select + var data1 = orderDb.GetById(1); + var data2 = orderDb.GetList(); + var data3 = orderDb.GetList(it => it.Id == 1); + var data4 = orderDb.GetSingle(it => it.Id == 1); + var p = new PageModel() { PageIndex = 1, PageSize = 2 }; + var data5 = orderDb.GetPageList(it => it.Name == "xx", p); + Console.Write(p.PageCount); + var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc); + Console.Write(p.PageCount); + List conModels = new List(); + conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1", FieldValueConvertFunc=it=>Convert.ToInt32(it) });//id=1 + var data7 = orderDb.GetPageList(conModels, p, it => it.Name, OrderByType.Asc); + orderDb.AsQueryable().Where(x => x.Id == 1).ToList(); + + //Insert + orderDb.Insert(insertObj); + orderDb.InsertRange(InsertObjs); + var id = orderDb.InsertReturnIdentity(insertObj); + orderDb.AsInsertable(insertObj).ExecuteCommand(); + + + //Delete + orderDb.Delete(insertObj); + orderDb.DeleteById(11111); + orderDb.DeleteById(new int[] { 1111, 2222 }); + orderDb.Delete(it => it.Id == 1111); + orderDb.AsDeleteable().Where(it => it.Id == 1111).ExecuteCommand(); + + //Update + orderDb.Update(insertObj); + orderDb.UpdateRange(InsertObjs); + orderDb.Update(it => new Order() { Name = "a", }, it => it.Id == 1); + orderDb.AsUpdateable(insertObj).UpdateColumns(it => new { it.Name }).ExecuteCommand(); + + //Use Inherit DbContext + OrderDal dal = new OrderDal(); + var data = dal.GetById(1); + var list = dal.GetList(); + + Console.WriteLine("#### DbContext End ####"); + } + + private static void CustomAttribute() + { + Console.WriteLine(""); + Console.WriteLine("#### Custom Attribute Start ####"); + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + ConnectionString = Config.ConnectionString, + DbType = DbType.Kdbndp, + IsAutoCloseConnection = true, + InitKeyType = InitKeyType.Attribute, + ConfigureExternalServices = new ConfigureExternalServices() + { + EntityService = (property, column) => + { + + var attributes = property.GetCustomAttributes(true);//get all attributes + + if (attributes.Any(it => it is KeyAttribute))// by attribute set primarykey + { + column.IsPrimarykey = true; + } + }, + EntityNameService = (type, entity) => + { + var attributes = type.GetCustomAttributes(true); + if (attributes.Any(it => it is TableAttribute)) + { + entity.DbTableName = (attributes.First(it => it is TableAttribute) as TableAttribute).Name; + } + } + } + }); + db.CodeFirst.InitTables();//Create Table + + db.Insertable(new AttributeTable() { Id = Guid.NewGuid().ToString(), Name = "Name" }).ExecuteCommand(); + var list = db.Queryable().ToList(); + + Console.WriteLine("#### Custom Attribute End ####"); + } + + + private static void SingletonPattern() + { + Console.WriteLine(""); + Console.WriteLine("#### Singleton Pattern Start ####"); + Console.WriteLine("Db_Id:" + singleDb.ContextID); + Console.WriteLine("Db_Id:" + singleDb.ContextID); + var task = new Task(() => + { + Console.WriteLine("Task DbId:" + singleDb.ContextID); + new Task(() => + { + Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID); + Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID); + + }).Start(); + Console.WriteLine("Task DbId:" + singleDb.ContextID); + }); + task.Start(); + task.Wait(); + System.Threading.Thread.Sleep(500); + Console.WriteLine(string.Join(",", singleDb.TempItems.Keys)); + + Console.WriteLine("#### Singleton Pattern end ####"); + } + + static SqlSugarClient singleDb = new SqlSugarClient( + new ConnectionConfig() + { + ConfigId = 1, + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents() + { + OnLogExecuting = (sql, p) => { Console.WriteLine(sql); } + } + }); + + + private static void DistributedTransactionExample() + { + Console.WriteLine(""); + Console.WriteLine("#### Distributed TransactionExample Start ####"); + SqlSugarClient db = new SqlSugarClient(new List() + { + new ConnectionConfig(){ ConfigId="1", DbType=DbType.Kdbndp, ConnectionString=Config.ConnectionString,InitKeyType=InitKeyType.Attribute,IsAutoCloseConnection=true }, + new ConnectionConfig(){ ConfigId="2", DbType=DbType.Kdbndp, ConnectionString=Config.ConnectionString2 ,InitKeyType=InitKeyType.Attribute ,IsAutoCloseConnection=true} + }); + + //use db1 + db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem));// + db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand(); + Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count()); + + //use db2 + db.ChangeDatabase("2"); + db.DbMaintenance.CreateDatabase();//Create Database2 + db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem)); + db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand(); + Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count()); + + // Example 1 + Console.WriteLine("Example 1"); + try + { + db.BeginTran(); + + db.ChangeDatabase("1");//use db1 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use db2 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + throw new Exception(); + db.CommitTran(); + } + catch + { + db.RollbackTran(); + Console.WriteLine("---Roll back"); + db.ChangeDatabase("1");//use db1 + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use db2 + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + } + + + + // Example 2 + Console.WriteLine("Example 2"); + + var result=db.UseTran(() => + { + + db.ChangeDatabase("1");//use db1 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use db2 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + throw new Exception(""); + + }); + if (result.IsSuccess == false) { + Console.WriteLine("---Roll back"); + db.ChangeDatabase("1");//use db1 + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use db2 + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + } + + // Example 3 + Console.WriteLine("Example 3"); + + var result2 = db.UseTranAsync(() => + { + + db.ChangeDatabase("1");//use db1 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use db2 + db.Deleteable().ExecuteCommand(); + Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + throw new Exception(""); + + }); + result2.Wait(); + if (result.IsSuccess == false) + { + Console.WriteLine("---Roll back"); + db.ChangeDatabase("1");//use sqlserver + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + + db.ChangeDatabase("2");//use mysql + Console.WriteLine(db.CurrentConnectionConfig.DbType); + Console.WriteLine(db.Queryable().Count()); + } + + Console.WriteLine("#### Distributed TransactionExample End ####"); + } + } + + /// + /// DbContext Example 1 + /// + public class DbContext + { + + public SqlSugarClient Db; + public DbContext() + { + Db = new SqlSugarClient(new ConnectionConfig() + { + ConnectionString = Config.ConnectionString, + DbType = DbType.Kdbndp, + IsAutoCloseConnection = true, + InitKeyType = InitKeyType.Attribute, + AopEvents = new AopEvents() + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + } + } + }); + } + public SimpleClient OrderDb => new SimpleClient(Db); + public SimpleClient OrderItemDb => new SimpleClient(Db); + } + + + public class OrderDal : DbContext + { + + } + /// + /// DbContext Example 2 + /// + /// + public class DbContext where T : class, new() + { + + public SqlSugarClient Db; + public DbContext() + { + Db = new SqlSugarClient(new ConnectionConfig() + { + ConnectionString = Config.ConnectionString, + DbType = DbType.Kdbndp, + IsAutoCloseConnection = true, + InitKeyType = InitKeyType.Attribute, + AopEvents = new AopEvents() + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + } + } + }); + } + public SimpleClient CurrentDb => new SimpleClient(Db); + public virtual T GetById(int id) + { + return CurrentDb.GetById(id); + } + public virtual List GetList() + { + return CurrentDb.GetList(); + } + public virtual bool Delete(int id) + { + return CurrentDb.DeleteById(id); + } + } + +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo1_Queryable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo1_Queryable.cs new file mode 100644 index 000000000..e66acdb17 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo1_Queryable.cs @@ -0,0 +1,341 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Data; +using System.Dynamic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + public class Demo1_Queryable + { + + public static void Init() + { + EasyExamples(); + QueryConditions(); + JoinTable(); + Async(); + NoEntity(); + Mapper(); + SqlFuncTest(); + Subquery(); + ReturnType(); + } + + private static void EasyExamples() + { + Console.WriteLine(""); + Console.WriteLine("#### Examples Start ####"); + var db = GetInstance(); + var dbTime = db.GetDate(); + var getAll = db.Queryable().ToList(); + var getOrderBy = db.Queryable().OrderBy(it => it.Name,OrderByType.Desc).ToList(); + var getOrderBy2 = db.Queryable().OrderBy(it => it.Id).OrderBy(it => it.Name, OrderByType.Desc).ToList(); + var getOrderBy3 = db.Queryable().OrderBy(it =>new { it.Name,it.Id}).ToList(); + var getRandom = db.Queryable().OrderBy(it => SqlFunc.GetRandom()).First(); + var getByPrimaryKey = db.Queryable().InSingle(2); + var getSingleOrDefault = db.Queryable().Where(it => it.Id == 1).Single(); + var getFirstOrDefault = db.Queryable().First(); + var getByWhere = db.Queryable().Where(it => it.Id == 1 || it.Name == "a").ToList(); + var getByWhere2 = db.Queryable().Where(it => it.Id == DateTime.Now.Year).ToList(); + var getByFuns = db.Queryable().Where(it => SqlFunc.IsNullOrEmpty(it.Name)).ToList(); + var getByFuns2 = db.Queryable().GroupBy(it => it.Name).Select(it => SqlFunc.AggregateDistinctCount(it.Price)).ToList(); + Console.WriteLine("#### Examples End ####"); + } + + private static void ReturnType() + { + Console.WriteLine(""); + Console.WriteLine("#### ReturnType Start ####"); + var db = GetInstance(); + List list = db.Queryable().ToList(); + + Order item = db.Queryable().First(it => it.Id == 1); + + DataTable dataTable = db.Queryable().Select(it => it.Id).ToDataTable(); + + var json = db.Queryable().ToJson(); + + List listInt = db.Queryable().Select(it => it.Id).ToList(); + + var dynamic = db.Queryable().Select().ToList(); + + var viewModel = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId , + JoinType.Left, o.CustomId == c.Id + )) + .Select().ToList(); + + var newDynamic = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, o.CustomId == c.Id + )) + .Select((o, i, c) => new { orderName = o.Name, cusName=c.Name }).ToList(); + + var newClass = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, o.CustomId == c.Id + )) + .Select((o, i, c) => new ViewOrder { Name=o.Name, CustomName=c.Name }).ToList(); + + + var oneClass = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, o.CustomId == c.Id + )) + .Select((o, i, c) => c).ToList(); + + var twoClass = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, o.CustomId == c.Id + )) + .Select((o, i, c) => new { o,i}).ToList(); + + List> ListDic = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, o.CustomId == c.Id + )) + .Select().ToList().Select(it => it.ToDictionary(x => x.Key, x => x.Value)).ToList(); + Console.WriteLine("#### ReturnType End ####"); + } + + private static void Subquery() + { + Console.WriteLine(""); + Console.WriteLine("#### Subquery Start ####"); + var db = GetInstance(); + + var list = db.Queryable().Take(10).Select(it => new + { + customName=SqlFunc.Subqueryable().Where("it.CustomId=id").Select(s=>s.Name), + customName2 = SqlFunc.Subqueryable().Where("it.CustomId = id").Where(s => true).Select(s => s.Name) + }).ToList(); + + var list2 = db.Queryable().Where(it => SqlFunc.Subqueryable().Where(i => i.OrderId == it.Id).Any()).ToList(); + + Console.WriteLine("#### Subquery End ####"); + } + + private static void SqlFuncTest() + { + Console.WriteLine(""); + Console.WriteLine("#### SqlFunc Start ####"); + var db = GetInstance(); + var index= db.Queryable().Select(it => SqlFunc.Contains("a", "cccacc")).First(); + + Console.WriteLine("#### SqlFunc End ####"); + } + + private static void Mapper() + { + Console.WriteLine(""); + Console.WriteLine("#### Mapper Start ####"); + var db = GetInstance(); + //Creater Table + db.CodeFirst.InitTables(typeof(Tree)); + db.DbMaintenance.TruncateTable("tree"); + db.Insertable(new Tree() { Id = 1, Name = "root" }).ExecuteCommand(); + db.Insertable(new Tree() { Id = 11, Name = "child1",ParentId=1 }).ExecuteCommand(); + db.Insertable(new Tree() { Id = 12, Name = "child2",ParentId=1 }).ExecuteCommand(); + db.Insertable(new Tree() { Id = 2, Name = "root" }).ExecuteCommand(); + db.Insertable(new Tree() { Id = 22, Name = "child3", ParentId = 2 }).ExecuteCommand(); + + // Same property name mapping,Both entities have parentId + var list = db.Queryable().Mapper(it => it.Parent, it => it.ParentId).ToList(); + + + //If both entities have parentId, I don't want to associate with parentId. + var list1 =db.Queryable() + //parent=(select * from parent where id=it.parentid) + .Mapper(it=>it.Parent,it=>it.ParentId, it=>it.Parent.Id) + //Child=(select * from parent where ParentId=it.id) + .Mapper(it => it.Child, it => it.Id, it => it.Parent.ParentId) + .ToList(); + //one to one + var list2 = db.Queryable().Mapper(it => it.Order, it => it.OrderId).ToList(); + + //one to many + var list3 = db.Queryable().Mapper(it => it.Items, it => it.Items.First().OrderId).ToList(); + + //many to many + db.CodeFirst.InitTables(); + + db.Insertable(new A() { Name = "A" }).ExecuteCommand(); + db.Insertable(new B() { Name = "B" }).ExecuteCommand(); + db.Insertable(new ABMapping() { AId = 1, BId = 1 }).ExecuteCommand(); + + var list4 = db.Queryable() + .Mapper(it => it.A, it => it.AId) + .Mapper(it => it.B, it => it.BId).ToList(); + + //Manual mode + var result = db.Queryable().Take(10).Select().Mapper((itemModel, cache) => + { + var allItems = cache.Get(orderList => { + var allIds = orderList.Select(it => it.Id).ToList(); + return db.Queryable().Where(it => allIds.Contains(it.OrderId)).ToList();//Execute only once + }); + itemModel.Items = allItems.Where(it => it.OrderId==itemModel.Id).ToList();//Every time it's executed + }).ToList(); + + Console.WriteLine("#### End Start ####"); + } + + private static void NoEntity() + { + Console.WriteLine(""); + Console.WriteLine("#### No Entity Start ####"); + var db = GetInstance(); + + var list = db.Queryable().AS("order").Where("id=id", new { id = 1 }).ToList(); + + var list2 = db.Queryable("o").AS("order").AddJoinInfo("OrderDetail", "i", "o.id=i.OrderId").Where("id=id", new { id = 1 }).Select("o.*").ToList(); + Console.WriteLine("#### No Entity End ####"); + } + + private static void JoinTable() + { + Console.WriteLine(""); + Console.WriteLine("#### Join Table Start ####"); + var db = GetInstance(); + + //Simple join + var list = db.Queryable((o, i, c) => o.Id == i.OrderId&&c.Id == o.CustomId) + .Select() + .ToList(); + + //Join table + var list2 = db.Queryable((o, i, c) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId, + JoinType.Left, c.Id == o.CustomId + )) + .Select().ToList(); + + //Join queryable + var query1 = db.Queryable((o, i) => new JoinQueryInfos( + JoinType.Left, o.Id == i.OrderId + )) + .Where(o => o.Name == "jack"); + + var query2 = db.Queryable(); + var list3=db.Queryable(query1, query2,JoinType.Left, (p1, p2) => p1.CustomId == p2.Id).Select().ToList(); + + Console.WriteLine("#### Join Table End ####"); + } + + private static void QueryConditions() + { + Console.WriteLine(""); + Console.WriteLine("#### Query Conditions Start ####"); + + SqlSugarClient db = GetInstance(); + + /*** By expression***/ + + //id=@id + var list = db.Queryable().Where(it => it.Id == 1).ToList(); + //id=@id or name like '%'+@name+'%' + var list2 = db.Queryable().Where(it => it.Id == 1 || it.Name.Contains("jack")).ToList(); + + + //Create expression + var exp = Expressionable.Create() + .And(it => it.Id == 1) + .Or(it => it.Name.Contains("jack")).ToExpression(); + var list3 = db.Queryable().Where(exp).ToList(); + + + /*** By sql***/ + + //id=@id + var list4 = db.Queryable().Where("id=@id", new { id = 1 }).ToList(); + //id=@id or name like '%'+@name+'%' + var list5 = db.Queryable().Where("id=@id or name like @name ", new { id = 1, name = "%jack%" }).ToList(); + + + + /*** By dynamic***/ + + //id=1 + var conModels = new List(); + conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" , FieldValueConvertFunc=it=>Convert.ToInt32(it) });//id=1 + var student = db.Queryable().Where(conModels).ToList(); + + //Complex use case + List Order = new List(); + conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1", FieldValueConvertFunc = it => Convert.ToInt32(it) });//id=1 + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Like, FieldValue = "1", FieldValueConvertFunc = it => Convert.ToInt32(it) });// id like '%1%' + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNullOrEmpty }); + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.In, FieldValue = "1,2,3" }); + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NotIn, FieldValue = "1,2,3" }); + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.NoEqual, FieldValue = "1,2,3" }); + //conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.IsNot, FieldValue = null });// id is not null + + conModels.Add(new ConditionalCollections() + { + ConditionalList = new List>()// (id=1 or id=2 and id=1) + { + //new KeyValuePair( WhereType.And ,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" }), + new KeyValuePair (WhereType.Or,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" , FieldValueConvertFunc = it => Convert.ToInt32(it) }), + new KeyValuePair ( WhereType.And,new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" ,FieldValueConvertFunc = it => Convert.ToInt32(it)}) + } + }); + var list6 = db.Queryable().Where(conModels).ToList(); + + /*** Conditional builder ***/ + + // use whereif + string name = ""; + int id = 1; + var query = db.Queryable() + .WhereIF(!string.IsNullOrEmpty(name), it => it.Name.Contains(name)) + .WhereIF(id > 0, it => it.Id == id).ToList(); + //clone new Queryable + var query2 = db.Queryable().Where(it => it.Id == 1); + var list7 = query2.Clone().Where(it => it.Name == "jack").ToList();//id=1 and name = jack + var list8 = query2.Clone().Where(it => it.Name == "tom").ToList();//id=1 and name = tom + + Console.WriteLine("#### Condition Screening End ####"); + + + + } + + private static void Async() + { + Console.WriteLine(""); + Console.WriteLine("#### Async Start ####"); + + SqlSugarClient db = GetInstance(); + var task1 = db.Queryable().FirstAsync(); + task1.Wait(); + var task2 = db.Queryable().Where(it => it.Id == 1).ToListAsync(); + + + task2.Wait(); + + Console.WriteLine("#### Async End ####"); + } + + private static SqlSugarClient GetInstance() + { + return new SqlSugarClient(new ConnectionConfig() + { + DbType = SqlSugar.DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo2_Updateable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo2_Updateable.cs new file mode 100644 index 000000000..dec1fc5ad --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo2_Updateable.cs @@ -0,0 +1,107 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo2_Updateable + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Updateable Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + + + /*** 1.entity or List ***/ + + var updateObj = new Order() { Id = 1, Name = "order1" }; + var updateObjs = new List { + new Order() { Id = 11, Name = "order11" }, + new Order() { Id = 12, Name = "order12" } + }; + + //update all columns by primary key + var result = db.Updateable(updateObj).ExecuteCommand();//update single + var result2 = db.Updateable(updateObjs).ExecuteCommand();//update List + + //Ignore Name and Price + var result3 = db.Updateable(updateObj).IgnoreColumns(it => new { it.CreateTime, it.Price }).ExecuteCommand(); + + //only update Name and CreateTime + var result4 = db.Updateable(updateObj).UpdateColumns(it => new { it.Name, it.CreateTime }).ExecuteCommand(); + + //If there is no primary key + var result5 = db.Updateable(updateObj).WhereColumns(it => new { it.Id }).ExecuteCommand();//update single by id + var result6 = db.Updateable(updateObjs).WhereColumns(it => new { it.Id }).ExecuteCommand();//update List by id + + + + + /*** 2.by expression ***/ + + //update name,createtime + var result7 = db.Updateable(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand(); + var result71 = db.Updateable().SetColumns(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand(); + //only update name + var result8 = db.Updateable(it => it.Name == "Name").Where(it => it.Id == 1).ExecuteCommand(); + var result81 = db.Updateable().SetColumns(it => it.Name == "Name" ).Where(it => it.Id == 1).ExecuteCommand(); + // + + + + + /*** 3.by Dictionary ***/ + var dt = new Dictionary(); + dt.Add("id", 1); + dt.Add("name", "abc"); + dt.Add("createTime", DateTime.Now); + var dtList = new List>(); + dtList.Add(dt); + + var t66 = db.Updateable(dt).AS("order").WhereColumns("id").ExecuteCommand(); + var t666 = db.Updateable(dtList).AS("order").WhereColumns("id").ExecuteCommand(); + + + + /*** 4.Other instructions ***/ + + var caseValue = "1"; + //Do not update NULL columns + db.Updateable(updateObj).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand(); + + //if 1 update name else if 2 update name,createtime + db.Updateable(updateObj) + .UpdateColumnsIF(caseValue == "1", it => new { it.Name }) + .UpdateColumnsIF(caseValue == "2", it => new { it.Name, it.CreateTime }) + .ExecuteCommand(); + //Use Lock + db.Updateable(updateObj).With(SqlWith.UpdLock).ExecuteCommand(); + + //Where Sql + db.Updateable(updateObj).Where("id=@x", new { x = 1 }).ExecuteCommand(); + + Console.WriteLine("#### Updateable End ####"); + } + + } +} \ No newline at end of file diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo3_Insertable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo3_Insertable.cs new file mode 100644 index 000000000..665a51202 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo3_Insertable.cs @@ -0,0 +1,56 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo3_Insertable + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Insertable Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + var insertObj = new Order() { Id = 1, Name = "order1",Price=0 }; + var updateObjs = new List { + new Order() { Id = 11, Name = "order11", Price=0 }, + new Order() { Id = 12, Name = "order12" , Price=0} + }; + + //Ignore CreateTime + db.Insertable(insertObj).IgnoreColumns(it => new { it.CreateTime }).ExecuteReturnIdentity();//get identity + db.Insertable(insertObj).IgnoreColumns("CreateTime").ExecuteReturnIdentity(); + + //Only insert Name and Price + db.Insertable(insertObj).InsertColumns(it => new { it.Name, it.Price }).ExecuteReturnIdentity(); + db.Insertable(insertObj).InsertColumns("Name", "Price").ExecuteReturnIdentity(); + + //ignore null columns + db.Insertable(updateObjs).ExecuteCommand();//get change row count + + //Use Lock + db.Insertable(insertObj).With(SqlWith.UpdLock).ExecuteCommand(); + + Console.WriteLine("#### Insertable End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo4_Deleteable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo4_Deleteable.cs new file mode 100644 index 000000000..676919e46 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo4_Deleteable.cs @@ -0,0 +1,48 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo4_Deleteable + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Deleteable Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + //by entity + db.Deleteable().Where(new Order() { Id = 1111 }).ExecuteCommand(); + + //by primary key + db.Deleteable().In(1111).ExecuteCommand(); + + //by primary key array + db.Deleteable().In(new int[] { 1111, 2222 }).ExecuteCommand(); + + //by expression + db.Deleteable().Where(it => it.Id == 11111).ExecuteCommand(); + + Console.WriteLine("#### Deleteable End ####"); + + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo5_SqlQueryable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo5_SqlQueryable.cs new file mode 100644 index 000000000..fb9791aa1 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo5_SqlQueryable.cs @@ -0,0 +1,37 @@ + +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo5_SqlQueryable + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### SqlQueryable Start ####"); + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true + }); + + int total = 0; + var list = db.SqlQueryable("select * from \"ORDER\"").ToPageList(1, 2, ref total); + + + //by expression + var list2 = db.SqlQueryable("select * from \"ORDER\"").Where(it => it.Id == 1).ToPageList(1, 2); + //by sql + var list3 = db.SqlQueryable("select * from \"ORDER\"").Where("id=@id", new { id = 1 }).ToPageList(1, 2); + + Console.WriteLine("#### SqlQueryable End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo6_Queue.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo6_Queue.cs new file mode 100644 index 000000000..2f91097a1 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo6_Queue.cs @@ -0,0 +1,52 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo6_Queue + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Queue Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + db.Insertable(new Order() { Name = "a" }).AddQueue(); + db.Insertable(new Order() { Name = "b" }).AddQueue(); + db.SaveQueues(); + + + db.Insertable(new Order() { Name = "a" }).AddQueue(); + db.Insertable(new Order() { Name = "b" }).AddQueue(); + db.Insertable(new Order() { Name = "c" }).AddQueue(); + db.Insertable(new Order() { Name = "d" }).AddQueue(); + var ar = db.SaveQueuesAsync(); + ar.Wait(); + + db.Queryable().AddQueue(); + db.Queryable().AddQueue(); + db.AddQueue("select * from `order` where id=@id", new { id = 10000 }); + /* var result2 = db.SaveQueues()*/; + + Console.WriteLine("#### Queue End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo7_Ado.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo7_Ado.cs new file mode 100644 index 000000000..d443890e3 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo7_Ado.cs @@ -0,0 +1,57 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo7_Ado + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Ado Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + //sql + var dt = db.Ado.GetDataTable("select * from \"ORDER\" where @id>0 or name=@name", new List(){ + new SugarParameter("@id",1), + new SugarParameter("@name","2") + }); + + //sql + var dt2 = db.Ado.GetDataTable("select * from \"ORDER\" where @id>0 or name=@name", new { id = 1, name = "2" }); + + //Stored Procedure + //var dt3 = db.Ado.UseStoredProcedure().GetDataTable("sp_school", new { name = "张三", age = 0 }); + //var nameP = new SugarParameter("@name", "张三"); + //var ageP = new SugarParameter("@age", null, true);//isOutput=true + //var dt4 = db.Ado.UseStoredProcedure().GetDataTable("sp_school", nameP, ageP); + + + + //There are many methods to under db.ado + var list= db.Ado.SqlQuery("select * from \"ORDER\" "); + var intValue=db.Ado.SqlQuerySingle("select 1"); + db.Ado.ExecuteCommand("delete from \"ORDER\" where id>1000"); + //db.Ado.xxx + Console.WriteLine("#### Ado End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo8_Saveable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo8_Saveable.cs new file mode 100644 index 000000000..eac041ca1 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo8_Saveable.cs @@ -0,0 +1,48 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo8_Saveable + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Saveable Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + + //insert or update + db.Saveable(new Order() { Id=1, Name="jack" }).ExecuteReturnEntity(); + + + //insert or update + db.Saveable(new Order() { Id = 1000, Name = "jack", CreateTime=DateTime.Now }) + .InsertColumns(it => new { it.Name,it.CreateTime, it.Price})//if insert into name,CreateTime,Price + .UpdateColumns(it => new { it.Name, it.CreateTime })//if update set name CreateTime + .ExecuteReturnEntity(); + + Console.WriteLine(""); + Console.WriteLine("#### Saveable End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo9_EntityMain.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo9_EntityMain.cs new file mode 100644 index 000000000..fb96f70ba --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Demo9_EntityMain.cs @@ -0,0 +1,46 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Demo9_EntityMain + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### EntityMain Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + var entityInfo = db.EntityMaintenance.GetEntityInfo(); + foreach (var column in entityInfo.Columns) + { + Console.WriteLine(column.DbColumnName); + } + + var dbColumnsName = db.EntityMaintenance.GetDbColumnName("Name"); + + var dbTableName = db.EntityMaintenance.GetTableName(); + + //more https://github.com/sunkaixuan/SqlSugar/wiki/9.EntityMain + Console.WriteLine("#### EntityMain End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoA_DbMain.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoA_DbMain.cs new file mode 100644 index 000000000..40ebc9e4c --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoA_DbMain.cs @@ -0,0 +1,42 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class DemoA_DbMain + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### DbMain Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + var tables = db.DbMaintenance.GetTableInfoList(); + foreach (var table in tables) + { + Console.WriteLine(table.Description); + } + //more https://github.com/sunkaixuan/SqlSugar/wiki/a.DbMain + Console.WriteLine("#### DbMain End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoB_Aop.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoB_Aop.cs new file mode 100644 index 000000000..b13a1ec02 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoB_Aop.cs @@ -0,0 +1,68 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class DemoB_Aop + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Aop Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true + }); + db.Aop.OnLogExecuted = (sql, pars) => //SQL executed event + { + Console.WriteLine("OnLogExecuted"+sql); + }; + db.Aop.OnLogExecuting = (sql, pars) => //SQL executing event (pre-execution) + { + Console.WriteLine("OnLogExecuting" + sql); + }; + db.Aop.OnError = (exp) =>//SQL execution error event + { + //exp.sql + }; + db.Aop.OnExecutingChangeSql = (sql, pars) => //SQL executing event (pre-execution,SQL script can be modified) + { + return new KeyValuePair(sql, pars); + }; + db.Aop.OnDiffLogEvent = it =>//Get data changes + { + var editBeforeData = it.BeforeData; + var editAfterData = it.AfterData; + var sql = it.Sql; + var parameter = it.Parameters; + var businessData = it.BusinessData; + var time = it.Time; + var diffType = it.DiffType;//enum insert 、update and delete + Console.WriteLine(businessData); + Console.WriteLine(editBeforeData[0].Columns[1].Value); + Console.WriteLine("to"); + Console.WriteLine(editAfterData[0].Columns[1].Value); + //Write logic + }; + + + db.Queryable().ToList(); + db.Queryable().ToList(); + + //OnDiffLogEvent + var data = db.Queryable().First(); + data.Name = "changeName"; + db.Updateable(data).EnableDiffLogEvent("--update Order--").ExecuteCommand(); + + Console.WriteLine("#### Aop End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoD_DbFirst.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoD_DbFirst.cs new file mode 100644 index 000000000..c2d44df30 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoD_DbFirst.cs @@ -0,0 +1,75 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + public class DemoD_DbFirst + { + public static void Init() + { + Console.WriteLine(); + Console.WriteLine("#### DbFirst Start ####"); + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true + }); + + db.DbFirst.CreateClassFile("c:\\Demo\\1", "Models"); + + + db.DbFirst.Where("Student").CreateClassFile("c:\\Demo\\2", "Models"); + + + db.DbFirst.Where(it => it.ToLower().StartsWith("view")).CreateClassFile("c:\\Demo\\3", "Models"); + + + db.DbFirst.Where(it => it.ToLower().StartsWith("view")).CreateClassFile("c:\\Demo\\4", "Models"); + + + db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\5", "Models"); + + + db.DbFirst.IsCreateDefaultValue().CreateClassFile("c:\\Demo\\6", "Demo.Models"); + + + db.DbFirst. SettingClassTemplate(old => { return old;}) + .SettingNamespaceTemplate(old =>{ return old;}) + .SettingPropertyDescriptionTemplate(old => + { + return @" /// + /// Desc_New:{PropertyDescription} + /// Default_New:{DefaultValue} + /// Nullable_New:{IsNullable} + /// "; + }) + .SettingPropertyTemplate(old =>{return old;}) + .SettingConstructorTemplate(old =>{return old; }) + .CreateClassFile("c:\\Demo\\7"); + + + + foreach (var item in db.DbMaintenance.GetTableInfoList()) + { + string entityName = item.Name.ToUpper();/*Format class name*/ + db.MappingTables.Add(entityName , item.Name); + foreach (var col in db.DbMaintenance.GetColumnInfosByTableName(item.Name)) + { + db.MappingColumns.Add(col.DbColumnName.ToUpper() /*Format class property name*/, col.DbColumnName, entityName); + } + } + db.DbFirst.IsCreateAttribute().CreateClassFile("c:\\Demo\\8", "Models"); + + + //Use Razor Template + //db.DbFirst.UseRazorAnalysis(RazorFirst.DefaultRazorClassTemplate).CreateClassFile(""); + + Console.WriteLine("#### DbFirst End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoE_CodeFirst.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoE_CodeFirst.cs new file mode 100644 index 000000000..e2274c353 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/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.Kdbndp, + ConnectionString = Config.ConnectionString3, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true + }); + db.DbMaintenance.CreateDatabase(); + db.CodeFirst.InitTables(typeof(CodeFirstTable1));//Create CodeFirstTable1 + db.Insertable(new CodeFirstTable1() { Name = "a", Text="a" }).ExecuteCommand(); + var list = db.Queryable().ToList(); + Console.WriteLine("#### CodeFirst end ####"); + } + } + + public class CodeFirstTable1 + { + [SugarColumn(IsIdentity = true, IsPrimaryKey = true)] + public int Id { get; set; } + public string Name { get; set; } + [SugarColumn(ColumnDataType = "varchar(255)")]//custom + public string Text { get; set; } + [SugarColumn(IsNullable = true)] + public DateTime CreateTime { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoF_Utilities.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoF_Utilities.cs new file mode 100644 index 000000000..c7851c805 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoF_Utilities.cs @@ -0,0 +1,46 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class DemoF_Utilities + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Utilities Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + + List ids = Enumerable.Range(1, 100).ToList(); + db.Utilities.PageEach(ids, 10, list => + { + Console.WriteLine(string.Join("," ,list)); + }); + + var list2= db.Utilities.DataTableToList(db.Ado.GetDataTable("select * from \"ORDER\"")); + + //more https://github.com/sunkaixuan/SqlSugar/wiki/f.Utilities + Console.WriteLine("#### Utilities End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoG_SimpleClient.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoG_SimpleClient.cs new file mode 100644 index 000000000..fa8ba05d5 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/DemoG_SimpleClient.cs @@ -0,0 +1,36 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class DemoG_SimpleClient + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### SimpleClient Start ####"); + + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + Console.WriteLine("#### SimpleClient End ####"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Democ_GobalFilter.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Democ_GobalFilter.cs new file mode 100644 index 000000000..cdec7892b --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Demo/Democ_GobalFilter.cs @@ -0,0 +1,77 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + public class DemoC_GobalFilter + { + public static void Init() + { + Console.WriteLine(""); + Console.WriteLine("#### Filter Start ####"); + var db = GetInstance(); + + + var sql = db.Queryable().ToSql(); + //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE isDelete=0 + Console.WriteLine(sql); + + + var sql2 = db.Queryable((main,ot)=> main.Id==ot.OrderId).ToSql(); + //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` main ,[OrderDetail] ot WHERE ( [main].[Id] = [ot].[OrderId] ) AND main.isDelete=0 + Console.WriteLine(sql2); + + + var sql3 = db.Queryable().Filter("Myfilter").ToSql();// Myfilter+Gobal + //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE Name='jack' AND isDelete=0 + Console.WriteLine(sql3); + + var sql4 = db.Queryable().Filter("Myfilter",isDisabledGobalFilter:true).ToSql();//only Myfilter + //SELECT [Id],[Name],[Price],[CreateTime] FROM `order` WHERE Name='jack' + Console.WriteLine(sql4); + Console.WriteLine("#### Filter End ####"); + } + + + public static SqlSugarClient GetInstance() + { + SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() { DbType = DbType.Kdbndp, ConnectionString = Config.ConnectionString, IsAutoCloseConnection = true }); + + //single table query gobal filter + db.QueryFilter.Add(new SqlFilterItem() + { + FilterValue = filterDb => + { + //Writable logic + return new SqlFilterResult() { Sql = " isDelete=0" };//Global string perform best + } + }); + + //Multi-table query gobal filter + db.QueryFilter.Add(new SqlFilterItem() + { + FilterValue = filterDb => + { + //Writable logic + return new SqlFilterResult() { Sql = " main.isDelete=0" }; + }, + IsJoinQuery=true + }); + + //Specific filters + db.QueryFilter.Add(new SqlFilterItem() + { + FilterName= "Myfilter", + FilterValue = filterDb => + { + //Writable logic + return new SqlFilterResult() { Sql = "Name='jack'" }; + } + }); + return db; + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/KdbndpTest.csproj b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/KdbndpTest.csproj new file mode 100644 index 000000000..84394ea2e --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/KdbndpTest.csproj @@ -0,0 +1,12 @@ + + + + Exe + netcoreapp3.1 + + + + + + + diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/AttributeTable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/AttributeTable.cs new file mode 100644 index 000000000..c1a43ad12 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/AttributeTable.cs @@ -0,0 +1,20 @@ +using System; +using System.Collections.Generic; +using System.ComponentModel.DataAnnotations; +using System.ComponentModel.DataAnnotations.Schema; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + [Table("MyAttributeTable")] + //[SugarTable("CustomAttributeTable")] + public class AttributeTable + { + + [Key] + //[SugarColumn(IsPrimaryKey =true)] + public string Id { get; set; } + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/CarType.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/CarType.cs new file mode 100644 index 000000000..00dc12710 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/CarType.cs @@ -0,0 +1,7 @@ +namespace OrmTest +{ + public class CarType + { + public bool State { get; set; } + } +} \ No newline at end of file diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Custom.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Custom.cs new file mode 100644 index 000000000..3b8871c57 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Custom.cs @@ -0,0 +1,14 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Custom + { + public int Id { get; set; } + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/EntityMapper.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/EntityMapper.cs new file mode 100644 index 000000000..b597012fb --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/EntityMapper.cs @@ -0,0 +1,15 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using SqlSugar; +namespace OrmTest +{ + [SugarTable("MyEntityMapper")] + public class EntityMapper + { + [SugarColumn(ColumnName ="MyName")] + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Mapper.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Mapper.cs new file mode 100644 index 000000000..8d7991d6c --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Mapper.cs @@ -0,0 +1,54 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + [SugarTable("OrderDetail")] + public class OrderItemInfo + { + [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int ItemId { get; set; } + public int OrderId { get; set; } + public decimal? Price { get; set; } + [SqlSugar.SugarColumn(IsNullable = true)] + public DateTime? CreateTime { get; set; } + [SugarColumn(IsIgnore = true)] + public Order Order { get; set; } + } + [SugarTable("Order")] + public class OrderInfo + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + public string Name { get; set; } + [SugarColumn(IsIgnore = true)] + public List Items { get; set; } + } + public class ABMapping + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int AId { get; set; } + public int BId { get; set; } + [SugarColumn(IsIgnore = true)] + public A A { get; set; } + [SugarColumn(IsIgnore = true)] + public B B { get; set; } + + } + public class A + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + public string Name { get; set; } + } + public class B + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/MyCustomAttributeTable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/MyCustomAttributeTable.cs new file mode 100644 index 000000000..11359d062 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/MyCustomAttributeTable.cs @@ -0,0 +1,20 @@ +using System; +using System.Collections.Generic; +using System.ComponentModel.DataAnnotations; +using System.ComponentModel.DataAnnotations.Schema; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + [Table("CustomAttributeTable")] + //[SugarTable("CustomAttributeTable")] + public class MyCustomAttributeTable + { + + [Key] + //[SugarColumn(IsPrimaryKey =true)] + public string Id { get; set; } + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Order.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Order.cs new file mode 100644 index 000000000..d7ff068b8 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Order.cs @@ -0,0 +1,24 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + + public class Order + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + + public string Name { get; set; } + public decimal Price { get; set; } + [SugarColumn(IsNullable = true)] + public DateTime CreateTime { get; set; } + [SugarColumn(IsNullable =true)] + public int CustomId { get; set; } + [SugarColumn(IsIgnore = true)] + public List Items { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/OrderItem.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/OrderItem.cs new file mode 100644 index 000000000..ae3262c7c --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/OrderItem.cs @@ -0,0 +1,18 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + [SqlSugar.SugarTable("OrderDetail")] + public class OrderItem + { + [SqlSugar.SugarColumn(IsPrimaryKey =true, IsIdentity =true)] + public int ItemId { get; set; } + public int OrderId { get; set; } + public decimal? Price { get; set; } + [SqlSugar.SugarColumn(IsNullable = true)] + public DateTime? CreateTime { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/TestTree.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/TestTree.cs new file mode 100644 index 000000000..b8250828a --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/TestTree.cs @@ -0,0 +1,17 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class TestTree + { + [SqlSugar.SugarColumn(ColumnDataType = "hierarchyid")] + public string TreeId { get; set; } + [SqlSugar.SugarColumn(ColumnDataType = "Geography")] + public string GId { get; set; } + public string Name { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Tree.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Tree.cs new file mode 100644 index 000000000..d2878de64 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/Tree.cs @@ -0,0 +1,20 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class Tree + { + [SqlSugar.SugarColumn(IsPrimaryKey =true)] + public int Id { get; set; } + public string Name { get; set; } + public int ParentId { get; set; } + [SqlSugar.SugarColumn(IsIgnore = true)] + public Tree Parent { get; set; } + [SqlSugar.SugarColumn(IsIgnore = true)] + public List Child { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/ViewOrder.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/ViewOrder.cs new file mode 100644 index 000000000..fcd465747 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Models/ViewOrder.cs @@ -0,0 +1,13 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class ViewOrder:Order + { + public string CustomName { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Program.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Program.cs new file mode 100644 index 000000000..72832d0a2 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/Program.cs @@ -0,0 +1,40 @@ +using System; + +namespace OrmTest +{ + class Program + { + static void Main(string[] args) + { + //Demo + Demo0_SqlSugarClient.Init(); + Demo1_Queryable.Init(); + Demo2_Updateable.Init(); + Demo3_Insertable.Init(); + Demo4_Deleteable.Init(); + Demo5_SqlQueryable.Init(); + Demo6_Queue.Init(); + Demo7_Ado.Init(); + Demo8_Saveable.Init(); + Demo9_EntityMain.Init(); + DemoA_DbMain.Init(); + DemoB_Aop.Init(); + DemoC_GobalFilter.Init(); + DemoD_DbFirst.Init(); ; + DemoE_CodeFirst.Init(); + DemoF_Utilities.Init(); + DemoG_SimpleClient.Init(); + + //Unit test + //NewUnitTest.Init(); + + //Rest Data + NewUnitTest.RestData(); + + Console.WriteLine("all successfully."); + Console.ReadKey(); + } + + + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Main.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Main.cs new file mode 100644 index 000000000..d6172c8a9 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Main.cs @@ -0,0 +1,45 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace OrmTest +{ + public partial class NewUnitTest + { + public static SqlSugarClient Db=> new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + + public static void RestData() + { + Db.DbMaintenance.TruncateTable(); + Db.DbMaintenance.TruncateTable(); + } + public static void Init() + { + CodeFirst(); + Updateable(); + Json(); + Ado(); + Queryable(); + QueryableAsync(); + Thread(); + Thread2(); + Thread3(); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UAdo.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UAdo.cs new file mode 100644 index 000000000..49788f35a --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UAdo.cs @@ -0,0 +1,57 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + public static void Ado() + { + + var task1 = Db.Ado.GetScalarAsync("select 1"); + task1.Wait(); + UValidate.Check(1, task1.Result, "ado"); + + var task2 = Db.Ado.GetIntAsync("select 2"); + task2.Wait(); + UValidate.Check(2, task2.Result, "ado"); + + + var task3 = Db.Ado.GetLongAsync("select 3"); + task3.Wait(); + UValidate.Check(3, task3.Result, "ado"); + + + var task4 = Db.Ado.GetDataTableAsync("select 4 as id"); + task4.Wait(); + UValidate.Check(4, task4.Result.Rows[0]["id"], "ado"); + + + var task5 = Db.Ado.GetInt("select @id as id",new { id=5}); + UValidate.Check(5, task5, "ado"); + + + + var task6 = Db.Ado.SqlQuery("select @id as id", new { id = 5 }); + UValidate.Check(5, task6[0].id, "ado"); + + + var task7 = Db.Ado.SqlQueryAsync("select @id as id", new { id = 7 }); + task7.Wait(); + UValidate.Check(7, task7.Result[0].id, "ado"); + + + var task8 = Db.Ado.SqlQueryAsync("select 8 as id"); + task8.Wait(); + UValidate.Check(8, task8.Result[0].id, "ado"); + + var task9=Db.Ado.SqlQuery(@"select * from ""order"";select * from OrderDetail"); + + var task10 = Db.Ado.SqlQueryAsync(@"select * from ""order"";select * from OrderDetail"); + task10.Wait(); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UCodeFirst.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UCodeFirst.cs new file mode 100644 index 000000000..099832be8 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UCodeFirst.cs @@ -0,0 +1,25 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + public static void CodeFirst() + { + if (Db.DbMaintenance.IsAnyTable("UnitCodeTest1", false)) + Db.DbMaintenance.DropTable("UnitCodeTest1"); + Db.CodeFirst.InitTables(); + } + public class UnitCodeTest1 + { + [SqlSugar.SugarColumn(IndexGroupNameList = new string[] { "group1" })] + public int Id { get; set; } + [SqlSugar.SugarColumn(DefaultValue= "now()", IndexGroupNameList =new string[] {"group1" } )] + public DateTime? CreateDate { get; set; } + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UJson.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UJson.cs new file mode 100644 index 000000000..a7fd05df8 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UJson.cs @@ -0,0 +1,34 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + + public static void Json() + { + Db.CodeFirst.InitTables(); + Db.DbMaintenance.TruncateTable(); + Db.Insertable(new UnitJsonTest() { Order = new Order { Id = 1, Name = "order1" } }).ExecuteCommand(); + var list = Db.Queryable().ToList(); + UValidate.Check("order1", list.First().Order.Name, "Json"); + Db.Updateable(new UnitJsonTest() { Id = Db.Queryable().First().Id, Order = new Order { Id = 2, Name = "order2" } }).ExecuteCommand(); + list= Db.Queryable().ToList(); + UValidate.Check("order2", list.First().Order.Name, "Json"); + var list2 = Db.Queryable().ToList(); + } + } + + + public class UnitJsonTest + { + [SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int Id { get; set; } + [SqlSugar.SugarColumn(ColumnDataType = "varchar(4000)", IsJson = true)] + public Order Order { get; set; } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryable.cs new file mode 100644 index 000000000..9fdc0766d --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryable.cs @@ -0,0 +1,323 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + public static void Queryable() + { + + var pageindex = 1; + var pagesize = 10; + var total = 0; + var totalPage = 0; + var list = Db.Queryable().ToPageList(pageindex, pagesize, ref total, ref totalPage); + + //Db.CodeFirst.InitTables(typeof(CarType)); + //Db.Updateable() + // .SetColumns(it => new CarType { State = SqlSugar.SqlFunc.IIF(it.State == true, false, true) }).Where(it => true) + // .ExecuteCommand(); + + //Db.CodeFirst.InitTables(typeof(TestTree)); + //Db.DbMaintenance.TruncateTable(); + //Db.Ado.ExecuteCommand("insert testtree values(hierarchyid::GetRoot(),geography :: STGeomFromText ('POINT(55.9271035250276 -3.29431266523898)',4326),'name')"); + //var list2 = Db.Queryable().ToList(); + + Db.CodeFirst.InitTables(); + Db.Queryable().Where(it => it.Id.HasValue).ToList(); + + Db.Queryable().Where(it => SqlSugar.SqlFunc.Equals(it.CreateTime.Date, it.CreateTime.Date)).ToList(); + + var sql = Db.Queryable().Select(it => new UnitSelectTest() + { + + DcNull = it.Dc, + Dc = it.Int + }).ToSql().Key; + UValidate.Check(sql, "SELECT \"dc\" AS \"dcnull\" , \"int\" AS \"dc\" FROM \"unitselecttest\"", "Queryable"); + + sql = Db.Updateable(new UnitSelectTest2()).ToSql().Key; + UValidate.Check(sql, @"UPDATE ""unitselecttest2"" SET + ""dc""=@Dc,""intnull""=@IntNull WHERE ""int""=@Int", "Queryable"); + + sql = Db.Queryable().IgnoreColumns(it => it.CreateTime).ToSql().Key; + UValidate.Check(sql, "SELECT \"id\",\"name\",\"price\",\"customid\" FROM \"order\" ", "Queryable"); + sql = Db.Queryable().IgnoreColumns(it => new { it.Id, it.Name }).ToSql().Key; + UValidate.Check(sql, "SELECT \"price\",\"createtime\",\"customid\" FROM \"order\" ", "Queryable"); + sql = Db.Queryable().IgnoreColumns("id").ToSql().Key; + UValidate.Check(sql, "SELECT \"name\",\"price\",\"createtime\",\"customid\" FROM \"order\" ", "Queryable"); + + var cts = IEnumerbleContains.Data(); + var list2=Db.Queryable() + .Where(p => /*ids.*/cts.Select(c => c.Id).Contains(p.Id)).ToList(); + + var cts2 = IEnumerbleContains.Data().ToList(); ; + var list3 = Db.Queryable() + .Where(p => /*ids.*/cts2.Select(c => c.Id).Contains(p.Id)).ToList(); + + + var list4 = Db.Queryable() + .Where(p => new List { 1, 2, 3 }.Where(b => b > 1).Contains(p.Id)).ToList(); + + Db.CodeFirst.InitTables(); + var list5 = Db.Queryable().Where(it => SqlSugar.SqlFunc.ToString(it.Date.Value.Year) == "1").ToList(); + var list6 = Db.Queryable().Where(it => it.Date.Value.Year == 1).ToList(); + var list7 = Db.Queryable().Where(it => it.Date.Value.Date == DateTime.Now.Date).ToList(); + + + SaleOrder saleOrderInfo = new SaleOrder(); + Db.CodeFirst.InitTables(); + var result = Db.GetSimpleClient().Update(o => new SaleOrder() + { + OrderStatus = 1, + CheckMan = saleOrderInfo.CheckMan, + CheckTime = DateTime.Now + }, o => o.OrderSn == saleOrderInfo.OrderSn && o.OrderStatus != 1); + } + + public static class IEnumerbleContains + { + public static IEnumerable Data() + { + for (int i = 0; i < 100; i++) + { + yield return new Order + { + Id = i, + }; + } + } + } + [SugarTable("UnitSaleOrder")] + public class SaleOrder + { + public SaleOrder() + { + SaleDate = DateTime.Now; + Team = 1; + AddTime = DateTime.Now; + OrderStatus = 0; + Points = 0; + PayPoints = 0; + PointsExchangeMoney = decimal.Zero; + IsPushMessage = false; + CostAmount = decimal.Zero; + OrderAmount = decimal.Zero; + RealOrderAmount = decimal.Zero; + AccountsDueAmount = decimal.Zero; + SettleType = 0; + IsPushMessage = false; + } + + /// + /// 订单号 + /// + public string OrderSn { get; set; } + + /// + /// 客户编号 + /// + public string CustomerNo { get; set; } + + + /// + /// 收货人姓名 + /// + public string CustomerName { get; set; } + + /// + /// 成本总金额 + /// + public decimal CostAmount { get; set; } + + /// + /// 订单总金额 + /// + public decimal OrderAmount { get; set; } + + /// + /// 实收金额（整单优惠后） + /// + public decimal RealOrderAmount { get; set; } + + /// + /// 销货日期 + /// + public DateTime SaleDate { get; set; } + + /// + /// 下单时间 + /// + public DateTime AddTime { get; set; } + + /// + /// 媒体资源投放ID + /// + public string IndustryCode { get; set; } + + public string IndustryName { get; set; } + + /// + /// 备注 + /// + public string Remark { get; set; } + + /// + /// 班组 + /// + public int Team { get; set; } + + /// + /// 销售员编号 + /// + public string SellerNo { get; set; } + + /// + /// 销售员姓名 + /// + public string SellerName { get; set; } + + /// + /// 操作人ID + /// + public virtual string HandlerCode { get; set; } + + /// + /// 操作者 + /// + public string Handler { get; set; } + + /// + /// 发货仓库代号 + /// + public string StoreCode { get; set; } + + /// + /// 发货仓库名称 + /// + public string StoreName { get; set; } + + /// + /// 销货店铺渠道代号 + /// + public string ShopChannelCode { get; set; } + + /// + /// 销货店铺渠道名称 + /// + public string ShopChannelName { get; set; } + + /// + /// 订单产品数 + /// + public int GoodsNum { get; set; } + + /// + /// 礼品数量 + /// + public int GiftNum { get; set; } + + /// + /// 对应预订单号 + /// + public string CustomerOrderSn { get; set; } + + /// + /// 订单赠送积分 + /// + public int Points { get; set; } + + /// + /// 应收款金额 + /// + public decimal AccountsDueAmount { get; set; } + + /// + /// 来自预约单号 + /// + public string ReserationOrderSn { get; set; } + + + /// + /// 订单状态 0为未审核 1为已审核 + /// + public int OrderStatus { get; set; } + + /// + /// 审核人 + /// + public string CheckMan { get; set; } + + /// + /// 审核时间 + /// + public DateTime? CheckTime { get; set; } + + /// + /// 结算类型 0为非金工石（零售） 1为金工石 + /// + public int SettleType { get; set; } + + /// + /// 使用积分 + /// + public int PayPoints { get; set; } + + /// + /// 积分抵现金额 + /// + public decimal PointsExchangeMoney { get; set; } + + /// + /// 是否已推送微信消息 + /// + public bool IsPushMessage { get; set; } + + } + + public class SaleOrderBaseInfo + { + public int GoodsNum { get; set; } + + public int GiftNum { get; set; } + + public decimal OrderAmount { get; set; } + + } + + + public class UnitTest3 + { + public DateTime? Date { get; set; } + } + + + public class UnitSelectTest2 + { + [SqlSugar.SugarColumn(IsOnlyIgnoreUpdate = true)] + public decimal? DcNull { get; set; } + public decimal Dc { get; set; } + public int? IntNull { get; set; } + [SqlSugar.SugarColumn(IsPrimaryKey = true)] + public decimal Int { get; set; } + } + + public class UnitSelectTest + { + public decimal? DcNull { get; set; } + public decimal Dc { get; set; } + public int? IntNull { get; set; } + public decimal Int { get; set; } + } + + public class UnitGuidTable + { + public Guid? Id { get; set; } + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryableAsync.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryableAsync.cs new file mode 100644 index 000000000..7ebce71e8 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UQueryableAsync.cs @@ -0,0 +1,43 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using SqlSugar; +namespace OrmTest +{ + public partial class NewUnitTest + { + public static void QueryableAsync() + { + q1(); + q2(); + q3(); + } + + private static void q1() + { + RefAsync total = 0; + var count = Db.Queryable().Count(); + Task t = Db.Queryable().ToPageListAsync(1, 2, total); + t.Wait(); + UValidate.Check(count, total.Value, "QueryableAsync"); + } + private static void q2() + { + RefAsync total = 0; + var count = Db.Queryable().Count(); + Task t = Db.Queryable().ToDataTablePageAsync(1, 2, total); + t.Wait(); + UValidate.Check(count, total.Value, "QueryableAsync"); + } + private static void q3() + { + RefAsync total = 0; + var count = Db.Queryable().Count(); + Task t = Db.Queryable().ToJsonPageAsync(1, 2, total); + t.Wait(); + UValidate.Check(count, total.Value, "QueryableAsync"); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread.cs new file mode 100644 index 000000000..a9b3916d3 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread.cs @@ -0,0 +1,378 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + + public static SqlSugarClient simpleDb => new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + public static SqlSugarClient ssDb => new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + IsShardSameThread = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + public static SqlSugarClient singleDb = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + public static SqlSugarClient singleAndSsDb = new SqlSugarClient(new ConnectionConfig() + { + DbType = DbType.Kdbndp, + ConnectionString = Config.ConnectionString, + InitKeyType = InitKeyType.Attribute, + IsAutoCloseConnection = true, + IsShardSameThread = true, + AopEvents = new AopEvents + { + OnLogExecuting = (sql, p) => + { + Console.WriteLine(sql); + Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value))); + } + } + }); + public static void Thread() + { + Simple(); + IsShardSameThread(); + Single(); + SingleAndIsShardSameThread(); + SimpleAsync(); + IsShardSameThreadAsync(); + SingleAsync(); + SingleAndIsShardSameThreadAsync(); + + } + + private static void Simple() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAndIsShardSameThread() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void Single() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void IsShardSameThread() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommand(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + + + private static void SimpleAsync() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); ; + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAndIsShardSameThreadAsync() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleAndSsDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAsync() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + singleDb.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void IsShardSameThreadAsync() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test2", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + Db.Insertable(new Order() { Name = "test3", CreateTime = DateTime.Now }).ExecuteCommandAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread2.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread2.cs new file mode 100644 index 000000000..5fe4c12dd --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread2.cs @@ -0,0 +1,316 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + + public static void Thread2() + { + Simple2(); + IsShardSameThread2(); + Single2(); + SingleAndIsShardSameThread2(); + SimpleAsync2(); + IsShardSameThreadAsync2(); + SingleAsync2(); + SingleAndIsShardSameThreadAsync2(); + + } + + private static void Simple2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAndIsShardSameThread2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void Single2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void IsShardSameThread2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToList(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + + + private static void SimpleAsync2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); ; + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAndIsShardSameThreadAsync2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void SingleAsync2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + + private static void IsShardSameThreadAsync2() + { + var t1 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(1); + } + + }); + var t2 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(10); + } + + }); + var t3 = new Task(() => + { + for (int i = 0; i < 100; i++) + { + simpleDb.Queryable().Take(10).ToListAsync().Wait(); + System.Threading.Thread.Sleep(6); + } + + }); + t1.Start(); + t2.Start(); + t3.Start(); + + Task.WaitAll(t1, t2, t3); + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread3.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread3.cs new file mode 100644 index 000000000..9e0e644c4 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UThread3.cs @@ -0,0 +1,117 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + + public static void Thread3() + { + Console.WriteLine("Thread3"); + SimpleAsync3().Wait(); + IsShardSameThreadAsync3().Wait(); + SingleAsync3().Wait(); + SingleAndIsShardSameThreadAsync3().Wait(); + + } + + + + private static async Task SimpleAsync3() + { + + for (int i = 0; i < 100; i++) + { + await simpleDb.Queryable().Take(10).ToListAsync(); + } + + for (int i = 0; i < 100; i++) + { + await simpleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync(); + } + + List orders = new List(); + for (int i = 0; i < 100; i++) + { + orders = await simpleDb.Queryable().Take(10).ToListAsync(); + } + if (orders.Count > 0) + { + Console.WriteLine("async is ok"); + } + } + + private static async Task SingleAndIsShardSameThreadAsync3() + { + for (int i = 0; i < 100; i++) + { + await singleAndSsDb.Queryable().Take(10).ToListAsync(); + } + + for (int i = 0; i < 100; i++) + { + await singleAndSsDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync(); + } + List orders = new List(); + for (int i = 0; i < 100; i++) + { + orders = await singleAndSsDb.Queryable().Take(10).ToListAsync(); + } + if (orders.Count > 0) + { + Console.WriteLine("async is ok"); + } + } + + private static async Task SingleAsync3() + { + for (int i = 0; i < 100; i++) + { + await singleDb.Queryable().Take(10).ToListAsync(); + } + + for (int i = 0; i < 100; i++) + { + await singleDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync(); + } + + List orders = new List(); + for (int i = 0; i < 100; i++) + { + orders = await singleDb.Queryable().Take(10).ToListAsync(); + } + if (orders.Count > 0) + { + Console.WriteLine("async is ok"); + } + } + + private static async Task IsShardSameThreadAsync3() + { + for (int i = 0; i < 100; i++) + { + await ssDb.Queryable().Take(10).ToListAsync(); + } + + for (int i = 0; i < 100; i++) + { + await ssDb.Insertable(new Order() { Name = "a", CustomId = 1 }).ExecuteCommandAsync(); + } + + List orders = new List(); + for (int i = 0; i < 100; i++) + { + orders = await ssDb.Queryable().Take(10).ToListAsync(); + } + if (orders.Count > 0) + { + Console.WriteLine("async is ok"); + } + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UValidate.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UValidate.cs new file mode 100644 index 000000000..bc2b97fc2 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/UValidate.cs @@ -0,0 +1,19 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public class UValidate + { + public static void Check(object a, object b, object name) + { + if (a?.ToString()?.Trim() != b?.ToString()?.Trim()) + { + throw new Exception(name + " error"); + } + } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Updateable.cs b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Updateable.cs new file mode 100644 index 000000000..3c2863c90 --- /dev/null +++ b/Src/Asp.NetCore2/SqlSeverTest/KdbndpTest/UnitTest/Updateable.cs @@ -0,0 +1,211 @@ +using SqlSugar; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace OrmTest +{ + public partial class NewUnitTest + { + public static void Updateable() + { + Db.CodeFirst.InitTables(typeof(UnitUser)); + Db.DbMaintenance.TruncateTable(); + Db.Insertable(new UnitUser() { USER_ID=1,USER_ACCOUNT = "a", USER_PWD = "b", USER_NAME = "c", PWD_LASTCHTIME = DateTime.Now, PWD_ERRORCOUNT = 1, PWD_LASTERRTIME = DateTime.Now }).ExecuteCommand(); + Db.Updateable(new UnitUser() { USER_ID=1, PWD_LASTERRTIME = null }).WhereColumns(it=> new{ it.PWD_ERRORCOUNT, it.PWD_LASTERRTIME }).ExecuteCommand(); + Db.CodeFirst.InitTables(typeof(UnitBoolTest)); + var x = new UnitBoolTest(); + //Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = !it.BoolValue }).Where(it=>it.Id==1).ExecuteCommand(); + //Db.Updateable().SetColumns(it => it.BoolValue == !it.BoolValue ).Where(it=>it.Id==1).ExecuteCommand(); + Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = x.BoolValue }).Where(it => it.Id == 1).ExecuteCommand(); + Db.Updateable().SetColumns(it => it.BoolValue == x.BoolValue).Where(it => it.Id == 1).ExecuteCommand(); + Db.Updateable().SetColumns(it => new UnitBoolTest() { BoolValue = !x.BoolValue }).Where(it => it.Id == 1).ExecuteCommand(); + //Db.Updateable().SetColumns(it => it.BoolValue == !x.BoolValue).Where(it => it.Id == 1).ExecuteCommand(); + Db.Updateable(x).ReSetValue(it => it.BoolValue == it.BoolValue).ExecuteCommand(); + Db.Updateable(x).ReSetValue(it => it.BoolValue == true).ExecuteCommand(); + //Db.Updateable(x).ReSetValue(it => it.BoolValue == !it.BoolValue).ExecuteCommand(); + Db.Updateable(x).UpdateColumns(it =>new { it.BoolValue }) .ExecuteCommand(); + + + + UnitSaveDiary saveDiary = new UnitSaveDiary(); + saveDiary.ID = 2; + saveDiary.TypeID = 10; + saveDiary.TypeName = "类型100"; + saveDiary.Title = "标题1000"; + saveDiary.Content = "内容"; + saveDiary.Time = DateTime.Now; + saveDiary.IsRemind = false;//无论传false/true 最终执行的结果都是以true执行的 + + var sql = Db.Updateable().SetColumns(it => new UnitDiary() + { + IsRemind = saveDiary.IsRemind, + }).Where(it => it.ID == saveDiary.ID).ToSql(); + UValidate.Check(sql.Key, @"UPDATE ""diary"" SET + ""isremind"" = @Const0 WHERE ( ""id"" = @ID1 )", "Updateable"); + + + sql = Db.Updateable().SetColumns(it => new UnitDiary() + { + TypeID = saveDiary.TypeID, + }).Where(it => it.ID == saveDiary.ID).ToSql(); + UValidate.Check(sql.Key, @"UPDATE ""diary"" SET + ""typeid"" = @Const0 WHERE ( ""id"" = @ID1 )", "Updateable"); + + } + } + public class UnitSaveDiary + { + public int ID { get; set; } + public int TypeID { get; set; } + public string TypeName { get; set; } + public string Title { get; set; } + public string Content { get; set; } + public DateTime? Time { get; set; } + public bool IsRemind { get; set; } + } + /// + /// 日记表 + /// + [SugarTable("Diary")] + public class UnitDiary + { + [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] + public int ID { get; set; } + /// + /// 用户ID + /// + public int? UserID { get; set; } + /// + /// 日记类型ID + /// + public int? TypeID { get; set; } + /// + /// 日记类型名称 + /// + public string TypeName { get; set; } + /// + /// 标题 + /// + public string Title { get; set; } + /// + /// 内容 + /// + public string Content { get; set; } + /// + /// 时间 + /// + public DateTime? Time { get; set; } + /// + /// 是否提醒 + /// + public bool? IsRemind { get; set; } + /// + /// 封面图 + /// + public string Cover { get; set; } + /// + /// 是否为系统日记 1:系统日记 0:用户日记 + /// + public bool? IsSystem { get; set; } + /// + /// 权重(排序) + /// + public int? Sequence { get; set; } + /// + /// + /// + public string IP { get; set; } + /// + /// + /// + public DateTime? CreateTime { get; set; } + /// + /// + /// + public DateTime? UpdateTime { get; set; } + /// + /// + /// + public bool? IsDelete { get; set; } + } + + public class UnitBoolTest + { + [SugarColumn(IsPrimaryKey =true)] + public int Id { get; set; } + public bool BoolValue { get; set; } + public string Name { get; set; } + } + /// + /// 普通用户表 + /// + [Serializable] + public class UnitUser + { + private System.Int64? _USER_ID; + /// + /// GUID主键 + /// + [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; + /// + /// 用户账号，不可重名，即使是假删除了，亦不可重复 + /// + public System.String USER_ACCOUNT { get { return this._USER_ACCOUNT; } set { this._USER_ACCOUNT = value; } } + + private System.String _USER_PWD; + /// + /// 用户密码 + /// + public System.String USER_PWD + { + get { return this._USER_PWD; } + set { this._USER_PWD = value; } + } + /// + /// 不允许用户密码序列化，可以反序列化 + /// + /// + public bool ShouldSerializeUSER_PWD() + { + return false; + } + + private System.String _USER_NAME; + /// + /// 用户姓名 + /// + + public System.String USER_NAME { get { return this._USER_NAME; } set { this._USER_NAME = value; } } + + private System.Int32 _USER_STATUS; + /// + /// 用户状体：10正常；20锁定；99已删除 + /// + public System.Int32 USER_STATUS { get { return this._USER_STATUS; } set { this._USER_STATUS = value; } } + + private System.DateTime _PWD_LASTCHTIME; + /// + /// 最后一次密码更新时间 + /// + public System.DateTime PWD_LASTCHTIME { get { return this._PWD_LASTCHTIME; } set { this._PWD_LASTCHTIME = value; } } + + private System.Int32? _PWD_ERRORCOUNT; + /// + /// 密码错误次数，达到定义的次数就锁定 + /// + public System.Int32? PWD_ERRORCOUNT { get { return this._PWD_ERRORCOUNT; } set { this._PWD_ERRORCOUNT = value ?? 0; } } + + private System.DateTime? _PWD_LASTERRTIME = null; + /// + /// 密码最后一次错误时间，满足定义的时间差之后，可自动解锁，如20分钟后自动解锁，亦作为累次错误次数的时间差比对基础 + /// 允许为空 + /// + public System.DateTime? PWD_LASTERRTIME { get { return this._PWD_LASTERRTIME; } set { this._PWD_LASTERRTIME = value; } } + } +} diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.sln b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.sln index d729251ac..16aa388f6 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.sln +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.sln @@ -19,6 +19,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PgSqlTest", "PgSqlTest\PgSq EndProject Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DmOrmTest", "DmOrmTest\DmOrmTest.csproj", "{FBA1A5CC-1C9D-476F-B19D-FD5E2201C30A}" EndProject +Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "KdbndpTest", "KdbndpTest\KdbndpTest.csproj", "{21744B61-74AB-4706-9A52-C9D0C4AAD19E}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Any CPU = Debug|Any CPU @@ -57,6 +59,10 @@ Global {FBA1A5CC-1C9D-476F-B19D-FD5E2201C30A}.Debug|Any CPU.Build.0 = Debug|Any CPU {FBA1A5CC-1C9D-476F-B19D-FD5E2201C30A}.Release|Any CPU.ActiveCfg = Release|Any CPU {FBA1A5CC-1C9D-476F-B19D-FD5E2201C30A}.Release|Any CPU.Build.0 = Release|Any CPU + {21744B61-74AB-4706-9A52-C9D0C4AAD19E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU + {21744B61-74AB-4706-9A52-C9D0C4AAD19E}.Debug|Any CPU.Build.0 = Debug|Any CPU + {21744B61-74AB-4706-9A52-C9D0C4AAD19E}.Release|Any CPU.ActiveCfg = Release|Any CPU + {21744B61-74AB-4706-9A52-C9D0C4AAD19E}.Release|Any CPU.Build.0 = Release|Any CPU EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Infrastructure/InstanceFactory.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Infrastructure/InstanceFactory.cs index a88dd08ef..39d61ace2 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Infrastructure/InstanceFactory.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Infrastructure/InstanceFactory.cs @@ -229,6 +229,10 @@ namespace SqlSugar { return new PostgreSQLInserttable(); } + else if (currentConnectionConfig.DbType == DbType.Kdbndp) + { + return new KdbndpInserttable(); + } else { return new InsertableProvider(); diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbBind/KdbndpBind.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbBind/KdbndpBind.cs index e02aeba51..d71af6fa8 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbBind/KdbndpBind.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbBind/KdbndpBind.cs @@ -109,6 +109,7 @@ namespace SqlSugar new KeyValuePair("bit",CSharpDataType.byteArray), new KeyValuePair("bit varying",CSharpDataType.byteArray), new KeyValuePair("varbit",CSharpDataType.@byte), + new KeyValuePair("regclass",CSharpDataType.@object) }; public override List StringThrow diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbMaintenance/KdbndpDbMaintenance.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbMaintenance/KdbndpDbMaintenance.cs index 2d463aa9a..f26c921bf 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbMaintenance/KdbndpDbMaintenance.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/DbMaintenance/KdbndpDbMaintenance.cs @@ -12,7 +12,7 @@ namespace SqlSugar { get { - return "SELECT datname FROM pg_database"; + return "SELECT datname FROM sys_database"; } } protected override string GetColumnInfosByTableNameSql @@ -26,22 +26,22 @@ namespace SqlSugar col_description(pclass.oid, pcolumn.ordinal_position) as ColumnDescription, case when pkey.colname = pcolumn.column_name then true else false end as IsPrimaryKey, - case when pcolumn.column_default like 'nextval%' + case when pcolumn.column_default like 'NEXTVAL%' then true else false end as IsIdentity, case when pcolumn.is_nullable = 'YES' then true else false end as IsNullable - from (select * from pg_tables where tablename = '{0}' and schemaname='public') ptables inner join pg_class pclass + from (select * from sys_tables where tablename = UPPER('{0}') and schemaname='PUBLIC') ptables inner join sys_class pclass on ptables.tablename = pclass.relname inner join (SELECT * FROM information_schema.columns ) pcolumn on pcolumn.table_name = ptables.tablename left join ( - select pg_class.relname,pg_attribute.attname as colname from - pg_constraint inner join pg_class - on pg_constraint.conrelid = pg_class.oid - inner join pg_attribute on pg_attribute.attrelid = pg_class.oid - and pg_attribute.attnum = pg_constraint.conkey[1] - inner join pg_type on pg_type.oid = pg_attribute.atttypid - where pg_constraint.contype='p' + select sys_class.relname,sys_attribute.attname as colname from + sys_constraint inner join sys_class + on sys_constraint.conrelid = sys_class.oid + inner join sys_attribute on sys_attribute.attrelid = sys_class.oid + and sys_attribute.attnum = sys_constraint.conkey[1] + inner join sys_type on sys_type.oid = sys_attribute.atttypid + where sys_constraint.contype='p' ) pkey on pcolumn.table_name = pkey.relname order by ptables.tablename"; return sql; @@ -52,17 +52,17 @@ namespace SqlSugar get { return @"select cast(relname as varchar) as Name, - cast(obj_description(relfilenode,'pg_class') as varchar) as Description from pg_class c - where relkind = 'r' and relname not like 'pg_%' and relname not like 'sql_%' order by relname"; + cast(obj_description(relfilenode,'sys_class') as varchar) as Description from sys_class c + where relkind = 'r' and relname not like 'sys_%' and relname not like 'sql_%' order by relname"; } } protected override string GetViewInfoListSql { get { - return @"select cast(relname as varchar) as Name,cast(Description as varchar) from pg_description - join pg_class on pg_description.objoid = pg_class.oid - where objsubid = 0 and relname in (SELECT viewname from pg_views + return @"select cast(relname as varchar) as Name,cast(Description as varchar) from sys_description + join sys_class on sys_description.objoid = sys_class.oid + where objsubid = 0 and relname in (SELECT viewname from sys_views WHERE schemaname ='public')"; } } @@ -256,7 +256,7 @@ namespace SqlSugar } var oldDatabaseName = this.Context.Ado.Connection.Database; var connection = this.Context.CurrentConnectionConfig.ConnectionString; - connection = connection.Replace(oldDatabaseName, "postgres"); + connection = connection.Replace(oldDatabaseName, "SAMPLES"); var newDb = new SqlSugarClient(new ConnectionConfig() { DbType = this.Context.CurrentConnectionConfig.DbType, diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpBuilder.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpBuilder.cs index 76d1ea7cf..0524d9112 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpBuilder.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpBuilder.cs @@ -35,19 +35,12 @@ namespace SqlSugar } } - public bool isAutoToLower - { - get - { - if (this.Context.CurrentConnectionConfig.MoreSettings == null) return true; - return this.Context.CurrentConnectionConfig.MoreSettings.PgSqlIsAutoToLower; - } - } + public override string GetTranslationColumnName(string propertyName) { if (propertyName.Contains(SqlTranslationLeft)) return propertyName; else - return SqlTranslationLeft + propertyName.ToLower(isAutoToLower) + SqlTranslationRight; + return SqlTranslationLeft + propertyName.ToUpper() + SqlTranslationRight; } //public override string GetNoTranslationColumnName(string name) @@ -64,7 +57,7 @@ namespace SqlSugar .FirstOrDefault(it => it.EntityName.Equals(entityName, StringComparison.CurrentCultureIgnoreCase) && it.PropertyName.Equals(propertyName, StringComparison.CurrentCultureIgnoreCase)); - return (mappingInfo == null ? SqlTranslationLeft + propertyName.ToLower(isAutoToLower) + SqlTranslationRight : SqlTranslationLeft + mappingInfo.DbColumnName.ToLower(isAutoToLower) + SqlTranslationRight); + return (mappingInfo == null ? SqlTranslationLeft + propertyName.ToUpper()+ SqlTranslationRight : SqlTranslationLeft + mappingInfo.DbColumnName.ToUpper() + SqlTranslationRight); } public override string GetTranslationTableName(string name) @@ -78,7 +71,7 @@ namespace SqlSugar name = (mappingInfo == null ? name : mappingInfo.DbTableName); if (name.Contains(".")&& !name.Contains("(")) { - return string.Join(".", name.ToLower(isAutoToLower).Split('.').Select(it => SqlTranslationLeft + it + SqlTranslationRight)); + return string.Join(".", name.ToUpper().Split('.').Select(it => SqlTranslationLeft + it + SqlTranslationRight)); } else if (name.Contains("(")) { @@ -90,7 +83,7 @@ namespace SqlSugar } else { - return SqlTranslationLeft + name.ToLower(isAutoToLower).TrimEnd('"').TrimStart('"') + SqlTranslationRight; + return SqlTranslationLeft + name.ToUpper().TrimEnd('"').TrimStart('"') + SqlTranslationRight; } } } diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpExpressionContext.cs b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpExpressionContext.cs index 4255d34c0..c546e8943 100644 --- a/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpExpressionContext.cs +++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSugar/Realization/Kdbndp/SqlBuilder/KdbndpExpressionContext.cs @@ -25,15 +25,9 @@ namespace SqlSugar } public override string GetTranslationText(string name) { - return SqlTranslationLeft + name.ToLower(isAutoToLower) + SqlTranslationRight; - } - public bool isAutoToLower - { - get - { - return base.PgSqlIsAutoToLower; - } + return SqlTranslationLeft + name.ToUpper() + SqlTranslationRight; } + public override string GetTranslationTableName(string entityName, bool isMapping = true) { Check.ArgumentNullException(entityName, string.Format(ErrorMessage.ObjNotExist, "Table Name")); @@ -53,7 +47,7 @@ namespace SqlSugar else if (isMapping) { var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(entityName, StringComparison.CurrentCultureIgnoreCase)); - return SqlTranslationLeft + (mappingInfo == null ? entityName : mappingInfo.DbTableName).ToLower(isAutoToLower) + SqlTranslationRight; + return SqlTranslationLeft + (mappingInfo == null ? entityName : mappingInfo.DbTableName).ToUpper() + SqlTranslationRight; } else if (isComplex) { @@ -86,11 +80,11 @@ namespace SqlSugar if (this.MappingColumns.HasValue()) { var mappingInfo = this.MappingColumns.SingleOrDefault(it => it.EntityName == entityName && it.PropertyName == propertyName); - return (mappingInfo == null ? propertyName : mappingInfo.DbColumnName).ToLower(isAutoToLower); + return (mappingInfo == null ? propertyName : mappingInfo.DbColumnName).ToUpper(); } else { - return propertyName.ToLower(isAutoToLower); + return propertyName.ToUpper(); } } }