Fast.Framework ORM 试用

简介

Fast.Framework 是一款基于 .NET 6 封装的轻量级ORM框架，支持多种数据库(SQL Server、Oracle、MySQL、PostgreSQL、SQLite)。
优点

• 性能好
  
• 使用简单
  

如何使用

1. 安装

NuGet搜索Fast.Framework并安装最新版本

2. 创建DbContext对象

DbContext是轻量级的，可以频繁创建，一个线程创建一个DbContext，不要跨线程使用。

1. private IDbContext GetDbContext()
2. {
3.     IDbContext _db = new DbContext(new List<DbOptions>() {
4.             new DbOptions()
5.             {
6.                 DbId = "1",
7.                 DbType = DbType.MySQL,
8.                 ProviderName = "MySqlConnector",
9.                 FactoryName = "MySqlConnector.MySqlConnectorFactory,MySqlConnector",
10.                 ConnectionStrings = "Data Source=localhost;Port=3306;User ID=root;Password=123456;Initial Catalog=fast_framework_test;Charset=utf8mb4;SslMode=none;Allow User Variables=True;connection timeout=600;"
11.             }
12.         });
14.     if (_printSql)
15.     {
16.         _db.Aop.DbLog = (sql, dp) =>
17.         {
18.             Console.WriteLine($"执行Sql:{sql}");
19.             if (dp != null)
20.             {
21.                 foreach (var item in dp)
22.                 {
23.                     Console.WriteLine($"参数名称:{item.ParameterName} 参数值:{item.Value}");
24.                 }
25.             }
26.         };
27.     }
29.     return _db;
30. }

复制代码

实体类

实体类原生支持微软特性，兼容Entity Framework。

1. using System.ComponentModel.DataAnnotations;
2. using System.ComponentModel.DataAnnotations.Schema;
4. namespace Models
5. {
6.     /// <summary>
7.     /// 用户表
8.     /// </summary>
9.     [Serializable]
10.     [Table("sys_user")]
11.     public partial class SysUser
12.     {
14.         /// <summary>
15.         /// 主键
16.         /// </summary>
17.         [Key]
18.         [Column("id")]
19.         public long Id { get; set; }
21.         /// <summary>
22.         /// 用户名
23.         /// </summary>
24.         [Column("user_name")]
25.         public string UserName { get; set; }
27.         /// <summary>
28.         /// 用户姓名
29.         /// </summary>
30.         [Column("real_name")]
31.         public string RealName { get; set; }
33.         /// <summary>
34.         /// 用户密码
35.         /// </summary>
36.         [Column("password")]
37.         public string Password { get; set; }
39.         /// <summary>
40.         /// 备注
41.         /// </summary>
42.         [Column("remark")]
43.         public string Remark { get; set; }
45.         /// <summary>
46.         /// 创建者ID
47.         /// </summary>
48.         [Column("create_userid")]
49.         public string CreateUserid { get; set; }
51.         /// <summary>
52.         /// 创建时间
53.         /// </summary>
54.         [Column("create_time")]
55.         public DateTime CreateTime { get; set; }
57.         /// <summary>
58.         /// 更新者ID
59.         /// </summary>
60.         [Column("update_userid")]
61.         public string UpdateUserid { get; set; }
63.         /// <summary>
64.         /// 更新时间
65.         /// </summary>
66.         [Column("update_time")]
67.         public DateTime? UpdateTime { get; set; }
69.     }
70. }

复制代码

.NET 6 依赖注入FastDbContext

配置文件

1. "DbConfig": [
2.   {
3.     "DbId": 1,
4.     "DbType": "MySQL",
5.     "IsDefault": true,
6.     "ProviderName": "MySqlConnector",
7.     "FactoryName": "MySqlConnector.MySqlConnectorFactory,MySqlConnector",
8.     "ConnectionStrings": "Data Source=localhost;Port=3306;User ID=root;Password=123456;Initial Catalog=fast_framework_test;Charset=utf8mb4;SslMode=none;Allow User Variables=True;connection timeout=600;"
9.   }
10. ]

复制代码

注入代码

1. //注入FastDbContext
2. builder.Services.Configure<List<DbOptions>>(builder.Configuration.GetSection("DbConfig"));
3. builder.Services.AddFastDbContext();

复制代码

循环插入

1. await db.Ado.BeginTranAsync();
2. foreach (SysUser user in userList)
3. {
4.     await db.Insert(user).ExceuteAsync();
5. }
6. await db.Ado.CommitTranAsync();

复制代码

批量插入

1. await GetDbContext().Insert(userList).ExceuteAsync();

复制代码

循环修改

1. await db.Ado.BeginTranAsync();
2. foreach (SysUser user in userList)
3. {
4.     await db.Update(user).ExceuteAsync();
5. }
6. await db.Ado.CommitTranAsync();

复制代码

批量修改

1. await GetDbContext().Update(userList).ExceuteAsync();

复制代码

条件查询

1. Pagination pagination = new Pagination();
2. pagination.Page = 10;
3. pagination.PageSize = 200;
5. var list = await _db.Query<SysUser>()
6.     .Where(t => t.Id > 20 && t.RealName.Contains("测试"))
7.     .OrderBy(t => t.CreateTime, "desc")
8.     .OrderBy(t => t.Id).ToPageListAsync(pagination);

复制代码

分组聚合统计查询

这个写法很优雅。

1. var list = await db.Query<BsOrderDetail>()
2.     .LeftJoin<BsOrder>((d, o) => o.Id == d.OrderId)
3.     .GroupBy((d, o) => new { o.Id, o.OrderTime, o.Remark })
4.     .Having((d, o) => SqlFunc.Sum(d.Quantity * d.Price) > 1000)
5.     .Select((d, o) => new
6.     {
7.         o.Id,
8.         o.OrderTime,
9.         o.Remark,
10.         Amount = SqlFunc.Sum(d.Quantity * d.Price)
11.     }).ToListAsync();

复制代码

性能测试

性能测试使用Winform测试
与其它ORM的对比请参考《ORM增删改查并发性能测试2》
常规测试


并发查询


并发插入


结论

感觉还是非常快的，性能非常优异。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！