一个可用于生产项目 基于 .NET 6 自研ORM

Fast Framework

作者 Mr-zhong

代码改变世界….

一、前言

Fast Framework 基于NET6.0 封装的轻量级 ORM 框架 支持多种数据库 SqlServer Oracle MySql PostgreSql Sqlite

优点： 体积小、可动态切换不同实现类库、原生支持微软特性、流畅API、使用简单、性能高、模型数据绑定采用 委托、强大的表达式解析、支持多种子查询可实现较为复杂查询、源代码可读性强。

缺点：目前仅支持Db Frist Code Frist 后续迭代。

开源地址 https://github.com/China-Mr-zhong/Fast.Framework （唯一）

目前作者已使用该框架应用多个生产项目

个别亮点功能：数值类型绑定自动格式化小数点后面多余的0、表达式参数名称自动编排 无需强制统一参数名称

本作者不提供任何性能对比数据，请各位感兴趣的自行测试，对比前建议预热连接

二、项目明细

名称	说明
Fast.Framework	框架主项目
Fast.Framework.Logging	基于微软接口实现的文件日志(非必要可不引用)
Fast.Framework.Test	控制台测试项目
Fast.Framework.UnitTest	单元测试项目
Fast.Framework.Web.Test	Web测试项目

三、核心对象

• Ado 原生Ado对象

                  IAdo ado = new AdoProvider(new DbOptions()
                  {
                      DbId = "1",
                      DbType = DbType.MySQL,
                      ProviderName = "MySqlConnector",
                      FactoryName = "MySqlConnector.MySqlConnectorFactory,MySqlConnector",
                      ConnectionStrings = "server=localhost;database=Test;user=root;pwd=123456789;port=3306;min pool size=3;max pool size=100;connect timeout=30;"
                  });
  

• DbContext 支持多租户 支持切换不同Ado实现类库 设置 ProviderName和FactoryName 即可

                  IDbContext db = new DbContext(new List() {
                  new DbOptions()
                  {
                      DbId = "1",
                      DbType = DbType.MySQL,
                      ProviderName = "MySqlConnector",
                      FactoryName = "MySqlConnector.MySqlConnectorFactory,MySqlConnector",
                      ConnectionStrings = "server=localhost;database=Test;user=root;pwd=123456789;port=3306;min pool size=3;max pool size=100;connect timeout=30;"
                  }});
  

• DbOptions Json文件配置格式

  "DbOptions": [
      {
        "DbId": 1,
        "DbType": "SQLServer",
        "ProviderName": "System.Data.SqlClient",
        "FactoryName": "System.Data.SqlClient.SqlClientFactory,System.Data",
        "ConnectionStrings": "server=localhost;database=Test;user=sa;pwd=123456789;min pool size=3;max pool size=100;connect timeout=120;"
      }]
  

• Asp.net Core 依赖注入

  // 注册服务 
  var builder = WebApplication.CreateBuilder(args);
  
  // 添加数据库上下文
  builder.Services.AddFastDbContext();
  
  // 从Json配置文件加载数据库选项
  builder.Services.Configure>(builder.Configuration.GetSection("DbOptions"));
  
  // 产品服务类 通过构造方法注入
  public class ProductService
  {
      /// 
  
      /// 数据库
      /// 
      private readonly IDbContext db;
  
      /// 
  
      /// 构造方法
      /// 
      /// 数据库
      public ProductService(IDbContext db)
      {
          this.db = db;
      }
  }
  

四、插入

