构建高复用.NET Core数据访问层的架构设计与实战在当今快速迭代的开发环境中数据访问层的设计质量直接影响着整个应用的可维护性和扩展性。许多团队都面临着一个共同痛点随着业务增长数据访问代码逐渐变得臃肿且难以管理。本文将分享一套经过多个中大型项目验证的通用数据访问层架构基于SqlSugar ORM和SQL Server实现但设计理念适用于任何数据库系统。1. 基础架构设计与核心组件1.1 分层架构的价值与实现良好的分层架构应该像乐高积木一样每个模块都能独立替换而不影响整体结构。在我们的设计中数据访问层分为三个关键部分基础设施层处理数据库连接、事务管理等底层操作仓储抽象层定义统一的数据操作接口服务实现层提供具体的业务逻辑实现这种分层带来的直接好处是当需要从SQL Server迁移到MySQL时只需修改基础设施层的实现业务代码几乎无需改动。1.2 核心组件关系图// 核心接口定义示例 public interface IBaseRepositoryT where T : class, new() { TaskT GetByIdAsync(object id); TaskListT GetListAsync(ExpressionFuncT, bool whereExpression); Taskbool InsertAsync(T entity); Taskbool UpdateAsync(T entity); Taskbool DeleteAsync(object id); }这个基础接口定义了最常用的CRUD操作所有具体仓储都将实现这个接口。值得注意的是我们使用了泛型约束where T : class, new()这确保了类型安全性。2. SqlSugar深度集成与优化2.1 上下文配置最佳实践SqlSugar的SqlSugarScope相比传统的SqlSugarClient具有更好的线程安全性和性能表现。以下是推荐的配置方式services.AddScopedISqlSugarClient(provider { var config new ConnectionConfig() { ConnectionString Configuration.GetConnectionString(Default), DbType DbType.SqlServer, IsAutoCloseConnection true }; var scope new SqlSugarScope(config, db { // 全局过滤器配置 db.QueryFilter.Add(new SqlFilterEntity { FilterValue entity entity.IsDeleted false }); // 更多全局配置... }); return scope; });2.2 高级查询功能封装对于复杂查询场景我们设计了链式API来提升开发体验public async TaskPageResultT QueryPageAsyncT( ExpressionFuncT, bool whereExpression, int pageIndex 1, int pageSize 10, ExpressionFuncT, object orderByExpression null, OrderByType orderByType OrderByType.Asc) where T : class, new() { var totalCount 0; var list await _db.QueryableT() .Where(whereExpression) .OrderByIF(orderByExpression ! null, orderByExpression, orderByType) .ToPageListAsync(pageIndex, pageSize, totalCount); return new PageResultT(pageIndex, pageSize, totalCount, list); }这个分页查询方法处理了条件过滤、排序和分页逻辑返回统一的分页结果对象。3. 事务管理与性能优化3.1 分布式事务处理模式在微服务架构下事务管理变得更加复杂。我们实现了两种事务模式事务类型适用场景实现复杂度性能影响本地事务单数据库操作低低分布式事务跨服务调用高中高对于大多数场景建议使用补偿事务模式而非传统的两阶段提交public async Taskbool ExecuteWithTransactionAsync(FuncTask action) { try { _db.Ado.BeginTran(); await action(); _db.Ado.CommitTran(); return true; } catch { _db.Ado.RollbackTran(); // 记录日志并触发补偿机制 await _compensationService.CompensateAsync(); return false; } }3.2 查询性能优化技巧在实际项目中我们总结了几个有效的性能优化策略延迟加载与贪婪加载的选择一对一关系使用Mapper特性一对多关系考虑使用Include方法批量操作优化// 普通插入 await _db.Insertable(list).ExecuteCommandAsync(); // 批量插入性能提升5-10倍 await _db.FastestOrder().BulkCopyAsync(list);二级缓存实现services.AddDistributedMemoryCache(); public async TaskListT GetCachedListAsync(string cacheKey, ExpressionFuncT, bool whereExpression) { if (_cache.TryGetValue(cacheKey, out ListT cachedData)) return cachedData; var data await GetListAsync(whereExpression); _cache.Set(cacheKey, data, TimeSpan.FromMinutes(30)); return data; }4. 实战学生管理系统案例4.1 领域模型设计在学生管理系统中我们定义了以下核心实体[SugarTable(Students)] public class Student { [SugarColumn(IsPrimaryKey true, IsIdentity true)] public int Id { get; set; } [SugarColumn(Length 50)] public string Name { get; set; } [SugarColumn(IsNullable true)] public int? Age { get; set; } [Navigate(typeof(StudentCourse), nameof(StudentCourse.StudentId), nameof(StudentCourse.CourseId))] public ListCourse Courses { get; set; } }4.2 业务服务实现基于通用仓储的学生服务实现示例public class StudentService : IStudentService { private readonly IBaseRepositoryStudent _studentRepo; public StudentService(IBaseRepositoryStudent studentRepo) { _studentRepo studentRepo; } public async TaskStudentDetailDto GetStudentDetailAsync(int id) { var student await _studentRepo.GetByIdAsync(id); if (student null) throw new NotFoundException(Student not found); return new StudentDetailDto { Id student.Id, Name student.Name, CourseCount student.Courses?.Count ?? 0 }; } }4.3 异常处理策略我们设计了分层的异常处理机制数据访问异常转换为自定义的DataAccessException业务规则异常使用BusinessException封装验证异常通过FluentValidation集成 重要提示永远不要将原始数据库异常直接暴露给客户端这可能导致敏感信息泄露5. 测试策略与持续集成5.1 单元测试模式对于数据访问层的测试我们采用内存数据库模拟数据的策略[Fact] public async Task GetByIdAsync_ShouldReturnStudent_WhenExists() { // 准备 var testStudent new Student { Id 1, Name Test }; _db.Insertable(testStudent).ExecuteCommand(); // 执行 var result await _studentRepo.GetByIdAsync(1); // 断言 Assert.NotNull(result); Assert.Equal(Test, result.Name); }5.2 集成测试要点集成测试需要关注数据库连接管理事务隔离级别并发控制性能基准建议使用TestContainers来创建真实的数据库实例进行测试而不是模拟。6. 扩展与定制化这套架构在实际项目中展示了惊人的灵活性。在某金融项目中我们仅用两天就完成了从SQL Server到Oracle的迁移在另一个电商项目中团队基于这个基础快速实现了多租户支持。关键在于始终保持接口稳定而实现可替换的设计原则。对于需要特殊定制的场景可以通过装饰器模式扩展功能而不修改核心代码public class AuditLogRepositoryDecoratorT : IBaseRepositoryT where T : class, new() { private readonly IBaseRepositoryT _inner; private readonly IAuditLogger _logger; public AuditLogRepositoryDecorator( IBaseRepositoryT inner, IAuditLogger logger) { _inner inner; _logger logger; } public async Taskbool InsertAsync(T entity) { await _logger.LogAsync(Insert, entity); return await _inner.InsertAsync(entity); } // 其他方法实现... }在最近的一个物联网项目中团队基于这个架构每天处理超过200万条设备数据系统稳定运行了8个月零故障。这种成功不是偶然的而是源于严谨的架构设计和持续的代码优化。