C# 轻量级 ORM 框架 NPoco 的简单应用

刘承建

目录

• 简介
  
• 快速入门
  
  
  
  • 安装 NuGet 包
    
  • 实体类User
    
  • 数据库类DbFactory
    
  • 增删改查
    
    
    
    • Insert
      
    • Select
      
    • Update
      
    • Delete
      
    
    
  
  
• 总结
  

简介

NPoco 是 PetaPoco 的一个分支，具有一些额外的功能，截至现在 github 星数 839。NPoco 中文资料没多少，我是被博客园群友推荐的，这几天简单尝试了一下：
github: https://github.com/schotime/NPoco
wiki: https://github.com/schotime/NPoco/wiki
NPoco 支持多种数据库系统，包括但不限于以下几种：

• Microsoft SQL Server
  
• SQLite
  
• MySQL
  
• PostgreSQL
  
• Oracle
  
• Firebird
  
• DB2
  
• SQL CE (SQL Compact Edition)
  

快速入门

本文使用SQLite数据库作为示例，创建一个控制台项目，尝试一些简单的用法。
安装 NuGet 包

对于使用 NPoco 和 SQLite 的情况，只需要安装两个 NuGet 包：

• NPoco - 这是 NPoco ORM 的核心库。
  
• System.Data.SQLite 或 Microsoft.Data.Sqlite - 这是用于连接 SQLite 数据库的 ADO.NET 提供程序。
  

选择 System.Data.SQLite 或 Microsoft.Data.Sqlite 主要取决于正在使用的 .NET 平台：

• .NET Core 3.1 或 .NET 5/6/7 的项目选择 Microsoft.Data.Sqlite
  
• .NET Framework 或早期的 .NET Core 版本的项目选择 System.Data.SQLite
  

这里使用 Microsoft.Data.Sqlite ，NuGet 包安装如下：

实体类User

新建一个实体类 User ，并定义实体类和字段的映射关系，参考 官方文档 Mapping：

1. //为了演示 TableName、Column ，表名和列名故意和实体类的属性名设置的不同
2. [TableName("Users")]
3. [PrimaryKey("UserId", AutoIncrement = true)]
4. public class User
5. {   
6.     public int UserId { get; set; }
8.     [Column("Email")]
9.     public string UserEmail { get; set; }
11.     [ComputedColumn]
12.     public DateTime CreateTime{ get; set; }
14.     [ComputedColumn]
15.     public DateTime UpdateTime { get;set; }
17.     // 重写 ToString 方法，打印实体类信息
18.     public override string ToString()
19.     {
20.         //SQLite存储日期和时间的方式是以UTC（协调世界时）为基准的，打印时需要转换成本地时间
21.         return $"UserId: {UserId}, " +
22.             $"Email: {UserEmail}," +
23.             $" CreatedTime: {CreateTime.ToLocalTime()}," +
24.             $" UpdateTime: {UpdateTime.ToLocalTime()}";
25.     }
26. }

复制代码

上面用到的 TableName、PrimaryKey、Column 特性根据字面意思很容易理解，需要特别注意 ComputedColumn 相关的三个特性：

• [Ignore] ：此属性将被忽略，并且无法映射到此属性，可以定义一些跟数据库无关但业务需要的属性。
  
• [ResultColumn] ：可以映射到标有 ResultColumn 列的属性，但这些属性不会包含在插入或更新中。需要在 SQL 中显式指定这些列，它不会包含在自动生成的 SQL 中。
  
• [ComputedColumn] ：具有 Computed 列属性的属性的工作方式与 Result 列属性相同，但是它们将在 SQL 中自动选择。
  

数据库类DbFactory

定义一个 DbFactory 类管理连接字符串和数据库实例，映射部分请参考 基于 Fluent / Convention 的映射：

1. public static class DbFactory
2. {
3.     private static DatabaseFactory dbFactory;
5.     public static Database GetDatabase()
6.     {
7.         return dbFactory.GetDatabase();
8.     }
10.     static DbFactory()
11.     {        
12.         dbFactory = DatabaseFactory.Config(x =>
13.         {
14.             // 也可以在这里配置实体的映射关系
15.             x.UsingDatabase(() => new Database(
16.                 "Data Source=mydatabase.db;",
17.                 DatabaseType.SQLite,
18.                 SqliteFactory.Instance)
19.             );            
20.         });
21.         InitDB();
22.     }
24.     static void InitDB()
25.     {
26.         // 创建数据库文件
27.         File.Create("mydatabase.db").Close();
28.         // 创建表
29.         using (IDatabase db = dbFactory.GetDatabase())
30.         {
31.             db.Execute(@"
32.                 -- 创建Users表
33.                 CREATE TABLE IF NOT EXISTS Users (
34.                     UserId INTEGER PRIMARY KEY AUTOINCREMENT,
35.                     Email TEXT,
36.                     CreateTime TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
37.                     UpdateTime TIMESTAMP DEFAULT CURRENT_TIMESTAMP
38.                 );
39.                 -- 创建触发器，在Users 表上的数据更新后自动更新 UpdateTime 字段
40.                 CREATE TRIGGER IF NOT EXISTS update_user_time
41.                 AFTER UPDATE OF Email, CreateTime ON Users
42.                 BEGIN
43.                     UPDATE Users SET UpdateTime = CURRENT_TIMESTAMP WHERE rowid = NEW.rowid;
44.                 END;"
45.             );
46.         }
47.     }
48. }

复制代码

