C#怎么使用Dapper Dapper连接数据库与查询方法

Dapper 是轻量级高性能 .NET ORM,基于 ADO.NET 封装,不生成 SQL,专注参数化查询与结果映射;支持多数据库、动态对象、多结果集、事务及异步操作,需手动管理连接与事务。

Dapper 是一个轻量级、高性能的 .NET ORM(对象关系映射)库,它不替代 ADO.NET,而是在其基础上封装了常用操作,让 SQL 查询更简洁、类型更安全。它不生成 SQL,也不做复杂映射,核心是“用最简方式把 SQL 结果映射成对象”。下面直接讲怎么用——以 SQL Server 为例,其他数据库(如 MySQL、PostgreSQL)只需换连接字符串和驱动即可。

安装 Dapper 和数据库驱动

在项目中通过 NuGet 安装:

  • Dapper:核心库,提供扩展方法(如 Query()Execute()
  • Microsoft.Data.SqlClient(推荐)或 System.Data.SqlClient(旧版):SQL Server 官方驱动
  • 如果是 MySQL,装 Pomelo.EntityFrameworkCore.MySqlMySqlConnector + Dapper;PostgreSQL 用 Npgsql

基础连接与查询(单对象/列表)

所有操作都基于 IDbConnection。Dapper 通过扩展方法注入功能,不需要继承或配置上下文。

  • 创建连接:用 new SqlConnection(connectionString),建议配合 using 确保释放
  • 查单条:用 QueryFirstOrDefault()(没结果返回 null)或 QuerySingle()(必须有且仅1条,否则异常)
  • 查多条:用 Query(),返回 IEnumerable,可转 .ToList()
  • 执行非查询(增删改):用 Execute(),返回影响行数

示例:

string connStr = "Server=.;Database=testdb;Trusted_Connection=true;";
using var conn = new SqlConnection(connStr);
conn.Open();

// 查询用户列表 var users = conn.Query("SELECT * FROM Users WHERE Age > @age", new { age = 18 }).ToList();

// 查询单个用户 var user = conn.QueryFirstOrDefault("SELECT * FROM Users WHERE Id = @id", new { id = 1 });

// 插入 int rows = conn.Execute("INSERT INTO Users (Name, Age) VALUES (@name, @age)", new { name = "张三", age = 25 });

参数化查询与动态对象支持

Dapper 原生支持命名参数(@xxx),自动匹配匿名对象或强类型对象的属性名,大小写敏感但不区分数据库字段别名大小写(取决于数据库本身)。

  • 传参推荐用匿名对象(new { a = 1, b = "x" })或实体类实例,避免字符串拼接防 SQL 注入
  • 查未知结构数据?用 Query(),返回 IDictionary 风格的动态对象,属性名即列名
  • 多结果集(如一次返回用户+订单)?用 QueryMultiple() + Read() 分步读取

事务与异步支持

Dapper 完全兼容 ADO.NET 的事务和 async/await。

  • 事务:用 conn.BeginTransaction(),传给 Query()Execute()transaction 参数
  • 异步方法:所有主方法都有对应异步版本,如 QueryAsync()ExecuteAsync()QueryMultipleAsync()
  • 注意:异步方法需调用方 await,连接也建议用 OpenAsync()

示例事务:

using var conn = new SqlConnection(connStr);
await conn.OpenAsync();
using var tx = conn.BeginTransaction();
try
{
    await conn.ExecuteAsync("INSERT ...", new { ... }, tx);
    await conn.ExecuteAsync("UPDATE ...", new { ... }, tx);
    tx.Commit();
}
catch
{
    tx.Rollback();
    throw;
}

基本上就这些。Dapper 不复杂但容易忽略细节:比如参数名必须严格匹配、连接要自己管理生命周期、没有迁移或实体跟踪——它只做一件事:快而稳地跑 SQL 并映射结果。