Dapper如何封装通用仓储 Dapper Repository模式实现方法

畫卷琴夢
发布: 2025-12-17 13:25:50
原创
768人浏览过
Dapper通用仓储应借鉴EF思想而非照搬,核心是泛型约束+手写SQL灵活性:定义IRepository接口(GetById/Find/Insert/Update/Delete),实现类通过特性识别主键与列映射,动态生成安全SQL,支持事务参数,分页由具体方法处理,查询逻辑下沉至具体仓储,连接由DI管理。

dapper如何封装通用仓储 dapper repository模式实现方法

用 Dapper 实现通用仓储(Generic Repository)不是要完全照搬 Entity Framework 那套抽象,而是借其思想——统一数据访问入口、减少重复 SQL、提升可测试性与可维护性。核心在于:用泛型约束实体类型,用 Dapper 的轻量扩展能力封装增删改查共性逻辑,同时保留手写 SQL 的灵活性和性能优势。

定义通用仓储接口

先明确契约,避免过度设计。一个实用的 IRepository 通常只需覆盖最常用操作:

  • GetById(id):按主键查单条(约定主键名为 Id 或 T 的 KeyAttribute)
  • GetAll():查全部(慎用,建议带分页)
  • Find(sql, param):自定义查询入口,保持 Dapper 灵活性
  • Insert(entity):插入并返回新 ID(如支持)
  • Update(entity):按主键更新非空/指定字段(可用 Expression 或显式字段列表)
  • Delete(id):按主键删除

实现基础仓储类

继承 IDbConnection 或注入 IDbConnectionFactory,避免在类里 new Connection —— 连接生命周期应由调用方或 DI 控制。关键点:

  • typeof(T).GetProperties() + 自定义特性(如 [Column], [Key])识别映射关系,不依赖约定俗成的 “Id” 名
  • Insert 和 Update 操作生成动态 SQL 时,跳过 readonlystatic 或标记为 [NotMapped] 的属性
  • Update 推荐使用 WHERE Id = @Id + 显式 SET 子句,不走全量更新,避免误覆写
  • 所有方法接受可选 IDbTransaction 参数,方便上层聚合多个操作

处理泛型与 SQL 构建的边界

Dapper 本身不提供 IQueryable,所以不要试图在 IRepository 上加 Where、OrderBy 等 LINQ 方法——那会引入表达式树解析,得不偿失。正确做法是:

  • 把查询逻辑下沉到具体仓储(如 UserRepository),它可继承 Repository 并暴露 FindByEmail(string)FindActiveWithOrders() 等语义化方法
  • 通用接口只留 Find(string sql, object param),让上层拼 SQL 或用 SqlBuilder(Dapper.Contrib 不推荐,但 DapperExtensions 已停更;可轻量封装自己的 SqlBuilder)
  • 分页统一用 OFFSET-FETCH(SQL Server)或 LIMIT-OFFSET(PostgreSQL/MySQL),由具体方法如 GetPaged(sql, param, page, size) 承担

注入与使用示例(.NET 6+)

注册时用作用域生命周期,连接字符串通过工厂创建:

Linfo.ai
Linfo.ai

Linfo AI 是一款AI驱动的 Chrome 扩展程序,可以将网页文章、行业报告、YouTube 视频和 PDF 文档转换为结构化摘要。

Linfo.ai 145
查看详情 Linfo.ai
services.AddScoped(typeof(IRepository<&gt), typeof(Repository<&gt));
services.AddSingleton<IDbConnectionFactory, SqlConnectionFactory>();
登录后复制

业务中使用:

public class UserService {
  private readonly IRepository<User> _userRepo;
  public UserService(IRepository<User> userRepo) => _userRepo = userRepo;

  public async Task<User> GetByOpenIdAsync(string openId) 
    => await _userRepo.FindFirstOrDefaultAsync("WHERE OpenId = @OpenId", new { OpenId = openId });
}
登录后复制

注意:通用仓储不替代领域服务,它只是数据搬运工。复杂业务逻辑、跨表一致性、事务边界仍应在 Application Service 层组织。

基本上就这些。不复杂但容易忽略的是连接管理、主键识别健壮性和 SQL 注入防护——所有参数必须走 Dapper 的 parameterized query,绝不用字符串拼接。

以上就是Dapper如何封装通用仓储 Dapper Repository模式实现方法的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号