Rabbit.Common.Data.Dapper 1.3.1

Rabbit.Common.Data.Dapper

Dapper micro-ORM component supporting MySQL and SQL Server with transaction scope, stored procedures, and batch operations. Inject IDapperHelper.

Dapper 数据库访问组件，支持 SQL Server 和 MySQL。

安装

dotnet add package Rabbit.Common.Data.Dapper

注册服务

单数据库配置

using Rabbit.Common.Data.Dapper;

services.AddDapperConfigure(
    DapperDbType.MySql,
    "Server=localhost;Database=mydb;User=root;Password=123456;",
    saveQueryLog: false,
    saveCommandLog: false
);

多数据库配置

services.AddDapperMapConfigure(
    "mydb",
    DapperDbType.MySql,
    "Server=localhost;Database=mydb;User=root;Password=123456;"
);

services.AddDapperMapConfigure(
    "orderdb",
    DapperDbType.SqlServer,
    "Server=.;Database=orderdb;User=sa;Password=123456;"
);

使用方式

单数据库

public class UserService
{
    private readonly IDapperHelper _db;

    public UserService(IDapperHelper db)
    {
        _db = db;
    }

    public async Task<List<User>> GetUsersAsync()
    {
        return await _db.QueryAsync<User>("SELECT * FROM users");
    }
}

多数据库

using Microsoft.Extensions.DependencyInjection;

public class OrderService
{
    private readonly IDapperHelper _orderDb;
    private readonly IDapperHelper _logDb;

    public OrderService(
        [FromKeyedServices("orderdb")] IDapperHelper orderDb,
        [FromKeyedServices("logdb")] IDapperHelper logDb)
    {
        _orderDb = orderDb;
        _logDb = logDb;
    }
}

主要方法

查询方法

• QueryAsync<T> - 查询列表
• QueryFirstOrDefaultAsync<T> - 查询单个
• ExecuteScalarAsync<T> - 查询单个值

执行方法

• ExecuteAsync - 执行 SQL（INSERT/UPDATE/DELETE）
• QueryProAsync<T> - 执行存储过程（查询）
• ExecuteProAsync - 执行存储过程（命令）

CRUD 方法

• Insert/InsertAsync - 插入单个实体
• InsertBatch/InsertBatchAsync - 批量插入
• Get/GetAsync - 根据 ID 获取
• Update/UpdateAsync - 更新实体
• Delete/DeleteAsync - 删除实体

事务支持

推荐方式：使用 BeginTransaction（自动管理连接）

// 使用 using 确保连接和事务正确释放
using var scope = _db.BeginTransaction();
try
{
    await _db.ExecuteAsync("UPDATE users SET balance = balance - 100 WHERE id = 1", transaction: scope.Transaction);
    await _db.ExecuteAsync("UPDATE users SET balance = balance + 100 WHERE id = 2", transaction: scope.Transaction);
    scope.Commit();
}
catch
{
    // 异常时自动回滚（Dispose 中处理）
    throw;
}

实体定义

使用 Dapper.Contrib 特性定义实体：

using Dapper.Contrib.Extensions;

[Table("users")]
public class User
{
    [Key]
    [ExplicitKey]  // 如果是自增主键使用 [Key]，如果是手动指定使用 [ExplicitKey]
    public long Id { get; set; }

    public string Name { get; set; }

    public int Age { get; set; }
}

支持的数据库类型

• DapperDbType.MySql - MySQL
• DapperDbType.SqlServer - SQL Server

日志说明

• 查询/命令执行时间超过 500ms 会自动记录慢查询日志
• 可通过 saveQueryLog 和 saveCommandLog 参数强制记录所有日志
• CRUD 操作日志会显示表名，便于调试