SQLite 并不直接支持在列定义中使用 ON UPDATE 语法，需要创建一个触发器在 Users 表上更新操作发生时自动更新 UpdateTime 字段。触发器触发时为了避免重新触发自身（递归触发），触发器要仅在 UpdateTime 之外的字段被更新时才触发。
增删改查

下面演示一下 Insert、Update、Delete、Query 等操作，简单的项目完全够用了，主程序如下：

1. static void Main(string[] args)
2. {
3.     Insert();
4.     Select();
5.     Thread.Sleep(3000);
6.     Update();
7.     Delete();
8. }

复制代码

Insert

创建一个 Insert 方法，实现单次插入和批量插入：

1. static void Insert()
2. {
3.     using (IDatabase db = DbFactory.GetDatabase())
4.     {
5.         Console.WriteLine("单次插入：");
6.         var user = new User { UserEmail = $"test@example.com" };
7.         db.Insert(user);
8.         Console.WriteLine(user.ToString());
10.         Console.WriteLine("批量插入：");
11.         List<User> users = new List<User>();
12.         for (int i = 0; i < 5; i++)
13.         {
14.             user = new User { UserEmail = $"test{i}@example.com" };
15.             users.Add(user);
16.         }
17.         var count = db.InsertBatch(users);
18.         Console.WriteLine($"批量插入 {count} 条记录");
20.         Console.WriteLine();
21.     }
22. }

复制代码

Select

创建一个 Select 方法，实现常见的查询方法：

1. static void Select()
2. {
3.     using (IDatabase db = DbFactory.GetDatabase())
4.     {
5.         Console.WriteLine("查询所有用户：");
6.         var users = db.Fetch<User>();
7.         users.ForEach(user => Console.WriteLine(user.ToString()));
8.                     
9.         Console.WriteLine("使用SQL语句查询：");
10.         //下面两种方式都可以
11.         users = db.Query<User>("SELECT * FROM Users WHERE Email LIKE @0", "%@example.com").ToList();
12.         users = db.Query<User>("WHERE Email LIKE @0", "%@example.com").ToList();           
13.         users.ForEach(user => Console.WriteLine(user.ToString()));
15.         Console.WriteLine("使用LINQ语句查询ID大于1的用户，并按ID排序：");
16.         //推荐用法LINQ语句查询   
17.         users = db.Query<User>()
18.             .Where(x => x.UserId > 1)
19.             .OrderBy(x => x.UserId)
20.             .ToList();
21.         users.ForEach(user => Console.WriteLine(user.ToString()));
23.         Console.WriteLine("通过ID查询单个用户：");
24.         //SingleById还有很多变体，这里不在单独举例
25.         var user = db.SingleOrDefaultById<User>(1);
26.         Console.WriteLine(user.ToString());
28.         Console.WriteLine();
29.     }
30. }

复制代码

注意：如果找不到记录，SingleById()方法会抛出异常，而 SingleOrDefaultById() 方法会返回 null，推荐使用 SingleOrDefaultById() 方法。
Update

创建一个 Update 方法，实现单个用户更新和批量更新：

1. static void Update()
2. {
3.     using (IDatabase db = DbFactory.GetDatabase())
4.     {
5.         Console.WriteLine("更新单个用户：");
6.         var user = db.SingleById<User>(1);
7.         user.UserEmail = "updated@example.com";
8.         db.Update(user);
9.         Console.WriteLine(db.SingleById<User>(1).ToString());
11.         Console.WriteLine("批量更新 ID > 3 的用户：");
12.         var users = db.Query<User>()
13.             .Where(x => x.UserId > 3).ToList()
14.             .Select(x => UpdateBatch.For(x, db.StartSnapshot(x))).ToList()
15.             .Select(x => { x.Poco.UserEmail = "updated@example.com"; return x; })
16.             .ToList();
17.         db.UpdateBatch(users, new BatchOptions { BatchSize = 50 });
18.         db.Fetch<User>().ForEach(user => Console.WriteLine(user.ToString()));
20.         Console.WriteLine();
21.     }
22. }

复制代码

注意：关于 UpdateBatch 方法的使用，官方文档没有详细说明，使用方法可以参考 UpdateTests
Delete

创建一个 Delete 方法，实现单个用户删除和批量删除：

1. static void Delete()
2. {
3.     using (IDatabase db = DbFactory.GetDatabase())
4.     {
5.         Console.WriteLine("删除单个用户：");
6.         var user = db.SingleById<User>(1);
7.         db.Delete(user);
8.         Console.WriteLine($"删除用户 {user.ToString()} 成功");
10.         Console.WriteLine("使用SQL构造器删除 Id > 4 的：");
11.         var sql = new Sql();
12.         sql.Append("DELETE FROM Users WHERE UserId > @0", 4);
13.         var count=db.Execute(sql);
14.         Console.WriteLine($"删除 {count} 条记录");
16.         Console.WriteLine("使用SQL语句删除 Id > 3 的：");
17.         count = db.Delete<User>("WHERE UserId > @0", 3);
18.         Console.WriteLine($"删除 {count} 条记录");
19.     }
20. }

复制代码

总结

一些简单功能上手比较容易，代码侵入性也比较小。复杂一点的功能上手比较难，因为中文资料少、官方文档也有点落后。
一般的小项目或者小功能模块可以使用NPoco，大项目还是建议使用国产的FreeSQL、SqlSugar。

来源:https://www.cnblogs.com/timefiles/p/18294967
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！