Fast.Framework Save Abandoned

Fast Framework 是一个基于NET6.0 封装的轻量级 ORM 框架支持多种数据库

Project README

Fast Framework

作者 Mr-zhong

一、前言

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

优点：体积小、可动态切换不同实现类库、原生支持微软特性、流畅API、使用简单、性能高、模型数据绑定采用委托+缓存、强大的表达式解析、子查询的原生支持、复杂表达式含成员变量解析，解析性能是目前常见框架中 No1 主要是有缓存的支持、源代码可读性强。

缺点：目前仅支持Db Frist Code Frist 暂时不考虑主要是需要花费大量时间和精力。

二、项目明细

名称	说明
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文件配置格式

"DbConfig": [
    {
      "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;"
    }]"DbConfig": [
    {
      "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);

// 添加数据库上下文 需引用Fast.Framework和Fast.Framework.Extensions包
builder.Services.AddFastDbContext();

// 从Json配置文件加载数据库选项
builder.Services.Configure<List<DbOptions>>(builder.Configuration.GetSection("DbConfig"));

// 产品服务类 通过构造方法注入
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 = await db.Insert(product).ExceuteAsync();
            Console.WriteLine($"实体对象插入 受影响行数 {result}");

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

            var product = new Product()
            {
                ProductCode = "1001",
                ProductName = "测试产品1"
            };
            var result = await db.Insert(product).ExceuteReturnIdentityAsync();
            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 = await db.Insert(list).ExceuteAsync();
            Console.WriteLine($"实体对象列表插入 受影响行数 {result}");

匿名对象插入

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

字典插入

            var product = new Dictionary<string, object>()
            {
                {"ProductCode","1001"},
                { "ProductName","测试商品1"}
            };
            //注意:需要显示指定类型否则无法重载到正确的方法,如果没有实体类型可用object类型并配合As方法显示指定表名称.
            var result = await db.Insert<Product>(product).ExceuteAsync();
            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"}
                 });
            }
            //注意:需要显示指定泛型类型否则无法重载到正确的方法,如果没有实体可用object类型并配合As方法显示指定表名称.
            var result = await db.Insert<Product>(list).ExceuteAsync();
            Console.WriteLine($"字典列表插入 受影响行数 {result}");

五、删除

实体对象删除

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

无条件删除

            var result = await db.Delete<Product>().ExceuteAsync();
            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 = await db.Update(product).ExceuteAsync();
            Console.WriteLine($"对象更新 受影响行数 {result}");

指定列更新

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

忽略列更新

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

实体对象列表更新

            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 = await db.Update(list).ExceuteAsync();
            Console.WriteLine($"对象列表更新 受影响行数 {result}");

匿名对象更新

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

字典更新

            var product = new Dictionary<string, object>()
            {
                { "ProductId",1},
                {"ProductCode","1001"},
                { "ProductName","测试商品1"}
            };
            //注意:需要显示指定泛型类型否则无法重载到正确的方法并且使用WhereColumns方法指定条件列
            var result = await db.Update<Product>(product).WhereColumns("ProductId").ExceuteAsync();
            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}"}
                });
            }
            //注意:需要显示指定泛型类型否则无法重载到正确的方法并且使用WhereColumns方法执行条件列
            var result = await db.Update<Product>(list).WhereColumns("ProductId").ExceuteAsync();
            Console.WriteLine($"字典列表更新 受影响行数 {result}");

表达式更新

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

七、查询

单一查询

            var data = await db.Query<Product>().FristAsync();

列表查询

            var data = await db.Query<Product>().ToListAsync();

返回单个字典

            var data = await db.Query<Product>().ToDictionaryAsync();

返回字典列表

            var data = await db.Query<Product>().ToDictionaryListAsync();

分页查询

            //分页查询不返回总数
            var data = await db.Query<Product>().ToPageListAsync(1,100);
            //分页查询返回总数
            var total = new RefAsync<int>();
            var data = await db.Query<Product>().ToPageListAsync(1, 100, refResult);
            Console.WriteLine($"总数：{total.Value}");

映射类型

            //只要B类型有A类型相同的属性就可以直接映射,无需在使用Select方法 New 具体类型赋值
            var data = await db.Query<A>().MappingType<B>().ToListAsync();

计数查询

            var data = await db.Query<Product>().CountAsync();

任何查询

            var data = await db.Query<Product>().AnyAsync();

条件查询

            var data = await db.Query<Product>().Where(w => w.ProductId == 1);
            //需要调用返回数据结果的方法 例如：ToListAsync

Like 查询

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

Not Like查询

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

//由于没有专门去扩展 Not Like 方法，可以用取反或使用比较变通实现 例如 w.ProductName.StartsWith("左模糊")==false 
//Mysql举例 最终解析后的结果为 `ProductName` Like '%左模糊' = 0 这种用法数据库是支持的 相当于 Not Like

Select查询 (选择字段)

            var data = await db.Query<Product>().Select(s => new
            {
                s.ProductId,
                s.ProductName
            }).ToListAsync();

Select查询 (Case When)

                var data = await 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()
                }).ToListAsync();

分组查询

            var data = await db.Query<Product>().GroupBy(s => new
            {
                s.ProductId,
                s.ProductName
            }).ToListAsync();