• 实体对象插入

              var product = new Product()
              {
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              var result = db.Insert(product).Exceute();
              Console.WriteLine($"实体对象插入 受影响行数 {result}");
  

• 实体对象插入并返回自增ID 仅支持 SQLServer MySQL SQLite

              var product = new Product()
              {
                  ProductCode = "1001",
                  ProductName = "测试产品1"
              };
              var result = db.Insert(product).ExceuteReturnIdentity();
              Console.WriteLine($"实体对象插入 返回自增ID {result}");
  

• 实体对象列表插入

              var list = new List();
              for (int i = 0; i 

• 匿名对象插入

              var obj = new
              {
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              //注意:需要使用As方法显示指定表名称
              var result = db.Insert(obj).As("Product").Exceute();
              Console.WriteLine($"匿名对象插入 受影响行数 {result}");
  

• 匿名对象列表插入

              var list = new List

• 字典插入

              var product = new Dictionary()
              {
                  {"ProductCode","1001"},
                  { "ProductName","测试商品1"}
              };
              var result = db.Insert(product).As("Product").Exceute();
              Console.WriteLine($"字典插入 受影响行数 {result}");
  

• 字典列表插入

              var list = new List>();
              for (int i = 0; i ()
                  {
                      {"ProductCode","1001"},
                      { "ProductName","测试商品1"}
                   });
              }
              var result = db.Insert(list).As("Product").Exceute();
              Console.WriteLine($"字典列表插入 受影响行数 {result}");
  

五、删除

• 实体对象删除

              var product = new Product()
              {
                  ProductId = 1,
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              //注意:必须标记KeyAuttribute特性 否则将抛出异常
              var result = db.Delete(product).Exceute();
              Console.WriteLine($"实体删除 受影响行数 {result}");
  

• 无条件删除

              var result = db.Delete().Exceute();
              Console.WriteLine($"无条件删除 受影响行数 {result}");
  

• 表达式删除

              var result = await db.Delete().Where(w => w.ProductId == 1).ExceuteAsync();
              Console.WriteLine($"条件删除 受影响行数 {result}");
  

• 特殊删除

  			      //特殊用法 如需单个条件或多个可搭配 WhereColumn或WhereColumns方法
              var result = await db.Delete

六、更新

• 实体对象更新

              var product = new Product()
              {
                  ProductId = 1,
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              //注意:标记KeyAuttribute特性属性或使用Where条件，为了安全起见全表更新将必须使用Where方法
              var result = db.Update(product).Exceute();
              Console.WriteLine($"对象更新 受影响行数 {result}");
  

• 指定列更新

              var result = db.Update(new Product() { ProductCode = "1001", ProductName = "1002" }).Columns("ProductCode", "ProductName").Exceute();
  						// 字段很多的话可以直接new List(){"列1","列2"}
  

• 忽略列更新

              var result = db.Update(new Product() { ProductCode = "1001", ProductName = "1002" }).IgnoreColumns("Custom1").Exceute();
              // 同上使用方法一样
  

• 实体对象列表更新

              var list = new List();
              for (int i = 0; i 

• 匿名对象更新

              var obj = new
              {
                  ProductId = 1,
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              //注意:需要显示指定表名称 以及更新条件 使用 Where或者WhereColumns方法均可
              var result = db.Update(obj).As("product").WhereColumns("ProductId").Exceute();
              Console.WriteLine($"匿名对象更新 受影响行数 {result}");
  

• 匿名对象列表更新

              var list = new List

• 字典更新

              var product = new Dictionary()
              {
                  { "ProductId",1},
                  {"ProductCode","1001"},
                  { "ProductName","测试商品1"}
              };
              var result = db.Update(product).As("Product").WhereColumns("ProductId").Exceute();
              Console.WriteLine($"字典更新 受影响行数 {result}");
  

• 字典列表更新

              var list = new List>();
              for (int i = 0; i ()
                  {
                      { "ProductId",i+1},
                      {"ProductCode",$"更新编号:{i+1}"},
                      { "ProductName",$"更新商品:{i + 1}"}
                  });
              }
              var result = db.Update(list).As("Product").WhereColumns("ProductId").Exceute();
              Console.WriteLine($"字典列表更新 受影响行数 {result}");
  

• 指定条件更新

              var product = new Product()
              {
                  ProductId = 1,
                  ProductCode = "1001",
                  ProductName = "测试商品1"
              };
              var result = db.Update(product).Where(p => p.ProductId == 100).Exceute();
              Console.WriteLine($"表达式更新 受影响行数 {result}");
  

• 并发更新 乐观锁-版本控制

                  //注意:仅支持非列表更新 版本列数据类型仅支持 object、string、Guid 时间类型存在精度丢失所以不做支持
  				var obj = db.Query().Where(w => w.ProductId == 1).Frist();
                  obj.Custom1 = "测试版本控制修改";
  				//参数为 true 更新失败将抛出异常
                  var result = db.Update(obj).ExceuteWithOptLock(true);
  

七、查询

• 单一查询

              var data = db.Query().First();
  

• 列表查询

              var data = db.Query().ToList();
  

• 返回单个字典

              var data = db.Query().ToDictionary();
  

• 返回字典列表

              var data = db.Query().ToDictionaryList();
  

• 分页查询

              //分页查询不返回总数
              var data = db.Query().ToPageList(1,100);
              //分页查询返回总数
  			var total = 0;//定义总数变量
  			var data = db.Query().ToPageList(1, 1, ref total);
              Console.WriteLine($"总数：{total}");
  

• 计数查询

              var data = db.Query().Count();
  

• 任何查询

              var data = db.Query().Any();
  

• 条件查询

              var data = db.Query().Where(w => w.ProductId == 1).ToList;
  

• Like 查询

              var data = db.Query().Where(w => w.ProductName.StartsWith("左模糊") || w.ProductName.EndsWith("右模糊") || w.ProductName.Contains("全模糊")).ToList();
  

• Not Like查询

  var data = db.Query().Where(w => !w.ProductName.StartsWith("左模糊") || !w.ProductName.EndsWith("右模糊") || !w.ProductName.Contains("全模糊")).ToList();
  

• Select查询 (选择字段)

              var data = db.Query().Select(s => new
              {
                  s.ProductId,
                  s.ProductName
              }).ToList();
  

• Select查询 (Case When)

                  var data = db.Query().Select(s => new
                  {
                      CaseTest1 = SqlFunc.Case(s.Custom1).When("1").Then("xx1").When("2").Then("xx2").Else("xx3").End(),
                      CaseTest2 = SqlFunc.CaseWhen(s.Custom1 == "1").Then("xx1").When(s.Custom1 == "2").Then("xx2").Else("xx3").End()
                  }).ToList();
  

• 分组查询

              var data = db.Query().GroupBy(s => new
              {
                  s.ProductId,
                  s.ProductName
              }).ToList();
  

• 分组聚合查询

              var sql = db.Query().InnerJoin((a, b) => a.OrderId == b.OrderId).GroupBy((a, b) => new
              {
                  a.OrderCode
              }).Select((a, b) => new
              {
                  a.OrderCode,
                  Sum_Qty = SqlFunc.Sum(b.Qty)//支持嵌套
              }).ToList();
  

• 排序查询

              var data = db.Query().OrderBy(s => new
              {
                  s.CreateTime
              }).ToList();
              //这是多个字段排序使用方法 还有其它重载方法
  

• Having查询

              var data = db.Query().GroupBy(s => new
              {
                  s.ProductId,
                  s.ProductName
              }).Having(s => SqlFunc.Count(s.ProductId) > 1).ToList();
              //必须先使用GroupBy方法 懂得都懂
  

• 联表查询

              var data = db.Query().LeftJoin((a, b) => a.ProductId == b.ProductId).ToList();
              // 右连接 RightJoin 内连接 InnerJoin 全连接 FullJoin
  

• 联合查询

              var query1 = db.Query();
              var query2 = db.Query();
              db.Union(query1, query2);//联合
              db.UnionAll(query1, query2);//全联合
              //执行查询调用Toxx方法
  

• 查询并插入 仅支持同实例的数据库 跨库 个人还是建议 用事务分开写查询和插入

                  //方式1
                  var result1 = db.Query().Where(w => w.ProductId == 1489087).Select(s => new
                  {
                      s.ProductCode,
                      s.ProductName
                  }).Insert(p => new
                  {
                      p.ProductCode,
                      p.ProductName
                  });
  
                  //方式2 需要注意的是 显示指定不带 列标识符 例如 `列名称1` 如有字段冲突 可自行加上标识符
                  var result2 = db.Query().Where(w => w.ProductId == 1489087).Select(s => new
                  {
                      s.ProductCode,
                      s.ProductName
                  }).Insert("表名称 同实例不同库 可以使用 db.数据库名称.表名称 ", "列名称1", "列名称2", "`带标识的列名称3`");
  
                  //方式3 需要注意同方式2 一样
                  var result3 = db.Query().Where(w => w.ProductId == 1489087).Select(s => new
                  {
                      s.ProductCode,
                      s.ProductName
                  }).Insert("表名称 同实例不同库 可以使用 db.数据库名称.表名称 ", new List() { "列名称1" });
  

• In查询

                  // 方式1
                  var data1 = db.Query().Where(w => SqlFunc.In(w.ProductCode, "1001", "1002")).ToList();
  
                  // 方式2
                  var data2 = db.Query().Where(w => SqlFunc.In(w.ProductCode, new List() { "123", "456" })).ToList();
  
                  // 方式3 需要动态更新IN值 使用这种
                  var list = new List() { "123", "456" };
                  var data3 = db.Query().Where(w => SqlFunc.In(w.ProductCode, list)).ToList();
  
                  // 方法4 参数同上一样 单独分离IN和NotIN 是为了兼容匿名查询
                  var data4 = db.Query().In("字段名称", "1001", "1002").ToList();
  

• Select子查询

                  var subQuery = db.Query().Where(w => w.ProductId == 1).Select(s => s.ProductName);
                  var sql1 = db.Query().Select(s => new Product()
                  {
                      Custom1 = db.SubQuery(subQuery)// SubQuery 的泛型是根据你左边赋值的属性类型来定义
                  }).ToList();
                  // 这种没有使用new 的 泛型可随意定义 实际作用就是避免 对象属性赋值类型冲突的问题
                  var sql2 = db.Query().Select(s => db.SubQuery(subQuery)).ToList();
  

• From子查询

                  var subQuery = db.Query();
                  var data = db.Query(subQuery).OrderBy(o => o.ProductCode).ToList();
  

• Join子查询

                  var subQuery = db.Query();
                  var data = db.Query().InnerJoin(subQuery, (a, b) => a.ProductId == b.ProductId).ToList();
  

• Include查询

                  // 联表条件 默认优先匹配主键 其次带有ID结尾的名称
                  var data = db.Query().Include(i => i.Products).ToList();
  

八、Lambda表达式

• 动态表达式 命名空间 Fast.Framework.Utils

                  var ex = DynamicWhereExp.Create().AndIF(1 == 1, a => a.DeleteMark == true).Build();
                  var data = db.Query().Where(ex).ToList();
  

• Sql函数 自定义函数 需引入命名空间 Fast.Framework.Utils

  • SqlServer

    • 类型转换

      方法名称	解析示例值	说明	自定义函数
      ToString	CONVERT( VARCHAR(255),123)	转换 VARCHAR	否
      ToDateTime	CONVERT( DATETIME,‘2022-09-16’)	转换 DATETIME	否
      ToDecimal	CONVERT( DECIMAL(10,6),‘123’)	转换 DECIMAL	否
      ToDouble	CONVERT( NUMERIC(10,6),‘123’)	转换 NUMERIC	否
      ToSingle	CONVERT( FLOAT,‘123’)	转换 FLOAT	否
      ToInt32	CONVERT( INT,‘123’)	转换 INT	否
      ToInt64	CONVERT( BIGINT,‘123’)	转换 BIGINT	否
      ToBoolean	CONVERT( BIT,‘1’)	转换 BIT	否
      ToChar	CONVERT( CHAR(2),’x’)	转换 CHAR	否

    • 聚合函数

      方法名称	解析示例值	说明	自定义函数
      Max	MAX( a.[xx] )	最大值	是
      Min	MIN( a.[xx] )	最小值	是
      Count	COUNT( a.[xx] )	计数	是
      Sum	SUM( a.[xx] )	合计	是
      Avg	AVG( a.[xx] )	平均	是

    • 数学函数

      方法名称	解析示例值	说明	自定义函数
      Abs	ABS( a.[xx] )	绝对值	是
      Round	ROUND( a.[xx] ,2 )	四舍五入	是

    • 字符串函数

      方法名称	解析示例值	说明	自定义函数
      StartsWith	LIKE ‘%’+’xx’	左模糊	否
      EndsWith	LIKE ‘xx’+‘%’	右模糊	否
      Contains	LIKE ‘%’+’xx’+‘%’	全模糊	否
      SubString	SUBSTRING( ‘xxxxxx’ ,1,3)	截取	否
      Replace	REPLACE( ‘xxx’,’x’,’y’)	替换	否
      Len	LEN( ‘xxx’ )	长度	是
      TrimStart	LTRIM( ‘ xx ‘ )	修剪起始空格	否
      TrimEnd	RTRIM( ‘ xx ‘ )	修剪末尾空格	否
      ToUpper	UPPER( ‘xx’ )	大写	否
      ToLower	LOWER( ‘xx’ )	小写	否
      Operation	CreateTime >= @Now_1	日期、数值、字符串范围比较	是

    • 日期函数

      方法名称	解析示例值	说明	自定义函数
      DateDiff	DATEDIFF( DAY ,a.[xx],b.[xx])	日期相差	是
      AddYears	DATEADD( YEAR,a.[xx],1 )	添加年份	否
      AddMonths	DATEADD( MONTH,a.[xx],1 )	添加月份	否
      AddDays	DATEADD( DAY,a.[xx],1 )	添加天数	否
      AddHours	DATEADD( HOUR,a.[xx],1 )	添加时	否
      AddMinutes	DATEADD( MINUTE,a.[xx],1 )	添加分	否
      AddSeconds	DATEADD( SECOND,a.[xx],1 )	添加秒	否
      AddMilliseconds	DATEADD( MILLISECOND,a.[xx],1 )	添加毫秒	否
      Year	YEAR( a.[xx] )	获取年份	是
      Month	MONTH( a.[xx] )	获取月份	是
      Day	DAY( a.[xx] )	获取天数	是

    • 查询函数

      方法名称	解析示例值	说明	自定义函数
      In	IN ( a.[xx] ,’x1′,’x2′,’x3′)	In查询	是
      NotIn	NOT IN ( a.[xx] ,’x1′,’x2′,’x3′)	Not In查询	是

    • 其它函数

      方法名称	解析示例值	说明	自定义函数
      NewGuid	NEWID()	获取GUID	否
      Equals	p.[ProductCode] = ‘123’	比较	否
      IsNull	ISNULL(a.[xx],0)	是否为空	是
      Case	CASE	case	是
      When	WHEN	when	是
      Then	THEN	then	是
      Else	ELSE	else	是
      End	END	end	是

  • MySql

    • 类型转换

      方法名称	解析示例值	说明	自定义函数
      ToString	CAST( a.`xx` AS CHAR(510) )	转换 CHAR(510)	否
      ToDateTime	CAST( a.`xx` AS DATETIME )	转换 DATETIME	否
      ToDecimal	CAST( a.`xx` AS DECIMAL(10,6) )	转换 DECIMAL(10,6)	否
      ToDouble	CAST( a.`xx` AS DECIMAL(10,6) )	转换 DECIMAL(10,6)	否
      ToInt32	CAST( a.`xx` AS DECIMAL(10) )	转换 DECIMAL(10)	否
      ToInt64	CAST( a.`xx` AS DECIMAL(19) )	转换 DECIMAL(19)	否
      ToBoolean	CAST( a.`xx` AS UNSIGNED )	转换 UNSIGNED	否
      ToChar	CAST( a.`xx` AS CHAR(2) )	转换 CHAR(2)	否

    • 聚合函数

      方法名称	解析示例值	说明	自定义函数
      Max	MAX( a.`xx` )	最大值	是
      Min	MIN( a.`xx` )	最小值	是
      Count	COUNT( a.`xx` )	计数	是
      Sum	SUM( a.`xx` )	合计	是
      Avg	AVG( a.`xx` )	平均	是

    • 数学函数

      方法名称	解析示例值	说明	自定义函数
      Abs	ABS( a.`xx` )	绝对值	是
      Round	ROUND( a.`xx` ,2 )	四舍五入	是

    • 字符串函数

      方法名称	解析示例值	说明	自定义函数
      StartsWith	LIKE CONCAT( ‘%’,’xx’ )	左模糊	否
      EndsWith	LIKE CONCAT( xx’,’%’ )	右模糊	否
      Contains	LIKE CONCAT( ‘%’,’xx’,’%’ )	全模糊	否
      SubString	SUBSTRING( ‘xxxxxx’ ,1,3 )	截取	否
      Replace	REPLACE( ‘xxx’,’x’,’y’ )	替换	否
      Len	LEN( ‘xxx’ )	长度	是
      Trim	TRIM( ‘ xx ‘ )	修剪空格	否
      TrimStart	LTRIM( ‘ xx ‘ )	修剪起始空格	否
      TrimEnd	RTRIM( ‘ xx ‘ )	修剪末尾空格	否
      ToUpper	UPPER( ‘xx’ )	大写	否
      ToLower	LOWER( ‘xx’ )	小写	否
      Concat	CONCAT(a.`xx1`,a.`xx2`)	字符串拼接	是

    • 日期函数

      方法名称	解析示例值	说明	自定义函数
      DateDiff	DATEDIFF( a.`xx`,b.`xx` )	日期相差 返回相差天数	是
      TimestampDiff	TIMESTAMPDIFF( DAY,a.`xx`,b.`xx` )	日期相差 指定时间单位	是
      AddYears	DATE_ADD( a.`xx`,INTERVAL 1 YEAR )	添加年份	否
      AddMonths	DATE_ADD( a.`xx`,INTERVAL 1 MONTH )	添加月份	否
      AddDays	DATE_ADD( a.`xx`,INTERVAL 1 DAY )	添加天数	否
      AddHours	DATE_ADD( a.`xx`,INTERVAL 1 HOUR )	添加时	否
      AddMinutes	DATE_ADD( a.`xx`,INTERVAL 1 MINUTE )	添加分	否
      AddSeconds	DATE_ADD( a.`xx`,INTERVAL 1 SECOND )	添加秒	否
      AddMilliseconds	DATE_ADD( a.`xx`,INTERVAL 1 MINUTE_SECOND )	添加毫秒	否
      Year	YEAR( a.`xx` )	获取年份	是
      Month	MONTH( a.`xx` )	获取月份	是
      Day	DAY( a.`xx` )	获取天数	是

    • 查询函数

      方法名称	解析示例值	说明	自定义函数
      In	IN ( a.`xx` ,’x1′,’x2′,’x3′ )	In查询	是
      NotIn	NOT IN ( a.`xx` ,’x1′,’x2′,’x3′ )	Not In查询	是

    • 其它函数

      方法名称	解析示例值	说明	自定义函数
      NewGuid	UUID()	获取GUID	否
      Equals	p.`ProductCode` = ‘123’	比较	否
      IfNull	IFNULL( a.`xx`,0 )	如果为空	是
      Case	CASE	case	是
      When	WHEN	when	是
      Then	THEN	then	是
      Else	ELSE	else	是
      End	END	end	是

  • Oracle

    • 类型转换

      方法名称	解析示例值	说明	自定义函数
      ToString	CAST( a.”xx” AS VARCHAR(255) )	转换 VARCHAR	否
      ToDateTime	TO_TIMESTAMP( a.”xx” ,’yyyy-MM-dd hh:mi:ss.ff’)	转换 DATETIME	否
      ToDecimal	CAST( a.”xx” AS DECIMAL(10,6) )	转换 DECIMAL	否
      ToDouble	CAST( a.”xx” AS NUMBER )	转换 NUMBER	否
      ToSingle	CAST( a.”xx” AS FLOAT )	转换 FLOAT	否
      ToInt32	CAST( a.”xx” AS INT )	转换 INT	否
      ToInt64	CAST( a.”xx” AS NUMBER )	转换 NUMBER	否
      ToBoolean	CAST( a.”xx” AS CHAR(1) )	转换 CHAR	否
      ToChar	CAST( a.”xx” AS CHAR(2) )	转换 CHAR	否

    • 聚合函数

      方法名称	解析示例值	说明	自定义函数
      Max	MAX( a.”xx” )	最大值	是
      Min	MIN( a.”xx” )	最小值	是
      Count	COUNT( a.”xx” )	计数	是
      Sum	SUM( a.”xx” )	合计	是
      Avg	AVG( a.”xx” )	平均	是

    • 数学函数

      方法名称	解析示例值	说明	自定义函数
      Abs	ABS( a.”xx” )	绝对值	是
      Round	ROUND( a.”xx” ,2 )	四舍五入	是

    • 字符串函数

      方法名称	解析示例值	说明	自定义函数
      StartsWith	LIKE CONCAT( ‘%’,’xx’ )	左模糊	否
      EndsWith	LIKE CONCAT( ‘xx’,’%’ )	右模糊	否
      Contains	LIKE CONCAT( ‘%’,’xx’,’%’ )	全模糊	否
      SubString	SUBSTRING( ‘xxxxxx’ ,1,3)	截取	否
      Replace	REPLACE( ‘xxx’,’x’,’y’)	替换	否
      Length	LENGTH( ‘xxx’ )	长度	是
      TrimStart	LTRIM( ‘ xx ‘ )	修剪起始空格	否
      TrimEnd	RTRIM( ‘ xx ‘ )	修剪末尾空格	否
      ToUpper	UPPER( ‘xx’ )	大写	否
      ToLower	LOWER( ‘xx’ )	小写	否
      Concat	CONCAT(a.”xx1″,a.”xx2″)	字符串拼接	是

    • 日期函数

      方法名称	解析示例值	说明	自定义函数
      Year	EXTRACT( YEAR FROM a.”xx” )	获取年份	是
      Month	EXTRACT( MONTH FROM a.”xx” )	获取月份	是
      Day	EXTRACT( DAY FROM a.”xx” )	获取天数	是

    • 查询函数

      方法名称	解析示例值	说明	自定义函数
      In	IN ( a.”xx” ,’x1′,’x2′,’x3′)	In查询	是
      NotIn	NOT IN ( a.”xx”,’x1′,’x2′,’x3′)	Not In查询	是

    • 其它函数

      方法名称	解析示例值	说明	自定义函数
      Equals	p.”ProductCode” = ‘123’	比较	否
      Nvl	NVL( a.”xx”,0 )	空,默认	是
      Case	CASE	case	是
      When	WHEN	when	是
      Then	THEN	then	是
      Else	ELSE	else	是
      End	END	end	是

  • PostgreSql

    • 类型转换

      方法名称	解析示例值	说明	自定义函数
      ToString	a.”xx”::VARCHAR(255)	转换 VARCHAR	否
      ToDateTime	a.”xx”::TIMESTAMP	转换 TIMESTAMP	否
      ToDecimal	a.”xx”::DECIMAL(10,6)	转换 DECIMAL	否
      ToDouble	a.”xx”::NUMERIC(10,6)	转换 NUMERIC	否
      ToSingle	a.”xx”::REAL	转换 REAL	否
      ToInt32	a.”xx”::INTEGER	转换 INT	否
      ToInt64	a.”xx”::BIGINT	转换 BIGINT	否
      ToBoolean	a.”xx”::BOOLEAN	转换 BOOLEAN	否
      ToChar	a.”xx”::CHAR(2)	转换 CHAR	否

    • 聚合函数

      方法名称	解析示例值	说明	自定义函数
      Max	MAX( a.”xx” )	最大值	是
      Min	MIN( a.”xx” )	最小值	是
      Count	COUNT( a.”xx” )	计数	是
      Sum	SUM( a.”xx” )	合计	是
      Avg	AVG( a.”xx” )	平均	是

    • 数学函数

      方法名称	解析示例值	说明	自定义函数
      Abs	ABS( a.”xx” )	绝对值	是
      Round	ROUND( a.”xx” ,2 )	四舍五入	是

    • 字符串函数

      方法名称	解析示例值	说明	自定义函数
      StartsWith	LIKE CONCAT( ‘%’,’xx’ )	左模糊	否
      EndsWith	LIKE CONCAT( ‘xx’,’%’ )	右模糊	否
      Contains	LIKE CONCAT( ‘%’,’xx’,’%’ )	全模糊	否
      SubString	SUBSTRING( ‘xxxxxx’ ,1,3 )	截取	否
      Replace	REPLACE( ‘xxx’,’x’,’y’ )	替换	否
      Length	LENGTH( ‘xxx’ )	长度	是
      Trim	TRIM( ‘ xx ‘ )	修剪空格	否
      TrimStart	LTRIM( ‘ xx ‘ )	修剪起始空格	否
      TrimEnd	RTRIM( ‘ xx ‘ )	修剪末尾空格	否
      ToUpper	UPPER( ‘xx’ )	大写	否
      ToLower	LOWER( ‘xx’ )	小写	否
      Concat	CONCAT(a.”xx1″,a.”xx2″)	字符串拼接	是

    • 日期函数

      方法名称	解析示例值	说明	自定义函数
      AddYears	a.”xx” + INTERVAL ‘1 YEAR’	添加年份	否
      AddMonths	a.”xx” + INTERVAL ‘1 MONTH’	添加月份	否
      AddDays	a.”xx” + INTERVAL ‘1 DAY’	添加天数	否
      AddHours	a.”xx” + INTERVAL ‘1 HOUR’	添加时	否
      AddMinutes	a.”xx” + INTERVAL ‘1 MINUTE’	添加分	否
      AddSeconds	a.”xx” + INTERVAL ‘1 SECOND’	添加秒	否
      AddMilliseconds	a.”xx” + INTERVAL ‘1 MINUTE_SECOND’	添加毫秒	否
      Year	YEAR( a.”xx” )	获取年份	是
      Month	MONTH( a.”xx” )	获取月份	是
      Day	DAY( a.”xx” )	获取天数	是

    • 查询函数

      方法名称	解析示例值	说明	自定义函数
      In	IN ( a.”xx” ,’x1′,’x2′,’x3′ )	In查询	是
      NotIn	NOT IN ( a.”xx” ,’x1′,’x2′,’x3′ )	Not In查询	是

    • 其它函数

      方法名称	解析示例值	说明	自定义函数
      Equals	p.”ProductCode“ = ‘123’	比较	否
      Case	CASE	case	是
      When	WHEN	when	是
      Then	THEN	then	是
      Else	ELSE	else	是
      End	END	end	是

  • Sqlite

    • 类型转换

      方法名称	解析示例值	说明	自定义函数
      ToString	CAST(a.[xx] AS TEXT )	转换 TEXT	否
      ToDateTime	DATETIME( a.[xx] )	转换 DateTime	否
      ToDecimal	CAST(a.[xx] AS DECIMAL(10,6) )	转换 DECIMAL	否
      ToDouble	CAST(a.[xx] AS NUMERIC(10,6) )	转换 NUMERIC	否
      ToSingle	CAST(a.[xx] AS FLOAT )	转换 FLOAT	否
      ToInt32	CAST(a.[xx] AS INTEGER )	转换 INTEGER	否
      ToInt64	CAST(a.[xx] AS BIGINT )	转换 BIGINT	否
      ToBoolean	CAST(a.[xx] AS CHAR(1) )	转换 CHAR	否
      ToChar	CAST(a.[xx] AS CHAR(2) )	转换 CHAR	否

    • 聚合函数

      方法名称	解析示例值	说明	自定义函数
      Max	MAX( a.[xx] )	最大值	是
      Min	MIN( a.[xx] )	最小值	是
      Count	COUNT( a.[xx] )	计数	是
      Sum	SUM( a.[xx] )	合计	是
      Avg	AVG( a.[xx] )	平均	是

    • 数学函数

      方法名称	解析示例值	说明	自定义函数
      Abs	ABS( a.[xx] )	绝对值	是
      Round	ROUND( a.[xx] ,2 )	四舍五入	是

    • 字符串函数

      方法名称	解析示例值	说明	自定义函数
      StartsWith	LIKE ‘%’||’xx’	左模糊	否
      EndsWith	LIKE ‘xx’||’%’	右模糊	否
      Contains	LIKE ‘%’||’xx’||’%’	全模糊	否
      SubString	SUBSTRING( ‘xxxxxx’ ,1,3 )	截取	否
      Replace	REPLACE( ‘xxx’,’x’,’y’ )	替换	否
      Length	LENGTH( ‘xxx’ )	长度	是
      Trim	TRIM( ‘ xx ‘ )	修剪空格	否
      TrimStart	LTRIM( ‘ xx ‘ )	修剪起始空格	否
      TrimEnd	RTRIM( ‘ xx ‘ )	修剪末尾空格	否
      ToUpper	UPPER( ‘xx’ )	大写	否
      ToLower	LOWER( ‘xx’ )	小写	否

    • 日期函数

      方法名称	解析示例值	说明	自定义函数
      AddYears	DATETIME( a.[xx],’1 YEAR’ )	添加年份	否
      AddMonths	DATETIME( a.[xx],’1 MONTH’ )	添加月份	否
      AddDays	DATETIME( a.[xx],’1 DAY’ )	添加天数	否
      AddHours	DATETIME( a.[xx],’1 HOUR’ )	添加时	否
      AddMinutes	DATETIME( a.[xx],’1 MINUTE’ )	添加分	否
      AddSeconds	DATETIME( a.[xx],’1 SECOND’ )	添加秒	否
      AddMilliseconds	DATETIME( a.[xx],’1 YEAR’ )	添加毫秒	否
      Year	STRFTIME( ‘%Y’, a.[xx] )	获取年份	是
      Month	STRFTIME( ‘%m’, a.[xx] )	获取月份	是
      Day	STRFTIME( ‘%j’, a.[xx] )	获取天数	是

    • 查询函数

      方法名称	解析示例值	说明	自定义函数
      In	IN ( a.”xx” ,’x1′,’x2′,’x3′ )	In查询	是
      NotIn	NOT IN ( a.”xx” ,’x1′,’x2′,’x3′ )	Not In查询	是

    • 其它函数

      方法名称	解析示例值	说明	自定义函数
      Equals	p.”ProductCode“ = ‘123’	比较	否
      Case	CASE	case	是
      When	WHEN	when	是
      Then	THEN	then	是
      Else	ELSE	else	是
      End	END	end	是

• 添加自定义函数解析

                  //注意:只能扩展未实现的方法名称 不能覆盖原有的实现
                  Models.DbType.MySQL.AddSqlFunc("方法名称", (visit, method, sqlStack) =>
                  {
                      //解析逻辑
                  });
  

九、数据库日志

				        db.Aop.DbLog = (sql, dp) =>
                {
                    Console.WriteLine($"执行Sql:{sql}");
                    if (dp != null)
                    {
                        foreach (var item in dp)
                        {
                            Console.WriteLine($"参数名称:{item.ParameterName} 参数值:{item.ParameterValue}");
                        }
                    }
                };

十、事务

• 普通事务

                try
                {
                    db.Ado.BeginTran();//开启事务
  
                    // 执行 CRUD
  
                    db.Ado.CommitTran();//提交事务
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                    db.Ado.RollbackTran();//回滚事务
                }
  

• 更大范围的事务

                  try
                  {
                      db.BeginTran();//开启事务
  
                    	// 执行 CRUD
  
                      db.CommitTran();//提交事务
                  }
                  catch (Exception ex)
                  {
                      db.RollbackTran();//回滚事务
                      Console.WriteLine(ex.Message);
                  }
  

十一、多租户

• 改变数据库

                  //数据库配置可从Json配置文件加载
  				IDbContext db = new DbContext(new List() {
                  new DbOptions()
                  {
                      DbId = "1",
                      DbType = Models.DbType.SQLServer,
                      ProviderName = "System.Data.SqlClient",
                      FactoryName = "System.Data.SqlClient.SqlClientFactory,System.Data",
                      ConnectionStrings = "server=localhost;database=Test;user=sa;pwd=123456789;min pool size=0;max pool size=100;connect timeout=120;"
                  },
                  new DbOptions()
                  {
                      DbId = "2",
                      DbType = Models.DbType.MySQL,
                      ProviderName = "MySqlConnector",
                      FactoryName = "MySqlConnector.MySqlConnectorFactory,MySqlConnector",
                      ConnectionStrings = "server=localhost;database=Test;user=root;pwd=123456789;port=3306;min pool size=0;max pool size=100;connect timeout=120;"
                  }});
                  db.ChangeDb("2");//切换到MySQL
  

十二、原生特性支持

    /// 

    /// 产品
    /// 
    [Table("ProductMain")]
    public class Product
    {
        /// 

        /// 产品ID
        /// 
        [Key]
        public int ProductId { get; set; }

        /// 

        /// 产品编号
        /// 
        [Column("ProductCode")]//不标记默认取当前属性名称
        public string ProductCode { get; set; }

        /// 

        /// 自定义1
        /// 
        [NotMapped]
        public string Custom1 { get; set; }
    }

十三、原生Ado

                // 原始起步
                // var conn = db.Ado.DbProviderFactory.CreateConnection();
                // var cmd = conn.CreateCommand();

                // 封装的方法分别以Execute和Create开头以及预处理 PrepareCommand 方法
                // 该方法可以自动帮你处理执行的预操作，主要作用是代码复用。

                // 当有非常复杂的查询 ORM不能满足需求的时候可以使用原生Ado满足业务需求

                // 构建数据集核心扩展方法 分别有 FristBuild ListBuild DictionaryBuild DictionaryListBuild
                var data = db.Ado.ExecuteReader(CommandType.Text, "select * from product", null).ListBuild();

十四、工作单元

• 注册数据库上下文和工作单元服务

  var builder = WebApplication.CreateBuilder(args);
  
  var configuration = builder.Configuration;
  
  // 添加数据库上下文服务
  builder.Services.AddFastDbContext();
  // 添加工作单元服务
  builder.Services.AddFastUnitOfWork();
  
  // 加载数据库配置
  builder.Services.Configure>(configuration.GetSection("DbConfig"));
  

• 实际应用

          /// 
  
          /// 工作单元
          /// 
          private readonly IUnitOfWork unitOfWork;
  
  
          /// 
  
          /// 构造方法
          /// 
          /// 工作单元
          public UnitOfWorkTestService(IUnitOfWork unitOfWork)
          {
              this.unitOfWork = unitOfWork;
          }
  
          /// 
  
          /// 测试
          /// 
          /// 
          public string Test()
          {
              //unitOfWork 对象无需显示使用using
              var result1 = unitOfWork.Db.Insert(new Category()
              {
                  CategoryName = "类别3"
              }).Exceute();
  
              var result2 = unitOfWork.Db.Insert(new Product()
              {
                  ProductCode = "测试工作单元",
              }).Exceute();
  
              unitOfWork.Commit();
  
              return "工作单元执行完成...";
          }
  

十五、大数据导入

• 批复制 仅支持SqlServer Oracle MySql PostgreSql

                  var list = new List();
                  for (int j = 1; j ().BulkCopy(list);
  

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net
机房租用，北京机房租用，IDC机房托管， http://www.e1idc.net