一个可用于生产项目 基于 .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<DbOptions>() {
                    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<List<DbOptions>>(builder.Configuration.GetSection("DbOptions"));
    
    // 产品服务类 通过构造方法注入
    public class ProductService
    {
        /// <summary>
        /// 数据库
        /// </summary>
        private readonly IDbContext db;
    
        /// <summary>
        /// 构造方法
        /// </summary>
        /// <param name="db">数据库</param>
        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<Product>();
                for (int i = 0; i < 2100; i++)
                {
                    list.Add(new Product()
                    {
                        ProductCode = $"编号{i + 1}",
                        ProductName = $"名称{i + 1}"
                    });
                }
                var result = db.Insert(list).Exceute();
                Console.WriteLine($"实体对象列表插入 受影响行数 {result}");
    
  • 匿名对象插入

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

                var list = new List<object>();
                for (int i = 0; i < 2100; i++)
                {
                    list.Add(new
                    {
                        ProductCode = $"编号{i + 1}",
                        ProductName = $"名称{i + 1}"
                    });
                }
                //注意:需要使用As方法显示指定表名称
                var result = db.Insert(list).As("Product").Exceute();
                Console.WriteLine($"匿名对象列表插入 受影响行数 {result}");
    
  • 字典插入

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

                var list = new List<Dictionary<string, object>>();
                for (int i = 0; i < 2100; i++)
                {
                    list.Add(new Dictionary<string, object>()
                    {
                        {"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<Product>().Exceute();
                Console.WriteLine($"无条件删除 受影响行数 {result}");
    
  • 表达式删除

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

    			      //特殊用法 如需单个条件或多个可搭配 WhereColumn或WhereColumns方法
                var result = await db.Delete<object>().As("Product").ExceuteAsync();
                Console.WriteLine($"无实体删除 受影响行数 {result}");
    
六、更新
  • 实体对象更新

                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<Product>(new Product() { ProductCode = "1001", ProductName = "1002" }).Columns("ProductCode", "ProductName").Exceute();
    						// 字段很多的话可以直接new List<string>(){"列1","列2"}
    
  • 忽略列更新

                var result = db.Update<Product>(new Product() { ProductCode = "1001", ProductName = "1002" }).IgnoreColumns("Custom1").Exceute();
                // 同上使用方法一样
    
  • 实体对象列表更新

                var list = new List<Product>();
                for (int i = 0; i < 2022; i++)
                {
                    list.Add(new Product()
                    {
                        ProductCode = $"编号{i + 1}",
                        ProductName = $"名称{i + 1}"
                    });
                }
                //注意:标记KeyAuttribute特性属性或使用WhereColumns方法指定更新条件列
                var result = db.Update(list).Exceute();
                Console.WriteLine($"对象列表更新 受影响行数 {result}");
    
  • 匿名对象更新

                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<object>();
                for (int i = 0; i < 2022; i++)
                {
                    list.Add(new
                    {
                        ProductId = i + 1,
                        ProductCode = $"编号{i + 1}",
                        ProductName = $"名称{i + 1}"
                    });
                }
                //由于是匿名对象需要显示指定表名称,使用WhereColumns方法指定更新条件列
                var result = db.Update(list).As("Product").WhereColumns("ProductId").Exceute();
                Console.WriteLine($"匿名对象列表更新 受影响行数 {result}");
    
  • 字典更新

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

                var list = new List<Dictionary<string, object>>();
                for (int i = 0; i < 2022; i++)
                {
                    list.Add(new Dictionary<string, object>()
                    {
                        { "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<Product>().Where(w => w.ProductId == 1).Frist();
                    obj.Custom1 = "测试版本控制修改";
    				//参数为 true 更新失败将抛出异常
                    var result = db.Update(obj).ExceuteWithOptLock(true);
    
七、查询
  • 单一查询

                var data = db.Query<Product>().First();
    
  • 列表查询

                var data = db.Query<Product>().ToList();
    
  • 返回单个字典

                var data = db.Query<Product>().ToDictionary();
    
  • 返回字典列表

                var data = db.Query<Product>().ToDictionaryList();
    
  • 分页查询

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

                var data = db.Query<Product>().Count();
    
  • 任何查询

                var data = db.Query<Product>().Any();
    
  • 条件查询

                var data = db.Query<Product>().Where(w => w.ProductId == 1).ToList;
    
  • Like 查询

                var data = db.Query<Product>().Where(w => w.ProductName.StartsWith("左模糊") || w.ProductName.EndsWith("右模糊") || w.ProductName.Contains("全模糊")).ToList();
    
  • Not Like查询

    var data = db.Query<Product>().Where(w => !w.ProductName.StartsWith("左模糊") || !w.ProductName.EndsWith("右模糊") || !w.ProductName.Contains("全模糊")).ToList();
    
    //由于没有专门去扩展 Not Like 方法,可以用取反或使用比较变通实现 例如 w.ProductName.StartsWith("左模糊")==false 
    //Mysql举例 最终解析后的结果为 `ProductName` Like '%左模糊' = 0 这种用法数据库是支持的 相当于 Not Like
    
  • Select查询 (选择字段)

                var data = db.Query<Product>().Select(s => new
                {
                    s.ProductId,
                    s.ProductName
                }).ToList();
    
  • Select查询 (Case When)

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

                var data = db.Query<Product>().GroupBy(s => new
                {
                    s.ProductId,
                    s.ProductName
                }).ToList();
    
  • 分组聚合查询

                var sql = db.Query<Order>().InnerJoin<OrderDetail>((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<Product>().OrderBy(s => new
                {
                    s.CreateTime
                }).ToList();
                //这是多个字段排序使用方法 还有其它重载方法
    
  • Having查询

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

                var data = db.Query<Product>().LeftJoin<Class1>((a, b) => a.ProductId == b.ProductId).ToList();
                // 右连接 RightJoin 内连接 InnerJoin 全连接 FullJoin
    
  • 联合查询

                var query1 = db.Query<Product>();
                var query2 = db.Query<Product>();
                db.Union(query1, query2);//联合
                db.UnionAll(query1, query2);//全联合
                //执行查询调用Toxx方法
    
  • 查询并插入 仅支持同实例的数据库 跨库 个人还是建议 用事务分开写查询和插入

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

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

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

                    var subQuery = db.Query<Product>();
                    var data = db.Query(subQuery).OrderBy(o => o.ProductCode).ToList();
    
  • Join子查询

                    var subQuery = db.Query<Product>();
                    var data = db.Query<Product>().InnerJoin(subQuery, (a, b) => a.ProductId == b.ProductId).ToList();
    
  • Include查询

                    // 联表条件 默认优先匹配主键 其次带有ID结尾的名称
                    var data = db.Query<Category>().Include(i => i.Products).ToList();
    
八、Lambda表达式
  • 动态表达式 命名空间 Fast.Framework.Utils

                    var ex = DynamicWhereExp.Create<Product>().AndIF(1 == 1, a => a.DeleteMark == true).Build();
                    var data = db.Query<Product>().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<DbOptions>() {
                    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
    
十二、原生特性支持
    /// <summary>
    /// 产品
    /// </summary>
    [Table("ProductMain")]
    public class Product
    {
        /// <summary>
        /// 产品ID
        /// </summary>
        [Key]
        public int ProductId { get; set; }

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

        /// <summary>
        /// 自定义1
        /// </summary>
        [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<Product>();
十四、工作单元
  • 注册数据库上下文和工作单元服务

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

            /// <summary>
            /// 工作单元
            /// </summary>
            private readonly IUnitOfWork unitOfWork;
    
    
            /// <summary>
            /// 构造方法
            /// </summary>
            /// <param name="unitOfWork">工作单元</param>
            public UnitOfWorkTestService(IUnitOfWork unitOfWork)
            {
                this.unitOfWork = unitOfWork;
            }
    
            /// <summary>
            /// 测试
            /// </summary>
            /// <returns></returns>
            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<Product>();
                    for (int j = 1; j <= 100000; j++)
                    {
                        list.Add(new Product()
                        {
                            CategoryId = 1,
                            ProductCode = $"测试编号_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            ProductName = $"测试名称_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            CreateTime = DateTime.Now,
                            Custom1 = $"测试自定义1_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom2 = $"测试自定义2_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom3 = $"测试自定义3_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom4 = $"测试自定义4_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom5 = $"测试自定义5_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom6 = $"测试自定义6_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom7 = $"测试自定义7_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom8 = $"测试自定义8_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom9 = $"测试自定义9_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom10 = $"测试自定义10_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom11 = $"测试自定义11_{Timestamp.CurrentTimestampSeconds()}_{j}",
                            Custom12 = $"测试自定义12_{Timestamp.CurrentTimestampSeconds()}_{j}",
                        });
                    }
                    db.Fast<Product>().BulkCopy(list);
    

原文链接:https://www.cnblogs.com/China-Mr-zhong/archive/2023/04/22/17342895.html

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:一个可用于生产项目 基于 .NET 6 自研ORM - Python技术站

(0)
上一篇 2023年4月22日
下一篇 2023年4月22日

相关文章

  • System.Data.OleDb.OleDbException: 未指定的错误的完美解决方法

    System.Data.OleDb.OleDbException: 未指定的错误 对于这个错误,一般是由于OleDbDataAdapter执行Fill方法时出现了某种异常。它可能是由于以下原因之一: SQL查询或其他数据库操作语句有语法错误。 数据库中的表或字段不存在。 数据类型不匹配。 数据库连接出现问题或者权限不足。 针对这种类型的错误,我们可以采取如下…

    C# 2023年5月15日
    00
  • c# Graphics使用方法(画圆写字代码)

    C# Graphics使用方法(画圆写字代码) 在C#中,我们可以使用System.Drawing命名空间下的Graphics类来实现绘图功能,包括画笔、画刷、线条、形状等等。本篇攻略主要介绍如何使用Graphics类绘制圆和写字的相关代码。 创建 Graphics 对象 要使用Graphics类进行绘图,首先要创建Graphics对象。我们可以通过两种方式…

    C# 2023年6月7日
    00
  • JS+WCF实现进度条实时监测数据加载量的方法详解

    JS+WCF实现进度条实时监测数据加载量的方法详解 在Web应用程序中,数据加载是一个常见的操作。为了提高用户体验,我们通常需要实现一个进度条来显示数据加载的进度。本文将详细讲解如何使用JS和WCF实现进度条实时监测数据加载量的方法,并提供两个示例。 1. 使用JS实现进度条 以下是使用JS实现进度条的基本步骤: 在HTML页面中,添加一个进度条元素。 &l…

    C# 2023年5月15日
    00
  • c# SendMail发送邮件实例代码

    下面详细讲解一下“c# SendMail发送邮件实例代码”的完整攻略。 什么是SendMail? SendMail是c#中一个邮件发送类,可以方便地实现发送邮件的功能。它的使用方法较为简单,只需要按照一定格式配置SMTP服务器和发件人信息,即可完成邮件的发送。 SendMail使用教程 配置SMTP服务器 在使用SendMail发送邮件前,需要首先配置SMT…

    C# 2023年6月7日
    00
  • C#多线程之Parallel类的用法

    C#多线程之Parallel类的用法 什么是Parallel类? Parallel类是 .NET Framework 4.0 中引入的一个提供高级多线程支持的类。使用该类能够方便地达到在多核处理器上并行运行代码的目的。Parallel类提供的方法和语法非常简洁易懂,大大提高了多线程编程的效率。 Parallel类的主要方法 Parallel.Invoke方法…

    C# 2023年6月6日
    00
  • C#实现备忘录功能

    当我们开发一个应用程序时,常常需要向用户提供一种保存信息的功能,以便用户在需要的时候能够找到并使用这些信息。这种保存用户信息的功能就称为备忘录。在C#中,我们可以很容易地实现备忘录的功能,并且可以根据自己的需求来创建不同形式的备忘录。下面是实现备忘录功能的完整攻略: 1. 创建备忘录的类和属性 我们需要创建一个备忘录的类来存储用户信息,并定义备忘录中的属性。…

    C# 2023年5月15日
    00
  • 详解c#索引(Index)和范围(Range)

    详解 C# 索引(Index)和范围(Range) 简介 C# 8.0 引入了一个新的功能,即索引和范围。 索引允许您通过使用[]操作符来访问元素的位置,而不是使用集合实例的元素本身。 而范围允许我们轻松地指定一个集合的范围,以便我们可以在此范围内迭代集合元素。如果您的工作与集合打交道,这些是您需要掌握的基本技能。 索引 索引是用于访问特定元素的整数。 索引…

    C# 2023年5月15日
    00
  • 用C#生成不重复的随机数的代码

    下面是关于使用C#生成不重复的随机数的完整攻略及示例: 生成不重复的随机数概述 在C#中生成随机数是很常见的需求,但如果要生成不重复的随机数则需要使用一些特殊的技巧。 首先,我们需要生成一个可重复的种子值seed。种子值可以用系统时间、Guid、随机数等值生成。可以使用new Random(seed)初始化Random对象来进行后续的随机数生成操作。 其次,…

    C# 2023年6月1日
    00
合作推广
合作推广
分享本页
返回顶部