分组聚合查询

            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)//支持嵌套
            }).ToListAsync();

排序查询

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

Having查询

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

联表查询

            var data = await db.Query<Product>().LeftJoin<Class1>((a, b) => a.ProductId == b.ProductId).ToListAsync();
            // 右连接对应的是 RightJoin 内连接对应 InnerJoin

联合查询

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

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

                //方式1
                var result1 = await 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 = await db.Query<Product>().Where(w => w.ProductId == 1489087).Select(s => new
                {
                    s.ProductCode,
                    s.ProductName
                }).Insert("表名称 同实例不同库 可以使用 db.数据库名称.表名称 ", "列名称1", "列名称2", "`带标识的列名称3`");

                //方式3 需要注意同方式2 一样
                var result3 = await 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 = await db.Query<Product>().Where(w => SqlFunc.In(w.ProductCode, "1001", "1002")).ToListAsync();

                // 方式2
                var data2 = await db.Query<Product>().Where(w => SqlFunc.In(w.ProductCode, new List<string>() { "123", "456" })).ToListAsync();

                // 方式3 需要动态更新IN值 使用这种
                var list = new List<string>() { "123", "456" };
                var data3 = await db.Query<Product>().Where(w => SqlFunc.In(w.ProductCode, list)).ToListAsync();

                // 方法4 参数同上一样 单独分离IN和NotIN 是为了兼容匿名查询
                var data4 = await db.Query<Product>().In("字段名称", "1001", "1002").ToListAsync();

子查询

                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 的泛型是根据你左边赋值的属性类型来定义
                }).ToListAsync();
                // 这种没有使用new 的 泛型可随意定义 实际作用就是避免 对象属性赋值类型冲突的问题
                var sql2 = db.Query<Product>().Select(s => db.SubQuery<string>(subQuery)).ToListAsync();

八、Lambda表达式

高性能表达式动态缓存的支持

                var list = new List<string>() { "1001" };
                Expression<Func<Product, bool>> ex = p => SqlFunc.In(p.ProductCode, list);

                for (int i = 1; i <= 3; i++)
                {
                    list.Add($"动态添加参数{i}");
                    var stopwatch1 = new Stopwatch();
                    stopwatch1.Start();
                    var result = ex.ResolveSql(new ResolveSqlOptions()
                    {
                        DbType = Models.DbType.MySQL,
                        ResolveSqlType = ResolveSqlType.Where
                    });
                    stopwatch1.Stop();
                    Console.WriteLine($"解析耗时:{stopwatch1.ElapsedMilliseconds}ms {stopwatch1.ElapsedMilliseconds / 1000.00}s 解析Sql字符串:{result.SqlString}");
                }

解析结果

解析耗时:14ms 0.014s 解析Sql字符串:p.`ProductCode` IN ( @2dac7a1c4aa64036aeee858b86fbd3a4_0,@2dac7a1c4aa64036aeee858b86fbd3a4_1 )
解析耗时:0ms 0s 解析Sql字符串:p.`ProductCode` IN ( @3b6b8fcb2f674cf490d44f97525c3c2b_0,@3b6b8fcb2f674cf490d44f97525c3c2b_1,@3b6b8fcb2f674cf490d44f97525c3c2b_2 )
解析耗时:0ms 0s 解析Sql字符串:p.`ProductCode` IN ( @4447c5d65e8a49c9b04549b7aac868b2_0,@4447c5d65e8a49c9b04549b7aac868b2_1,@4447c5d65e8a49c9b04549b7aac868b2_2,@4447c5d65e8a49c9b04549b7aac868b2_3 )

动态表达式需引入命名空间 Fast.Framework.Utils

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

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' )	小写	否

日期函数

方法名称	解析示例值	说明	自定义函数
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.Value}");
                        }
                    }
                };

十、事务

普通事务

              try
              {
                  await db.Ado.BeginTranAsync();//开启事务

                  // 执行 CRUD

                  await db.Ado.CommitTranAsync();//提交事务
              }
              catch (Exception ex)
              {
                  Console.WriteLine(ex.Message);
                  await db.Ado.RollbackTranAsync();//回滚事务
              }

更大范围的事务

                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("1");//切换到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满足业务需求

                // 构建数据集核心扩展方法 分别有 FristBuildAsync ListBuildAsync DictionaryBuildAsync DictionaryListBuildAsync
                var data = await db.Ado.ExecuteReaderAsync(CommandType.Text, "select * from product", null).ListBuildAsync<Product>();

Open Source Agenda is not affiliated with "Fast.Framework" Project. README Source: China-Mr-zhong/Fast.Framework

Stars

Open Issues

Last Commit

1 year ago

License

Apache-2.0

Open Source Agenda Badge

<a href="https://www.opensourceagenda.com/projects/fastframework"><img src="https://www.opensourceagenda.com/projects/fastframework/reviews/badge.svg" alt="Open Source Agenda"></a>

Submit Review Review Your Favorite Project

Submit Resource Articles, Courses, Videos

Submit Article Submit a post to our blog

From the blog

Dec 11, 2022

How to Choose Which Programming Language to Learn First?

From the blog

Dec 11, 2022

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

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

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

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

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

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

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