一個可用於生產專案基於 .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 ) 四捨五入是

方法名稱	解析範例值	說明	自定義函數
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查詢是

方法名稱	解析範例值	說明	自定義函數
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 ) 四捨五入是

方法名稱	解析範例值	說明	自定義函數
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查詢是

方法名稱	解析範例值	說明	自定義函數
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 ) 四捨五入是

方法名稱	解析範例值	說明	自定義函數
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查詢是

方法名稱	解析範例值	說明	自定義函數
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 ) 四捨五入是

方法名稱	解析範例值	說明	自定義函數
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查詢是

方法名稱	解析範例值	說明	自定義函數
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 ) 四捨五入是

方法名稱	解析範例值	說明	自定義函數
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查詢是

方法名稱	解析範例值	說明	自定義函數
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);

一個可用於生產專案 基於 .NET 6 自研ORM

Fast Framework

一、前言

二、專案明細

三、核心物件

四、插入

五、刪除

六、更新

七、查詢

八、Lambda表示式

九、資料庫紀錄檔

十、事務

十一、多租戶

十二、原生特性支援

十三、原生Ado

十四、工作單元

十五、巨量資料匯入

一個可用於生產專案基於 .NET 6 自研ORM