From 3f790e0c1d31ae193dd137aaaf79aebcec5b3e1c Mon Sep 17 00:00:00 2001
From: sunkaixuan <610262374@qq.com>
Date: Tue, 23 Aug 2022 00:30:09 +0800
Subject: [PATCH] Add GBase
---
Src/Asp.NetCore2/.editorconfig | 10 +
Src/Asp.NetCore2/GbaseTest/Config.cs | 31 +
.../GbaseTest/Demo/Demo0_SqlSugarClient.cs | 422 ++++++++++++++
.../GbaseTest/Demo/Demo1_Queryable.cs | 342 +++++++++++
.../GbaseTest/Demo/Demo2_Updateable.cs | 107 ++++
.../GbaseTest/Demo/Demo3_Insertable.cs | 56 ++
.../GbaseTest/Demo/Demo4_Deleteable.cs | 48 ++
.../GbaseTest/Demo/Demo5_SqlQueryable.cs | 37 ++
.../GbaseTest/Demo/Demo6_Queue.cs | 52 ++
Src/Asp.NetCore2/GbaseTest/Demo/Demo7_Ado.cs | 57 ++
.../GbaseTest/Demo/Demo8_Saveable.cs | 48 ++
.../GbaseTest/Demo/Demo9_EntityMain.cs | 46 ++
.../GbaseTest/Demo/DemoA_DbMain.cs | 42 ++
Src/Asp.NetCore2/GbaseTest/Demo/DemoB_Aop.cs | 68 +++
.../GbaseTest/Demo/DemoD_DbFirst.cs | 75 +++
.../GbaseTest/Demo/DemoE_CodeFirst.cs | 40 ++
.../GbaseTest/Demo/DemoF_Utilities.cs | 46 ++
.../GbaseTest/Demo/DemoG_SimpleClient.cs | 36 ++
.../GbaseTest/Demo/Democ_GobalFilter.cs | 77 +++
Src/Asp.NetCore2/GbaseTest/GbaseTest.csproj | 7 +-
.../GbaseTest/Models/AttributeTable.cs | 20 +
Src/Asp.NetCore2/GbaseTest/Models/CarType.cs | 7 +
Src/Asp.NetCore2/GbaseTest/Models/Custom.cs | 14 +
.../GbaseTest/Models/EntityMapper.cs | 15 +
Src/Asp.NetCore2/GbaseTest/Models/Mapper.cs | 54 ++
.../Models/MyCustomAttributeTable.cs | 20 +
Src/Asp.NetCore2/GbaseTest/Models/Order.cs | 24 +
.../GbaseTest/Models/OrderItem.cs | 18 +
Src/Asp.NetCore2/GbaseTest/Models/TestTree.cs | 17 +
Src/Asp.NetCore2/GbaseTest/Models/Tree.cs | 20 +
.../GbaseTest/Models/ViewOrder.cs | 13 +
Src/Asp.NetCore2/GbaseTest/Program.cs | 6 +-
.../SqlSeverTest/SqlSeverTest.csproj | 4 +
.../DataTableExtensions/GBaseDataAdapter.cs | 157 +++++
.../GBase/CodeFirst/GBaseCodeFirst.cs | 33 ++
.../GBase/DbBind/GBaseDbBind.cs | 72 +++
.../GBase/DbFirst/GBaseDbFirst.cs | 11 +
.../GBase/DbMaintenance/GBaseDbMaintenance.cs | 534 ++++++++++++++++++
.../SqlSugar.GBaseCore/GBase/GBaseProvider.cs | 184 ++++++
.../GBase/Queryable/GBaseQueryable.cs | 58 ++
.../GBase/SqlBuilder/GBaseBlukCopy.cs | 154 +++++
.../GBase/SqlBuilder/GBaseBuilder.cs | 15 +
.../GBase/SqlBuilder/GBaseDeleteBuilder.cs | 13 +
.../SqlBuilder/GBaseExpressionContext.cs | 58 ++
.../GBase/SqlBuilder/GBaseFastBuilder.cs | 56 ++
.../GBase/SqlBuilder/GBaseInsertBuilder.cs | 66 +++
.../GBase/SqlBuilder/GBaseQueryBuilder.cs | 122 ++++
.../GBase/SqlBuilder/GBaseUpdateBuilder.cs | 79 +++
.../SqlSugar.GBaseCore.csproj | 16 +
.../SqlSugar.GBaseCore/Tools/ErrorMessage.cs | 64 +++
.../SqlSugar.GBaseCore/Tools/FileHelper.cs | 70 +++
.../SqlSugar.GBaseCore/Tools/UtilConstants.cs | 73 +++
.../Tools/UtilExtensions.cs | 142 +++++
.../SqlSugar.GBaseCore/Tools/UtilMethods.cs | 507 +++++++++++++++++
.../Tools/ValidateExtensions.cs | 172 ++++++
.../Infrastructure/InstanceFactory.cs | 4 +
Src/Asp.NetCore2/SqlSugarCore.sln | 22 +-
57 files changed, 4556 insertions(+), 5 deletions(-)
create mode 100644 Src/Asp.NetCore2/.editorconfig
create mode 100644 Src/Asp.NetCore2/GbaseTest/Config.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo0_SqlSugarClient.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo1_Queryable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo2_Updateable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo3_Insertable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo4_Deleteable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo5_SqlQueryable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo6_Queue.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo7_Ado.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo8_Saveable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Demo9_EntityMain.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoA_DbMain.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoB_Aop.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoD_DbFirst.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoE_CodeFirst.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoF_Utilities.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/DemoG_SimpleClient.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Demo/Democ_GobalFilter.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/AttributeTable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/CarType.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/Custom.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/EntityMapper.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/Mapper.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/MyCustomAttributeTable.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/Order.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/OrderItem.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/TestTree.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/Tree.cs
create mode 100644 Src/Asp.NetCore2/GbaseTest/Models/ViewOrder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/DataTableExtensions/GBaseDataAdapter.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/CodeFirst/GBaseCodeFirst.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbBind/GBaseDbBind.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbFirst/GBaseDbFirst.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbMaintenance/GBaseDbMaintenance.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/GBaseProvider.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/Queryable/GBaseQueryable.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBlukCopy.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseDeleteBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseExpressionContext.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseFastBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseInsertBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseQueryBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseUpdateBuilder.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/SqlSugar.GBaseCore.csproj
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/ErrorMessage.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/FileHelper.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/UtilConstants.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/UtilExtensions.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/UtilMethods.cs
create mode 100644 Src/Asp.NetCore2/SqlSugar.GBaseCore/Tools/ValidateExtensions.cs
diff --git a/Src/Asp.NetCore2/.editorconfig b/Src/Asp.NetCore2/.editorconfig
new file mode 100644
index 000000000..a8dab40a4
--- /dev/null
+++ b/Src/Asp.NetCore2/.editorconfig
@@ -0,0 +1,10 @@
+[*.cs]
+
+# CS8618: 在退出构造函数时,不可为 null 的字段必须包含非 null 值。请考虑声明为可以为 null。
+dotnet_diagnostic.CS8618.severity = none
+
+# CS8625: 无法将 null 字面量转换为非 null 的引用类型。
+dotnet_diagnostic.CS8625.severity = none
+
+# CS8604: 引用类型参数可能为 null。
+dotnet_diagnostic.CS8604.severity = none
diff --git a/Src/Asp.NetCore2/GbaseTest/Config.cs b/Src/Asp.NetCore2/GbaseTest/Config.cs
new file mode 100644
index 000000000..b5e80a511
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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 = "Driver={GBase ODBC DRIVER (64-Bit)};Host=localhost;Service=19088;Server=gbase01;Database=testdb;Protocol=onsoctcp;Uid=gbasedbt;Pwd=GBase123;Db_locale=zh_CN.utf8;Client_locale=zh_CN.utf8";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString2 = "Driver={GBase ODBC DRIVER (64-Bit)};Host=localhost;Service=19088;Server=gbase01;Database=testdb2;Protocol=onsoctcp;Uid=gbasedbt;Pwd=GBase123;Db_locale=zh_CN.utf8;Client_locale=zh_CN.utf8";
+ ///
+ /// Account have permission to create database
+ /// 用有建库权限的数据库账号
+ ///
+ public static string ConnectionString3 = "Driver={GBase ODBC DRIVER (64-Bit)};Host=localhost;Service=19088;Server=gbase01;Database=testdb3;Protocol=onsoctcp;Uid=gbasedbt;Pwd=GBase123;Db_locale=zh_CN.utf8;Client_locale=zh_CN.utf8";
+ }
+}
diff --git a/Src/Asp.NetCore2/GbaseTest/Demo/Demo0_SqlSugarClient.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo0_SqlSugarClient.cs
new file mode 100644
index 000000000..a5fdc11ea
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/Demo/Demo0_SqlSugarClient.cs
@@ -0,0 +1,422 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+namespace OrmTest
+{
+ public class Demo0_SqlSugarClient
+ {
+
+ public static void Init()
+ {
+ SqlSugarClient();//Create db
+ DbContext();//Optimizing SqlSugarClient usage
+ SingletonPattern();//Singleten Pattern
+ DistributedTransactionExample();
+ MasterSlave();//Read-write separation
+ CustomAttribute();
+ }
+
+ private static void MasterSlave()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### MasterSlave Start ####");
+ SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,//Master Connection
+ DbType = DbType.GBase,
+ 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.GBase,
+ ConnectionString = Config.ConnectionString,
+ InitKeyType = InitKeyType.Attribute,
+ IsAutoCloseConnection = true,
+ AopEvents = new AopEvents
+ {
+ OnLogExecuting = (sql, p) =>
+ {
+ Console.WriteLine(sql);
+ Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
+ }
+ }
+ });
+
+ //If no exist create datebase
+ db.DbMaintenance.CreateDatabase();
+
+ //Use db query
+ var dt = db.Ado.GetDataTable("select 1");
+
+ //Create tables
+ db.CodeFirst.InitTables(typeof(OrderItem),typeof(Order));
+ var id = db.Insertable(new Order() { Name = "order1", CustomId = 1, Price = 0, CreateTime = DateTime.Now }).ExecuteReturnIdentity();
+
+ //Insert data
+ db.Insertable(new OrderItem() { OrderId = id, Price = 0, CreateTime=DateTime.Now }).ExecuteCommand();
+ Console.WriteLine("#### SqlSugarClient End ####");
+
+ }
+
+ private static void DbContext()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### DbContext Start ####");
+ var insertObj = new Order { Name = "jack", CreateTime = DateTime.Now };
+ var InsertObjs = new Order[] { insertObj };
+
+ DbContext context = new DbContext();
+
+ context.Db.CodeFirst.InitTables();//Create Tables
+ ;
+ var orderDb = context.OrderDb;
+
+ //Select
+ var data1 = orderDb.GetById(1);
+ var data2 = orderDb.GetList();
+ var data3 = orderDb.GetList(it => it.Id == 1);
+ var data4 = orderDb.GetSingle(it => it.Id == 1);
+ var p = new PageModel() { PageIndex = 1, PageSize = 2 };
+ var data5 = orderDb.GetPageList(it => it.Name == "xx", p);
+ Console.Write(p.TotalCount);
+ var data6 = orderDb.GetPageList(it => it.Name == "xx", p, it => it.Name, OrderByType.Asc);
+ Console.Write(p.TotalCount);
+ List conModels = new List();
+ conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1", 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.GBase,
+ IsAutoCloseConnection = true,
+ InitKeyType = InitKeyType.Attribute,
+ ConfigureExternalServices = new ConfigureExternalServices()
+ {
+ EntityService = (property, column) =>
+ {
+
+ var attributes = property.GetCustomAttributes(true);//get all attributes
+
+ if (attributes.Any(it => it is KeyAttribute))// by attribute set primarykey
+ {
+ column.IsPrimarykey = true;
+ }
+ },
+ EntityNameService = (type, entity) =>
+ {
+ var attributes = type.GetCustomAttributes(true);
+ if (attributes.Any(it => it is TableAttribute))
+ {
+ entity.DbTableName = (attributes.First(it => it is TableAttribute) as TableAttribute).Name;
+ }
+ }
+ }
+ });
+ db.CodeFirst.InitTables();//Create Table
+
+ db.Insertable(new AttributeTable() { Id = Guid.NewGuid().ToString(), Name = "Name" }).ExecuteCommand();
+ var list = db.Queryable().ToList();
+
+ Console.WriteLine("#### Custom Attribute End ####");
+ }
+
+
+ private static void SingletonPattern()
+ {
+ Console.WriteLine("");
+ Console.WriteLine("#### Singleton Pattern Start ####");
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ Console.WriteLine("Db_Id:" + singleDb.ContextID);
+ var task = new Task(() =>
+ {
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ new Task(() =>
+ {
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+ Console.WriteLine("_Task_Task DbId:" + singleDb.ContextID);
+
+ }).Start();
+ Console.WriteLine("Task DbId:" + singleDb.ContextID);
+ });
+ task.Start();
+ task.Wait();
+ System.Threading.Thread.Sleep(500);
+ Console.WriteLine(string.Join(",", singleDb.TempItems.Keys));
+
+ Console.WriteLine("#### Singleton Pattern end ####");
+ }
+
+ static SqlSugarScope singleDb = new SqlSugarScope(
+ new ConnectionConfig()
+ {
+ ConfigId = 1,
+ DbType = DbType.GBase,
+ 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.GBase, ConnectionString=Config.ConnectionString,InitKeyType=InitKeyType.Attribute,IsAutoCloseConnection=true },
+ new ConnectionConfig(){ ConfigId="2", DbType=DbType.GBase, ConnectionString=Config.ConnectionString2 ,InitKeyType=InitKeyType.Attribute ,IsAutoCloseConnection=true}
+ });
+
+ var db1 = db.Ado.Connection.Database;
+ //use db1
+ db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem));//
+ db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand();
+ Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count());
+
+ //use db2
+ db.ChangeDatabase("2");
+ var db2 = db.Ado.Connection.Database;
+ db.DbMaintenance.CreateDatabase();//Create Database2
+ db.CodeFirst.SetStringDefaultLength(200).InitTables(typeof(Order), typeof(OrderItem));
+ db.Insertable(new Order() { Name = "order1", CreateTime = DateTime.Now }).ExecuteCommand();
+ Console.WriteLine(db.CurrentConnectionConfig.DbType + ":" + db.Queryable().Count());
+
+ if (db2 == db1)
+ {
+ return;
+ }
+
+ // Example 1
+ Console.WriteLine("Example 1");
+ try
+ {
+ db.BeginTran();
+
+ db.ChangeDatabase("1");//use db1
+ db.Deleteable().ExecuteCommand();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ db.Deleteable().ExecuteCommand();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ throw new Exception();
+ db.CommitTran();
+ }
+ catch
+ {
+ db.RollbackTran();
+ Console.WriteLine("---Roll back");
+ db.ChangeDatabase("1");//use db1
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ }
+
+
+
+ // Example 2
+ Console.WriteLine("Example 2");
+
+ var result=db.UseTran(() =>
+ {
+
+ db.ChangeDatabase("1");//use db1
+ db.Deleteable().ExecuteCommand();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ db.Deleteable().ExecuteCommand();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ throw new Exception("");
+
+ });
+ if (result.IsSuccess == false) {
+ Console.WriteLine("---Roll back");
+ db.ChangeDatabase("1");//use db1
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ }
+
+ // Example 3
+ Console.WriteLine("Example 3");
+
+ var result2 = db.UseTranAsync(async () =>
+ {
+
+ db.ChangeDatabase("1");//use db1
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use db2
+ await db.Deleteable().ExecuteCommandAsync();
+ Console.WriteLine("---Delete all " + db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ throw new Exception("");
+
+ });
+ result2.Wait();
+ if (result2.Result.IsSuccess == false)
+ {
+ Console.WriteLine("---Roll back");
+ db.ChangeDatabase("1");//use sqlserver
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+
+ db.ChangeDatabase("2");//use mysql
+ Console.WriteLine(db.CurrentConnectionConfig.DbType);
+ Console.WriteLine(db.Queryable().Count());
+ }
+
+ }
+ }
+
+ ///
+ /// DbContext Example 1
+ ///
+ public class DbContext
+ {
+
+ public SqlSugarClient Db;
+ public DbContext()
+ {
+ Db = new SqlSugarClient(new ConnectionConfig()
+ {
+ ConnectionString = Config.ConnectionString,
+ DbType = DbType.GBase,
+ 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.GBase,
+ 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/GbaseTest/Demo/Demo1_Queryable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo1_Queryable.cs
new file mode 100644
index 000000000..7201fb89a
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/Demo/Demo1_Queryable.cs
@@ -0,0 +1,342 @@
+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)
+ .Where(it=>it.A.Id==1).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.GBase,
+ 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/GbaseTest/Demo/Demo2_Updateable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo2_Updateable.cs
new file mode 100644
index 000000000..6ce365545
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo3_Insertable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo3_Insertable.cs
new file mode 100644
index 000000000..c0c055a19
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo4_Deleteable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo4_Deleteable.cs
new file mode 100644
index 000000000..5ab8befc8
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo5_SqlQueryable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo5_SqlQueryable.cs
new file mode 100644
index 000000000..deee2c58d
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo6_Queue.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo6_Queue.cs
new file mode 100644
index 000000000..a526c22ed
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo7_Ado.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo7_Ado.cs
new file mode 100644
index 000000000..3192bd1fa
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo8_Saveable.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo8_Saveable.cs
new file mode 100644
index 000000000..0bcfac7de
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Demo9_EntityMain.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Demo9_EntityMain.cs
new file mode 100644
index 000000000..26e963a0d
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoA_DbMain.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoA_DbMain.cs
new file mode 100644
index 000000000..751d10ef9
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoB_Aop.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoB_Aop.cs
new file mode 100644
index 000000000..645a67760
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoD_DbFirst.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoD_DbFirst.cs
new file mode 100644
index 000000000..bf844105a
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoE_CodeFirst.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoE_CodeFirst.cs
new file mode 100644
index 000000000..65640cb98
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoF_Utilities.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoF_Utilities.cs
new file mode 100644
index 000000000..009192a0e
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/DemoG_SimpleClient.cs b/Src/Asp.NetCore2/GbaseTest/Demo/DemoG_SimpleClient.cs
new file mode 100644
index 000000000..816a43aec
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase,
+ 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/GbaseTest/Demo/Democ_GobalFilter.cs b/Src/Asp.NetCore2/GbaseTest/Demo/Democ_GobalFilter.cs
new file mode 100644
index 000000000..38fb5006c
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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.GBase, 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/GbaseTest/GbaseTest.csproj b/Src/Asp.NetCore2/GbaseTest/GbaseTest.csproj
index c8c5dadec..5ba209dd3 100644
--- a/Src/Asp.NetCore2/GbaseTest/GbaseTest.csproj
+++ b/Src/Asp.NetCore2/GbaseTest/GbaseTest.csproj
@@ -1,4 +1,4 @@
-
+
Exe
@@ -9,4 +9,9 @@
+
+
+
+
+
diff --git a/Src/Asp.NetCore2/GbaseTest/Models/AttributeTable.cs b/Src/Asp.NetCore2/GbaseTest/Models/AttributeTable.cs
new file mode 100644
index 000000000..c1a43ad12
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/CarType.cs b/Src/Asp.NetCore2/GbaseTest/Models/CarType.cs
new file mode 100644
index 000000000..00dc12710
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/Custom.cs b/Src/Asp.NetCore2/GbaseTest/Models/Custom.cs
new file mode 100644
index 000000000..3b8871c57
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/EntityMapper.cs b/Src/Asp.NetCore2/GbaseTest/Models/EntityMapper.cs
new file mode 100644
index 000000000..b597012fb
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/Mapper.cs b/Src/Asp.NetCore2/GbaseTest/Models/Mapper.cs
new file mode 100644
index 000000000..8d7991d6c
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/MyCustomAttributeTable.cs b/Src/Asp.NetCore2/GbaseTest/Models/MyCustomAttributeTable.cs
new file mode 100644
index 000000000..11359d062
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/Order.cs b/Src/Asp.NetCore2/GbaseTest/Models/Order.cs
new file mode 100644
index 000000000..d7ff068b8
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/OrderItem.cs b/Src/Asp.NetCore2/GbaseTest/Models/OrderItem.cs
new file mode 100644
index 000000000..ae3262c7c
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/TestTree.cs b/Src/Asp.NetCore2/GbaseTest/Models/TestTree.cs
new file mode 100644
index 000000000..b8250828a
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/Tree.cs b/Src/Asp.NetCore2/GbaseTest/Models/Tree.cs
new file mode 100644
index 000000000..d2878de64
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Models/ViewOrder.cs b/Src/Asp.NetCore2/GbaseTest/Models/ViewOrder.cs
new file mode 100644
index 000000000..fcd465747
--- /dev/null
+++ b/Src/Asp.NetCore2/GbaseTest/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/GbaseTest/Program.cs b/Src/Asp.NetCore2/GbaseTest/Program.cs
index 729f6a5da..c398988b2 100644
--- a/Src/Asp.NetCore2/GbaseTest/Program.cs
+++ b/Src/Asp.NetCore2/GbaseTest/Program.cs
@@ -1,4 +1,5 @@
-using System;
+using OrmTest;
+using System;
namespace GbaseTest
{
@@ -6,8 +7,7 @@ namespace GbaseTest
{
static void Main(string[] args)
{
- var odbc= new System.Data.Odbc.OdbcConnection(@"Driver={GBase ODBC 8.3 DRIVER};Server=localhost;port=19088;Database=;Protocol=onsoctcp;Uid=gbasedbt;Pwd=GBase123;");
- odbc.Open();
+ Demo0_SqlSugarClient.Init();
Console.WriteLine("Hello World!");
}
}
diff --git a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.csproj b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.csproj
index 48586a03a..cab36f214 100644
--- a/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.csproj
+++ b/Src/Asp.NetCore2/SqlSeverTest/SqlSeverTest.csproj
@@ -11,6 +11,10 @@
+
+
+
+
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/DataTableExtensions/GBaseDataAdapter.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/DataTableExtensions/GBaseDataAdapter.cs
new file mode 100644
index 000000000..c2069ce9d
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/DataTableExtensions/GBaseDataAdapter.cs
@@ -0,0 +1,157 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.Odbc;
+using System.Text;
+namespace SqlSugar.GBase
+{
+ ///
+ /// 数据填充器
+ ///
+ public class GBaseDataAdapter : IDataAdapter
+ {
+ private OdbcCommand command;
+ private string sql;
+ private OdbcConnection _sqlConnection;
+
+ ///
+ /// SqlDataAdapter
+ ///
+ ///
+ public GBaseDataAdapter(OdbcCommand command)
+ {
+ this.command = command;
+ }
+
+ public GBaseDataAdapter()
+ {
+
+ }
+
+ ///
+ /// SqlDataAdapter
+ ///
+ ///
+ ///
+ public GBaseDataAdapter(string sql, OdbcConnection _sqlConnection)
+ {
+ this.sql = sql;
+ this._sqlConnection = _sqlConnection;
+ }
+
+ ///
+ /// SelectCommand
+ ///
+ public OdbcCommand SelectCommand
+ {
+ get
+ {
+ if (this.command == null)
+ {
+ var conn = (OdbcConnection)this._sqlConnection;
+ this.command = conn.CreateCommand();
+ this.command.CommandText = sql;
+ }
+ return this.command;
+ }
+ set
+ {
+ this.command = value;
+ }
+ }
+
+ ///
+ /// Fill
+ ///
+ ///
+ public void Fill(DataTable dt)
+ {
+ if (dt == null)
+ {
+ dt = new DataTable();
+ }
+ var columns = dt.Columns;
+ var rows = dt.Rows;
+ using (var dr = command.ExecuteReader())
+ {
+ for (int i = 0; i < dr.FieldCount; i++)
+ {
+ string name = dr.GetName(i).Trim();
+ if (!columns.Contains(name))
+ columns.Add(new DataColumn(name, dr.GetFieldType(i)));
+ else
+ {
+ columns.Add(new DataColumn(name + i, dr.GetFieldType(i)));
+ }
+ }
+
+ while (dr.Read())
+ {
+ DataRow daRow = dt.NewRow();
+ for (int i = 0; i < columns.Count; i++)
+ {
+ daRow[columns[i].ColumnName] = dr.GetValue(i);
+ }
+ dt.Rows.Add(daRow);
+ }
+ }
+ dt.AcceptChanges();
+ }
+
+ ///
+ /// Fill
+ ///
+ ///
+ public void Fill(DataSet ds)
+ {
+ if (ds == null)
+ {
+ ds = new DataSet();
+ }
+ using (var dr = command.ExecuteReader())
+ {
+ do
+ {
+ var dt = new DataTable();
+ var columns = dt.Columns;
+ var rows = dt.Rows;
+ for (int i = 0; i < dr.FieldCount; i++)
+ {
+ string name = dr.GetName(i).Trim();
+ if (dr.GetFieldType(i).Name == "DateTime")
+ {
+ if (!columns.Contains(name))
+ columns.Add(new DataColumn(name, UtilConstants.DateType));
+ else
+ {
+ columns.Add(new DataColumn(name + i, UtilConstants.DateType));
+ }
+ }
+ else
+ {
+ if (!columns.Contains(name))
+ columns.Add(new DataColumn(name, dr.GetFieldType(i)));
+ else
+ {
+ columns.Add(new DataColumn(name + i, dr.GetFieldType(i)));
+ }
+ }
+ }
+
+ while (dr.Read())
+ {
+ DataRow daRow = dt.NewRow();
+ for (int i = 0; i < columns.Count; i++)
+ {
+ daRow[columns[i].ColumnName] = dr.GetValue(i);
+ }
+ dt.Rows.Add(daRow);
+ }
+ dt.AcceptChanges();
+ ds.Tables.Add(dt);
+ } while (dr.NextResult());
+ }
+ }
+ }
+
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/CodeFirst/GBaseCodeFirst.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/CodeFirst/GBaseCodeFirst.cs
new file mode 100644
index 000000000..119c5db5a
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/CodeFirst/GBaseCodeFirst.cs
@@ -0,0 +1,33 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+namespace SqlSugar.GBase
+{
+ public class GBaseCodeFirst:CodeFirstProvider
+ {
+ protected override string GetTableName(EntityInfo entityInfo)
+ {
+ var table= this.Context.EntityMaintenance.GetTableName(entityInfo.EntityName);
+ var tableArray = table.Split('.');
+ var noFormat = table.Split(']').Length==1;
+ if (tableArray.Length > 1 && noFormat)
+ {
+ var dbMain = new GBaseDbMaintenance() { Context = this.Context };
+ var schmes = dbMain.GetSchemas();
+ if (!schmes.Any(it => it.EqualCase(tableArray.First())))
+ {
+ return tableArray.Last();
+ }
+ else
+ {
+ return dbMain.SqlBuilder.GetTranslationTableName(table);
+ }
+ }
+ else
+ {
+ return table;
+ }
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbBind/GBaseDbBind.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbBind/GBaseDbBind.cs
new file mode 100644
index 000000000..56c318119
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbBind/GBaseDbBind.cs
@@ -0,0 +1,72 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+namespace SqlSugar.GBase
+{
+ public class GBaseDbBind : DbBindProvider
+ {
+ public override string GetDbTypeName(string csharpTypeName)
+ {
+ if (csharpTypeName == nameof(DateTimeOffset))
+ {
+ return nameof(DateTimeOffset);
+ }
+ else
+ {
+ return base.GetDbTypeName(csharpTypeName);
+ }
+ }
+ public override List> MappingTypes
+ {
+ get
+ {
+ var extService = this.Context.CurrentConnectionConfig.ConfigureExternalServices;
+ if (extService != null&& extService.AppendDataReaderTypeMappings.HasValue())
+ {
+ return extService.AppendDataReaderTypeMappings.Union(MappingTypesConst).ToList();
+ }
+ else
+ {
+ return MappingTypesConst;
+ }
+ }
+ }
+ public static List> MappingTypesConst = new List>()
+ {
+ new KeyValuePair("int",CSharpDataType.@int),
+ new KeyValuePair("varchar",CSharpDataType.@string),
+ new KeyValuePair("nvarchar",CSharpDataType.@string),
+ new KeyValuePair("sql_variant",CSharpDataType.@string),
+ new KeyValuePair("text",CSharpDataType.@string),
+ new KeyValuePair("char",CSharpDataType.@string),
+ new KeyValuePair("ntext",CSharpDataType.@string),
+ new KeyValuePair("nchar",CSharpDataType.@string),
+ new KeyValuePair("hierarchyid",CSharpDataType.@string),
+ new KeyValuePair("bigint",CSharpDataType.@long),
+ new KeyValuePair("bit",CSharpDataType.@bool),
+ new KeyValuePair("datetime",CSharpDataType.DateTime),
+ new KeyValuePair("time",CSharpDataType.DateTime),
+ new KeyValuePair("smalldatetime",CSharpDataType.DateTime),
+ new KeyValuePair("timestamp",CSharpDataType.byteArray),
+ new KeyValuePair("datetime2",CSharpDataType.DateTime),
+ new KeyValuePair("date",CSharpDataType.DateTime),
+ new KeyValuePair("decimal",CSharpDataType.@decimal),
+ new KeyValuePair("single",CSharpDataType.@decimal),
+ new KeyValuePair("money",CSharpDataType.@decimal),
+ new KeyValuePair("numeric",CSharpDataType.@decimal),
+ new KeyValuePair("smallmoney",CSharpDataType.@decimal),
+ new KeyValuePair("float",CSharpDataType.@double),
+ new KeyValuePair("float",CSharpDataType.Single),
+ new KeyValuePair("real",CSharpDataType.@float),
+ new KeyValuePair("smallint",CSharpDataType.@short),
+ new KeyValuePair("tinyint",CSharpDataType.@byte),
+ new KeyValuePair("uniqueidentifier",CSharpDataType.Guid),
+ new KeyValuePair("binary",CSharpDataType.byteArray),
+ new KeyValuePair("image",CSharpDataType.byteArray),
+ new KeyValuePair("varbinary",CSharpDataType.byteArray),
+ new KeyValuePair("datetimeoffset", CSharpDataType.DateTimeOffset),
+ new KeyValuePair("datetimeoffset", CSharpDataType.DateTime)};
+ };
+
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbFirst/GBaseDbFirst.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbFirst/GBaseDbFirst.cs
new file mode 100644
index 000000000..1f6763d02
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbFirst/GBaseDbFirst.cs
@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseDbFirst : DbFirstProvider
+ {
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbMaintenance/GBaseDbMaintenance.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbMaintenance/GBaseDbMaintenance.cs
new file mode 100644
index 000000000..e047ab714
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/DbMaintenance/GBaseDbMaintenance.cs
@@ -0,0 +1,534 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseDbMaintenance : DbMaintenanceProvider
+ {
+ #region DML
+ protected override string GetDataBaseSql
+ {
+ get
+ {
+ return "SELECT NAME FROM master.dbo.sysdatabases ORDER BY NAME";
+ }
+ }
+ protected override string GetColumnInfosByTableNameSql
+ {
+ get
+ {
+ string sql = @"SELECT sysobjects.name AS TableName,
+ syscolumns.Id AS TableId,
+ syscolumns.name AS DbColumnName,
+ systypes.name AS DataType,
+ COLUMNPROPERTY(syscolumns.id,syscolumns.name,'PRECISION') as [length],
+ isnull(COLUMNPROPERTY(syscolumns.id,syscolumns.name,'Scale'),0) as Scale,
+ isnull(COLUMNPROPERTY(syscolumns.id,syscolumns.name,'Scale'),0) as DecimalDigits,
+ sys.extended_properties.[value] AS [ColumnDescription],
+ syscomments.text AS DefaultValue,
+ syscolumns.isnullable AS IsNullable,
+ columnproperty(syscolumns.id,syscolumns.name,'IsIdentity')as IsIdentity,
+ (CASE
+ WHEN EXISTS
+ (
+ select 1
+ from sysindexes i
+ join sysindexkeys k on i.id = k.id and i.indid = k.indid
+ join sysobjects o on i.id = o.id
+ join syscolumns c on i.id=c.id and k.colid = c.colid
+ where o.xtype = 'U'
+ and exists(select 1 from sysobjects where xtype = 'PK' and name = i.name)
+ and o.name=sysobjects.name and c.name=syscolumns.name
+ ) THEN 1
+ ELSE 0
+ END) AS IsPrimaryKey
+ FROM syscolumns
+ INNER JOIN systypes ON syscolumns.xtype = systypes.xtype
+ LEFT JOIN sysobjects ON syscolumns.id = sysobjects.id
+ LEFT OUTER JOIN sys.extended_properties ON (sys.extended_properties.minor_id = syscolumns.colid
+ AND sys.extended_properties.major_id = syscolumns.id)
+ LEFT OUTER JOIN syscomments ON syscolumns.cdefault = syscomments.id
+ WHERE syscolumns.id IN
+ (SELECT id
+ FROM sysobjects
+ WHERE upper(xtype) IN('U',
+ 'V') )
+ AND (systypes.name <> 'sysname')
+ AND sysobjects.name='{0}'
+ AND systypes.name<>'geometry'
+ AND systypes.name<>'geography'
+ ORDER BY syscolumns.colid";
+ return sql;
+ }
+ }
+ protected override string GetTableInfoListSql
+ {
+ get
+ {
+ return @"SELECT s.Name,Convert(varchar(max),tbp.value) as Description
+ FROM sysobjects s
+ LEFT JOIN sys.extended_properties as tbp ON s.id=tbp.major_id and tbp.minor_id=0 AND (tbp.Name='MS_Description' OR tbp.Name is null) WHERE s.xtype IN('U') ";
+ }
+ }
+ protected override string GetViewInfoListSql
+ {
+ get
+ {
+ return @"SELECT s.Name,Convert(varchar(max),tbp.value) as Description
+ FROM sysobjects s
+ LEFT JOIN sys.extended_properties as tbp ON s.id=tbp.major_id and tbp.minor_id=0 AND (tbp.Name='MS_Description' OR tbp.Name is null) WHERE s.xtype IN('V') ";
+ }
+ }
+ #endregion
+
+ #region DDL
+ protected override string CreateDataBaseSql
+ {
+ get
+ {
+ return @"create database {0} ";
+ }
+ }
+ protected override string AddPrimaryKeySql
+ {
+ get
+ {
+ return "ALTER TABLE {0} ADD CONSTRAINT {1} PRIMARY KEY({2})";
+ }
+ }
+ protected override string AddColumnToTableSql
+ {
+ get
+ {
+ return "ALTER TABLE {0} ADD {1} {2}{3} {4} {5} {6}";
+ }
+ }
+ protected override string AlterColumnToTableSql
+ {
+ get
+ {
+ return "ALTER TABLE {0} ALTER COLUMN {1} {2}{3} {4} {5} {6}";
+ }
+ }
+ protected override string BackupDataBaseSql
+ {
+ get
+ {
+ return @"USE master;BACKUP DATABASE {0} TO disk = '{1}'";
+ }
+ }
+ protected override string CreateTableSql
+ {
+ get
+ {
+ return "CREATE TABLE {0}(\r\n{1})";
+ }
+ }
+ protected override string CreateTableColumn
+ {
+ get
+ {
+ return "{0} {1}{2} {3} {4} {5}";
+ }
+ }
+ protected override string TruncateTableSql
+ {
+ get
+ {
+ return "TRUNCATE TABLE {0}";
+ }
+ }
+ protected override string BackupTableSql
+ {
+ get
+ {
+ return "SELECT TOP {0} * INTO {1} FROM {2}";
+ }
+ }
+ protected override string DropTableSql
+ {
+ get
+ {
+ return "DROP TABLE {0}";
+ }
+ }
+ protected override string DropColumnToTableSql
+ {
+ get
+ {
+ return "ALTER TABLE {0} DROP COLUMN {1}";
+ }
+ }
+ protected override string DropConstraintSql
+ {
+ get
+ {
+ return "ALTER TABLE {0} DROP CONSTRAINT {1}";
+ }
+ }
+ protected override string RenameColumnSql
+ {
+ get
+ {
+ return "exec sp_rename '{0}.{1}','{2}','column';";
+ }
+ }
+ protected override string AddColumnRemarkSql
+ {
+ get
+ {
+ return "EXECUTE sp_addextendedproperty N'MS_Description', N'{2}', N'user', N'dbo', N'table', N'{1}', N'column', N'{0}'"; ;
+ }
+ }
+
+ protected override string DeleteColumnRemarkSql
+ {
+ get
+ {
+ return "EXEC sp_dropextendedproperty 'MS_Description','user',dbo,'table','{1}','column','{0}'";
+ }
+
+ }
+
+ protected override string IsAnyColumnRemarkSql
+ {
+ get
+ {
+ return @"SELECT" +
+ " A.name AS table_name," +
+ " B.name AS column_name," +
+ " C.value AS column_description" +
+ " FROM sys.tables A" +
+ " LEFT JOIN sys.extended_properties C ON C.major_id = A.object_id" +
+ " LEFT JOIN sys.columns B ON B.object_id = A.object_id AND C.minor_id = B.column_id" +
+ " INNER JOIN sys.schemas SC ON SC.schema_id = A.schema_id AND SC.name = 'dbo'" +
+ " WHERE A.name = '{1}' and B.name = '{0}'";
+
+ }
+ }
+
+ protected override string AddTableRemarkSql
+ {
+ get
+ {
+ return "EXECUTE sp_addextendedproperty N'MS_Description', '{1}', N'user', N'dbo', N'table', N'{0}', NULL, NULL";
+ }
+ }
+
+ protected override string DeleteTableRemarkSql
+ {
+ get
+ {
+ return "EXEC sp_dropextendedproperty 'MS_Description','user',dbo,'table','{0}' ";
+ }
+
+ }
+
+ protected override string IsAnyTableRemarkSql
+ {
+ get
+ {
+ return @"SELECT C.class_desc
+ FROM sys.tables A
+ LEFT JOIN sys.extended_properties C ON C.major_id = A.object_id
+ INNER JOIN sys.schemas SC ON SC.schema_id=A.schema_id AND SC.name='dbo'
+ WHERE A.name = '{0}' AND minor_id=0";
+ }
+
+ }
+
+ protected override string RenameTableSql
+ {
+ get
+ {
+ return "EXEC sp_rename '{0}','{1}'";
+ }
+ }
+
+ protected override string CreateIndexSql
+ {
+ get
+ {
+ return "CREATE {3} NONCLUSTERED INDEX Index_{0}_{2} ON {0}({1})";
+ }
+ }
+ protected override string AddDefaultValueSql
+ {
+ get
+ {
+ return "alter table {0} ADD DEFAULT '{2}' FOR {1}";
+ }
+ }
+ protected override string IsAnyIndexSql
+ {
+ get
+ {
+ return "select count(*) from sys.indexes where name='{0}'";
+ }
+ }
+ #endregion
+
+ #region Check
+ protected override string CheckSystemTablePermissionsSql
+ {
+ get
+ {
+ return "select top 1 id from sysobjects";
+ }
+ }
+ #endregion
+
+ #region Scattered
+ protected override string CreateTableNull
+ {
+ get
+ {
+ return "NULL";
+ }
+ }
+ protected override string CreateTableNotNull
+ {
+ get
+ {
+ return "NOT NULL";
+ }
+ }
+ protected override string CreateTablePirmaryKey
+ {
+ get
+ {
+ return "PRIMARY KEY";
+ }
+ }
+ protected override string CreateTableIdentity
+ {
+ get
+ {
+ return "IDENTITY(1,1)";
+ }
+ }
+
+ #endregion
+
+ #region Methods
+ public override bool IsAnyTable(string tableName, bool isCache = true)
+ {
+ if (tableName.Contains("."))
+ {
+ var schemas = GetSchemas();
+ var first =this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').First());
+ var schemaInfo= schemas.FirstOrDefault(it=>it.EqualCase(first));
+ if (schemaInfo == null)
+ {
+ return base.IsAnyTable(tableName, isCache);
+ }
+ else
+ {
+ var result= this.Context.Ado.GetInt($"select object_id('{tableName}')");
+ return result > 0;
+ }
+ }
+ else
+ {
+ return base.IsAnyTable(tableName, isCache);
+ }
+ }
+ public List GetSchemas()
+ {
+ return this.Context.Ado.SqlQuery("SELECT name FROM sys.schemas where name <> 'dbo'");
+ }
+ public override bool DeleteTableRemark(string tableName)
+ {
+ string sql = string.Format(this.DeleteTableRemarkSql, tableName);
+ if (tableName.Contains("."))
+ {
+ var schemas = GetSchemas();
+ var tableSchemas = this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').First());
+ if (schemas.Any(y => y.EqualCase(tableSchemas)))
+ {
+ sql = string.Format(this.DeleteTableRemarkSql, this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').Last()));
+ if (tableSchemas.EqualCase("user"))
+ {
+ sql = sql.Replace("'user'", "'SCHEMA'").Replace("dbo", $"'{tableSchemas}'");
+ }
+ else
+ {
+ sql = sql.Replace(",dbo,", $",{tableSchemas},").Replace("'user'", "'SCHEMA'");
+ }
+ }
+ }
+ this.Context.Ado.ExecuteCommand(sql);
+ return true;
+ }
+ public override bool IsAnyTableRemark(string tableName)
+ {
+ string sql = string.Format(this.IsAnyTableRemarkSql, tableName);
+ if (tableName.Contains("."))
+ {
+ var schemas = GetSchemas();
+ var tableSchemas = this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').First());
+ if (schemas.Any(y => y.EqualCase(tableSchemas)))
+ {
+ sql = string.Format(this.IsAnyTableRemarkSql, this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').Last()));
+ sql = sql.Replace("'dbo'", $"'{tableSchemas}'");
+ }
+ }
+ var dt = this.Context.Ado.GetDataTable(sql);
+ return dt.Rows != null && dt.Rows.Count > 0;
+ }
+ public override bool AddTableRemark(string tableName, string description)
+ {
+ string sql = string.Format(this.AddTableRemarkSql, tableName, description);
+ if (tableName.Contains("."))
+ {
+ var schemas = GetSchemas();
+ var tableSchemas =this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').First());
+ if (schemas.Any(y => y.EqualCase(tableSchemas)))
+ {
+ sql = string.Format(this.AddTableRemarkSql, this.SqlBuilder.GetNoTranslationColumnName(tableName.Split('.').Last()), description);
+ if (tableSchemas.EqualCase("user"))
+ {
+ sql = sql.Replace("N'user', N'dbo'", $"N'user', '{tableSchemas}'").Replace("N'user'", "N'SCHEMA'");
+ }
+ else
+ {
+ sql = sql.Replace("N'dbo'", $"N'{tableSchemas}'").Replace("N'user'", "N'SCHEMA'");
+ }
+ }
+ }
+ this.Context.Ado.ExecuteCommand(sql);
+ return true;
+ }
+ public override bool AddDefaultValue(string tableName, string columnName, string defaultValue)
+ {
+ if (defaultValue == "''")
+ {
+ defaultValue = "";
+ }
+ var template = AddDefaultValueSql;
+ if (defaultValue != null && defaultValue.ToLower() == "getdate()")
+ {
+ template = template.Replace("'{2}'", "{2}");
+ }
+ string sql = string.Format(template, tableName, columnName, defaultValue);
+ this.Context.Ado.ExecuteCommand(sql);
+ return true;
+ }
+
+ ///
+ ///by current connection string
+ ///
+ ///
+ ///
+ public override bool CreateDatabase(string databaseName, string databaseDirectory = null)
+ {
+ if (databaseDirectory != null)
+ {
+ try
+ {
+ if (!FileHelper.IsExistDirectory(databaseDirectory))
+ {
+ FileHelper.CreateDirectory(databaseDirectory);
+ }
+ }
+ catch
+ {
+ //Databases and sites are not in the same service
+ }
+ }
+ var oldDatabaseName = this.Context.Ado.Connection.Database;
+ var connection = this.Context.CurrentConnectionConfig.ConnectionString;
+ connection = connection.Replace(oldDatabaseName, "master");
+ var newDb = new SqlSugarClient(new ConnectionConfig()
+ {
+ DbType = this.Context.CurrentConnectionConfig.DbType,
+ IsAutoCloseConnection = true,
+ ConnectionString = connection
+ });
+ if (!GetDataBaseList(newDb).Any(it => it.Equals(databaseName, StringComparison.CurrentCultureIgnoreCase)))
+ {
+ var sql = CreateDataBaseSql;
+ if (databaseDirectory.HasValue())
+ {
+ sql += @"on primary
+ (
+ name = N'{0}',
+ filename = N'{1}\{0}.mdf',
+ size = 10mb,
+ maxsize = 100mb,
+ filegrowth = 1mb
+ ),
+ (
+ name = N'{0}_ndf',
+ filename = N'{1}\{0}.ndf',
+ size = 10mb,
+ maxsize = 100mb,
+ filegrowth = 10 %
+ )
+ log on
+ (
+ name = N'{0}_log',
+ filename = N'{1}\{0}.ldf',
+ size = 100mb,
+ maxsize = 1gb,
+ filegrowth = 10mb
+ ); ";
+ }
+ if (databaseName.Contains("."))
+ {
+ databaseName = $"[{databaseName}]";
+ }
+ newDb.Ado.ExecuteCommand(string.Format(sql, databaseName, databaseDirectory));
+ }
+ return true;
+ }
+ public override bool CreateTable(string tableName, List columns, bool isCreatePrimaryKey = true)
+ {
+ tableName = this.SqlBuilder.GetTranslationTableName(tableName);
+ foreach (var item in columns)
+ {
+ if (item.DataType == "decimal" && item.DecimalDigits == 0 && item.Length == 0)
+ {
+ item.DecimalDigits = 4;
+ item.Length = 18;
+ }
+ }
+ string sql = GetCreateTableSql(tableName, columns);
+ this.Context.Ado.ExecuteCommand(sql);
+ if (isCreatePrimaryKey)
+ {
+ var pkColumns = columns.Where(it => it.IsPrimarykey).ToList();
+ if (pkColumns.Count > 1)
+ {
+ this.Context.DbMaintenance.AddPrimaryKeys(tableName, pkColumns.Select(it => it.DbColumnName).ToArray());
+ }
+ else
+ {
+ foreach (var item in pkColumns)
+ {
+ this.Context.DbMaintenance.AddPrimaryKey(tableName, item.DbColumnName);
+ }
+ }
+ }
+ return true;
+ }
+ public override List GetColumnInfosByTableName(string tableName, bool isCache = true)
+ {
+ tableName = SqlBuilder.GetNoTranslationColumnName(tableName);
+ var result= base.GetColumnInfosByTableName(tableName, isCache);
+ return result;
+ }
+ public override bool RenameColumn(string tableName, string oldColumnName, string newColumnName)
+ {
+ tableName = this.SqlBuilder.GetTranslationTableName(tableName);
+ oldColumnName = this.SqlBuilder.GetTranslationColumnName(oldColumnName);
+ newColumnName = this.SqlBuilder.GetNoTranslationColumnName(newColumnName);
+ string sql = string.Format(this.RenameColumnSql, tableName, oldColumnName, newColumnName);
+ this.Context.Ado.ExecuteCommand(sql);
+ return true;
+ }
+ #endregion
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/GBaseProvider.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/GBaseProvider.cs
new file mode 100644
index 000000000..1b95f9e7c
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/GBaseProvider.cs
@@ -0,0 +1,184 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.Common;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Xml.Linq;
+using System.Data.Odbc;
+namespace SqlSugar.GBase
+{
+ public class GBaseProvider : AdoProvider
+ {
+ public GBaseProvider() { }
+ public override IDbConnection Connection
+ {
+ get
+ {
+ if (base._DbConnection == null)
+ {
+ try
+ {
+ base._DbConnection = new OdbcConnection(base.Context.CurrentConnectionConfig.ConnectionString);
+ }
+ catch (Exception ex)
+ {
+ throw ex;
+ }
+ }
+ return base._DbConnection;
+ }
+ set
+ {
+ base._DbConnection = value;
+ }
+ }
+ ///
+ /// Only GBase
+ ///
+ ///
+ public override void BeginTran(string transactionName)
+ {
+ CheckConnection();
+ base.Transaction = ((OdbcConnection)this.Connection).BeginTransaction();
+ }
+ ///
+ /// Only GBase
+ ///
+ ///
+ ///
+ public override void BeginTran(IsolationLevel iso, string transactionName)
+ {
+ CheckConnection();
+ base.Transaction = ((OdbcConnection)this.Connection).BeginTransaction(iso);
+ }
+ public override IDataAdapter GetAdapter()
+ {
+ return new GBaseDataAdapter();
+ }
+ public override DbCommand GetCommand(string sql, SugarParameter[] parameters)
+ {
+ OdbcCommand sqlCommand = new OdbcCommand(sql, (OdbcConnection)this.Connection);
+ sqlCommand.CommandType = this.CommandType;
+ sqlCommand.CommandTimeout = this.CommandTimeOut;
+ if (this.Transaction != null)
+ {
+ sqlCommand.Transaction = (OdbcTransaction)this.Transaction;
+ }
+ if (parameters.HasValue())
+ {
+ OdbcParameter[] ipars = GetSqlParameter(parameters);
+ sqlCommand.Parameters.AddRange(ipars);
+ }
+ CheckConnection();
+ return sqlCommand;
+ }
+ public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command)
+ {
+ ((GBaseDataAdapter)dataAdapter).SelectCommand = (OdbcCommand)command;
+ }
+ ///
+ /// if mysql return MySqlParameter[] pars
+ /// if sqlerver return SqlParameter[] pars ...
+ ///
+ ///
+ ///
+ public override IDataParameter[] ToIDbDataParameter(params SugarParameter[] parameters)
+ {
+ if (parameters == null || parameters.Length == 0) return new OdbcParameter[] { };
+ OdbcParameter[] result = new OdbcParameter[parameters.Length];
+ int index = 0;
+ foreach (var parameter in parameters)
+ {
+ if (parameter.Value == null) parameter.Value = DBNull.Value;
+ var sqlParameter = new OdbcParameter();
+ sqlParameter.ParameterName = parameter.ParameterName;
+ //sqlParameter.UdtTypeName = parameter.UdtTypeName;
+ sqlParameter.Size = parameter.Size;
+ sqlParameter.Value = parameter.Value;
+ sqlParameter.DbType = parameter.DbType;
+ sqlParameter.Direction = parameter.Direction;
+ result[index] = sqlParameter;
+ if (sqlParameter.Direction.IsIn(ParameterDirection.Output, ParameterDirection.InputOutput,ParameterDirection.ReturnValue))
+ {
+ if (this.OutputParameters == null) this.OutputParameters = new List();
+ this.OutputParameters.RemoveAll(it => it.ParameterName == sqlParameter.ParameterName);
+ this.OutputParameters.Add(sqlParameter);
+ }
+ ++index;
+ }
+ return result;
+ }
+ ///
+ /// if mysql return MySqlParameter[] pars
+ /// if sqlerver return SqlParameter[] pars ...
+ ///
+ ///
+ ///
+ public OdbcParameter[] GetSqlParameter(params SugarParameter[] parameters)
+ {
+ if (parameters == null || parameters.Length == 0) return null;
+ OdbcParameter[] result = new OdbcParameter[parameters.Length];
+ int index = 0;
+ foreach (var parameter in parameters)
+ {
+ if (parameter.Value == null) parameter.Value = DBNull.Value;
+ var sqlParameter = new OdbcParameter();
+ sqlParameter.ParameterName = parameter.ParameterName;
+ //sqlParameter.UdtTypeName = parameter.UdtTypeName;
+ sqlParameter.Size = parameter.Size;
+ sqlParameter.Value = parameter.Value;
+ sqlParameter.DbType = GetDbType(parameter);
+ var isTime = parameter.DbType == System.Data.DbType.Time;
+ if (isTime)
+ {
+ sqlParameter.Value = DateTime.Parse(parameter.Value?.ToString()).TimeOfDay;
+ }
+ if (sqlParameter.Value != null && sqlParameter.Value != DBNull.Value && sqlParameter.DbType == System.Data.DbType.DateTime)
+ {
+ var date = Convert.ToDateTime(sqlParameter.Value);
+ if (date == DateTime.MinValue)
+ {
+ sqlParameter.Value = UtilMethods.GetMinDate(this.Context.CurrentConnectionConfig);
+ }
+ }
+ if (parameter.Direction == 0)
+ {
+ parameter.Direction = ParameterDirection.Input;
+ }
+ sqlParameter.Direction = parameter.Direction;
+ result[index] = sqlParameter;
+ if (sqlParameter.Direction.IsIn(ParameterDirection.Output, ParameterDirection.InputOutput, ParameterDirection.ReturnValue))
+ {
+ if (this.OutputParameters == null) this.OutputParameters = new List();
+ this.OutputParameters.RemoveAll(it => it.ParameterName == sqlParameter.ParameterName);
+ this.OutputParameters.Add(sqlParameter);
+ }
+
+ ++index;
+ }
+ return result;
+ }
+
+ private static System.Data.DbType GetDbType(SugarParameter parameter)
+ {
+ if (parameter.DbType==System.Data.DbType.UInt16)
+ {
+ return System.Data.DbType.Int16;
+ }
+ else if (parameter.DbType == System.Data.DbType.UInt32)
+ {
+ return System.Data.DbType.Int32;
+ }
+ else if (parameter.DbType == System.Data.DbType.UInt64)
+ {
+ return System.Data.DbType.Int64;
+ }
+ else
+ {
+ return parameter.DbType;
+ }
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/Queryable/GBaseQueryable.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/Queryable/GBaseQueryable.cs
new file mode 100644
index 000000000..d84a7186a
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/Queryable/GBaseQueryable.cs
@@ -0,0 +1,58 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Text;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseQueryable:QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+ public class GBaseQueryable : QueryableProvider
+ {
+
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBlukCopy.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBlukCopy.cs
new file mode 100644
index 000000000..56a4a3a82
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBlukCopy.cs
@@ -0,0 +1,154 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using Microsoft.Data.SqlClient;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseBlukCopy
+ {
+ internal List> DbColumnInfoList { get; set; }
+ internal SqlSugarProvider Context { get; set; }
+ internal ISqlBuilder Builder { get; set; }
+ internal InsertBuilder InsertBuilder { get; set; }
+ internal object[] Inserts { get; set; }
+
+ public int ExecuteBulkCopy()
+ {
+ if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0;
+
+ if (Inserts.First().GetType() == typeof(DataTable))
+ {
+ return WriteToServer();
+ }
+ DataTable dt = GetCopyData();
+ SqlBulkCopy bulkCopy = GetBulkCopyInstance();
+ bulkCopy.DestinationTableName = InsertBuilder.GetTableNameString;
+ try
+ {
+ bulkCopy.WriteToServer(dt);
+ }
+ catch (Exception ex)
+ {
+ CloseDb();
+ throw ex;
+ }
+ CloseDb();
+ return DbColumnInfoList.Count;
+ }
+
+ public async Task ExecuteBulkCopyAsync()
+ {
+ if (DbColumnInfoList == null || DbColumnInfoList.Count == 0) return 0;
+
+ if (Inserts.First().GetType() == typeof(DataTable))
+ {
+ return WriteToServer();
+ }
+ DataTable dt=GetCopyData();
+ SqlBulkCopy bulkCopy = GetBulkCopyInstance();
+ bulkCopy.DestinationTableName = InsertBuilder.GetTableNameString;
+ try
+ {
+ await bulkCopy.WriteToServerAsync(dt);
+ }
+ catch (Exception ex)
+ {
+ CloseDb();
+ throw ex;
+ }
+ CloseDb();
+ return DbColumnInfoList.Count;
+ }
+
+ private int WriteToServer()
+ {
+ var dt = this.Inserts.First() as DataTable;
+ if (dt == null)
+ return 0;
+ Check.Exception(dt.TableName == "Table", "dt.TableName can't be null ");
+ dt = GetCopyWriteDataTable(dt);
+ SqlBulkCopy copy = GetBulkCopyInstance();
+ copy.DestinationTableName = this.Builder.GetTranslationColumnName(dt.TableName);
+ copy.WriteToServer(dt);
+ CloseDb();
+ return dt.Rows.Count;
+ }
+ private DataTable GetCopyWriteDataTable(DataTable dt)
+ {
+ var result = this.Context.Ado.GetDataTable("select top 0 * from " + this.Builder.GetTranslationColumnName(dt.TableName));
+ foreach (DataRow item in dt.Rows)
+ {
+ DataRow dr= result.NewRow();
+ foreach (DataColumn column in result.Columns)
+ {
+
+ if (dt.Columns.Cast().Select(it => it.ColumnName.ToLower()).Contains(column.ColumnName.ToLower()))
+ {
+ dr[column.ColumnName] = item[column.ColumnName];
+ if (dr[column.ColumnName] == null)
+ {
+ dr[column.ColumnName] = DBNull.Value;
+ }
+ }
+ }
+ result.Rows.Add(dr);
+ }
+ result.TableName = dt.TableName;
+ return result;
+ }
+ private SqlBulkCopy GetBulkCopyInstance()
+ {
+ SqlBulkCopy copy;
+ if (this.Context.Ado.Transaction == null)
+ {
+ copy = new SqlBulkCopy((SqlConnection)this.Context.Ado.Connection);
+ }
+ else
+ {
+ copy = new SqlBulkCopy((SqlConnection)this.Context.Ado.Connection, SqlBulkCopyOptions.CheckConstraints, (SqlTransaction)this.Context.Ado.Transaction);
+ }
+ if (this.Context.Ado.Connection.State == ConnectionState.Closed)
+ {
+ this.Context.Ado.Connection.Open();
+ }
+ copy.BulkCopyTimeout = this.Context.Ado.CommandTimeOut;
+ return copy;
+ }
+ private DataTable GetCopyData()
+ {
+ var dt = this.Context.Ado.GetDataTable("select top 0 * from " + InsertBuilder.GetTableNameString);
+ foreach (var rowInfos in DbColumnInfoList)
+ {
+ var dr = dt.NewRow();
+ foreach (var value in rowInfos)
+ {
+ if (value.Value != null && UtilMethods.GetUnderType(value.Value.GetType()) == UtilConstants.DateType)
+ {
+ if (value.Value != null && value.Value.ToString() == DateTime.MinValue.ToString())
+ {
+ value.Value = Convert.ToDateTime("1753/01/01");
+ }
+ }
+ if (value.Value == null)
+ {
+ value.Value = DBNull.Value;
+ }
+ dr[value.DbColumnName] = value.Value;
+ }
+ dt.Rows.Add(dr);
+ }
+ return dt;
+ }
+ private void CloseDb()
+ {
+ if (this.Context.CurrentConnectionConfig.IsAutoCloseConnection && this.Context.Ado.Transaction == null)
+ {
+ this.Context.Ado.Connection.Close();
+ }
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBuilder.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBuilder.cs
new file mode 100644
index 000000000..6b8651c63
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseBuilder.cs
@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Text.RegularExpressions;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseBuilder : SqlBuilderProvider
+ {
+ public override string SqlTranslationLeft { get { return "["; } }
+ public override string SqlTranslationRight { get { return "]"; } }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseDeleteBuilder.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseDeleteBuilder.cs
new file mode 100644
index 000000000..da9195ddf
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseDeleteBuilder.cs
@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseDeleteBuilder: DeleteBuilder
+ {
+
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseExpressionContext.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseExpressionContext.cs
new file mode 100644
index 000000000..518f2ec23
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseExpressionContext.cs
@@ -0,0 +1,58 @@
+using System;
+using System.Collections.Generic;
+using System.Collections.ObjectModel;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Reflection;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public partial class GBaseExpressionContext : ExpressionContext, ILambdaExpressions
+ {
+ public SqlSugarProvider Context { get; set; }
+ public GBaseExpressionContext()
+ {
+ base.DbMehtods = new GBaseMethod();
+ }
+
+ }
+ public partial class GBaseMethod : DefaultDbMethod, IDbMethods
+ {
+ public override string GetForXmlPath()
+ {
+ return " FOR XML PATH('')),1,len(N','),'') ";
+ }
+ public override string GetStringJoinSelector(string result, string separator)
+ {
+ return $"stuff((SELECT cast(N'{separator}' as nvarchar(max)) + cast({result} as nvarchar(max))";
+ }
+ public override string DateValue(MethodCallExpressionModel model)
+ {
+ var parameter = model.Args[0];
+ var parameter2 = model.Args[1];
+ if (parameter.MemberName != null && parameter.MemberName is DateTime)
+ {
+ return string.Format(" datepart({0},'{1}') ", parameter2.MemberValue, parameter.MemberName);
+ }
+ else
+ {
+ return string.Format(" datepart({0},{1}) ", parameter2.MemberValue, parameter.MemberName);
+ }
+ }
+ public override string HasValue(MethodCallExpressionModel model)
+ {
+ if (model.Args[0].Type == UtilConstants.GuidType)
+ {
+ var parameter = model.Args[0];
+ return string.Format("( {0} IS NOT NULL )", parameter.MemberName);
+ }
+ else
+ {
+ var parameter = model.Args[0];
+ return string.Format("( {0}<>'' AND {0} IS NOT NULL )", parameter.MemberName);
+ }
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseFastBuilder.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseFastBuilder.cs
new file mode 100644
index 000000000..236822aa3
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseFastBuilder.cs
@@ -0,0 +1,56 @@
+using Microsoft.Data.SqlClient;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.SqlClient;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+
+ public class GBaseFastBuilder:FastBuilder,IFastBuilder
+ {
+ public override bool IsActionUpdateColumns { get; set; } = true;
+ public override DbFastestProperties DbFastestProperties { get; set; } = new DbFastestProperties() {
+ HasOffsetTime=true
+ };
+ public async Task ExecuteBulkCopyAsync(DataTable dt)
+ {
+
+ SqlBulkCopy bulkCopy = GetBulkCopyInstance();
+ bulkCopy.DestinationTableName = dt.TableName;
+ try
+ {
+ await bulkCopy.WriteToServerAsync(dt);
+ }
+ catch (Exception ex)
+ {
+ CloseDb();
+ throw ex;
+ }
+ CloseDb();
+ return dt.Rows.Count;
+ }
+ public SqlBulkCopy GetBulkCopyInstance()
+ {
+ SqlBulkCopy copy;
+ if (this.Context.Ado.Transaction == null)
+ {
+ copy = new SqlBulkCopy((SqlConnection)this.Context.Ado.Connection);
+ }
+ else
+ {
+ copy = new SqlBulkCopy((SqlConnection)this.Context.Ado.Connection, SqlBulkCopyOptions.CheckConstraints, (SqlTransaction)this.Context.Ado.Transaction);
+ }
+ if (this.Context.Ado.Connection.State == ConnectionState.Closed)
+ {
+ this.Context.Ado.Connection.Open();
+ }
+ copy.BulkCopyTimeout = this.Context.Ado.CommandTimeOut;
+ return copy;
+ }
+
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseInsertBuilder.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseInsertBuilder.cs
new file mode 100644
index 000000000..18e5a7d2e
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseInsertBuilder.cs
@@ -0,0 +1,66 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseInsertBuilder:InsertBuilder
+ {
+ public override string ToSqlString()
+ {
+ if (IsNoInsertNull)
+ {
+ DbColumnInfoList = DbColumnInfoList.Where(it => it.Value != null).ToList();
+ }
+ var groupList = DbColumnInfoList.GroupBy(it => it.TableId).ToList();
+ var isSingle = groupList.Count() == 1;
+ string columnsString = string.Join(",", groupList.First().Select(it => Builder.GetTranslationColumnName(it.DbColumnName)));
+ if (isSingle)
+ {
+ string columnParametersString = string.Join(",", this.DbColumnInfoList.Select(it => Builder.SqlParameterKeyWord + it.DbColumnName));
+ return string.Format(SqlTemplate, GetTableNameString, columnsString, columnParametersString);
+ }
+ else
+ {
+ StringBuilder batchInsetrSql = new StringBuilder();
+ int pageSize = 200;
+ if (this.EntityInfo.Columns.Count > 30)
+ {
+ pageSize = 50;
+ }
+ else if (this.EntityInfo.Columns.Count > 20)
+ {
+ pageSize = 100;
+ }
+ int pageIndex = 1;
+ int totalRecord = groupList.Count;
+ int pageCount = (totalRecord + pageSize - 1) / pageSize;
+ while (pageCount >= pageIndex)
+ {
+ batchInsetrSql.AppendFormat(SqlTemplateBatch, GetTableNameString, columnsString);
+ int i = 0;
+ foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList())
+ {
+ var isFirst = i == 0;
+ if (!isFirst)
+ {
+ batchInsetrSql.Append(SqlTemplateBatchUnion);
+ }
+ batchInsetrSql.Append("\r\n SELECT " + string.Join(",", columns.Select(it => string.Format(SqlTemplateBatchSelect, FormatValue(it.Value), Builder.GetTranslationColumnName(it.DbColumnName)))));
+ ++i;
+ }
+ pageIndex++;
+ batchInsetrSql.Append("\r\n;\r\n");
+ }
+ var result = batchInsetrSql.ToString();
+ if (this.Context.CurrentConnectionConfig.DbType == DbType.GBase)
+ {
+ result += "select SCOPE_IDENTITY();";
+ }
+ return result;
+ }
+ }
+ }
+}
diff --git a/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseQueryBuilder.cs b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseQueryBuilder.cs
new file mode 100644
index 000000000..0b4cf2f8e
--- /dev/null
+++ b/Src/Asp.NetCore2/SqlSugar.GBaseCore/GBase/SqlBuilder/GBaseQueryBuilder.cs
@@ -0,0 +1,122 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SqlSugar.GBase
+{
+ public class GBaseQueryBuilder: QueryBuilder
+ {
+ public override string SqlTemplate
+ {
+ get
+ {
+ return "SELECT {0}{"+UtilConstants.ReplaceKey+"} FROM {1}{2}{3}{4}";
+ }
+ }
+ public override string ToSqlString()
+ {
+ var oldTake = Take;
+ var oldSkip = Skip;
+ var isDistinctPage = IsDistinct && (Take > 1 || Skip > 1);
+ if (isDistinctPage)
+ {
+ Take = null;
+ Skip = null;
+ }
+ var result = _ToSqlString();
+ if (isDistinctPage)
+ {
+ if (this.OrderByValue.HasValue())
+ {
+ Take = int.MaxValue;
+ result = result.Replace("DISTINCT", $" DISTINCT TOP {int.MaxValue} ");
+ }
+ Take = oldTake;
+ Skip = oldSkip;
+ result =this.Context.SqlQueryable