如何在数据层而非控制器中使用Entity Framework DbContext

1. 在App.Business层封装Repository（核心步骤） #

你需要在App.Business层定义数据操作的接口与实现类，把DbContext的访问完全封装在这个层内，控制器只依赖Repository接口，不直接接触DbContext。

比如先定义具体业务的Repository接口：

// App.Business/IUserRepository.cs
public interface IUserRepository
{
    Task<User> GetUserByIdAsync(int id);
    Task AddUserAsync(User user);
    // 按需添加其他数据操作方法
}

然后实现该接口，仅在实现类中注入DbContext：

// App.Business/UserRepository.cs
public class UserRepository : IUserRepository
{
    private readonly YourDbContext _dbContext;

    public UserRepository(YourDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public async Task<User> GetUserByIdAsync(int id)
    {
        return await _dbContext.Users.FindAsync(id);
    }

    public async Task AddUserAsync(User user)
    {
        await _dbContext.Users.AddAsync(user);
        await _dbContext.SaveChangesAsync();
    }
}

如果需要通用Repository减少重复代码，可定义通用接口与基类：

// App.Business/IRepository.cs
public interface IRepository<T> where T : class
{
    Task<T> GetByIdAsync(int id);
    Task AddAsync(T entity);
    Task SaveChangesAsync();
}

// App.Business/Repository.cs
public class Repository<T> : IRepository<T> where T : class
{
    protected readonly YourDbContext _dbContext;
    protected readonly DbSet<T> _dbSet;

    public Repository(YourDbContext dbContext)
    {
        _dbContext = dbContext;
        _dbSet = dbContext.Set<T>();
    }

    public async Task<T> GetByIdAsync(int id)
    {
        return await _dbSet.FindAsync(id);
    }

    public async Task AddAsync(T entity)
    {
        await _dbSet.AddAsync(entity);
    }

    public async Task SaveChangesAsync()
    {
        await _dbContext.SaveChangesAsync();
    }
}

2. 配置依赖注入（Program.cs） #

在项目入口Program.cs中，先注册DbContext，再将App.Business层的Repository接口与实现类绑定，确保控制器只能获取Repository实例：

// Program.cs
var builder = WebApplication.CreateBuilder(args);

// 1. 注册DbContext（保持原有配置，比如SQL Server）
builder.Services.AddDbContext<YourDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection")));

// 2. 注册具体Repository：接口映射到实现类，生命周期用Scoped（与DbContext一致）
builder.Services.AddScoped<IUserRepository, UserRepository>();
// 若使用通用Repository，注册方式如下：
builder.Services.AddScoped(typeof(IRepository<>), typeof(Repository<>));

// 3. 添加控制器（保持原有配置）
builder.Services.AddControllersWithViews();

var app = builder.Build();

// 中间件配置等后续代码...
app.Run();

3. 控制器中仅依赖Repository接口 #

控制器只注入Repository接口，完全不直接引用DbContext：

// App.Controllers/UserController.cs
public class UserController : ControllerBase
{
    private readonly IUserRepository _userRepository;

    public UserController(IUserRepository userRepository)
    {
        _userRepository = userRepository;
    }

    [HttpGet("{id}")]
    public async Task<IActionResult> GetUser(int id)
    {
        var user = await _userRepository.GetUserByIdAsync(id);
        return user == null ? NotFound() : Ok(user);
    }

    [HttpPost]
    public async Task<IActionResult> AddUser(User user)
    {
        await _userRepository.AddUserAsync(user);
        return CreatedAtAction(nameof(GetUser), new { id = user.Id }, user);
    }
}

4. 关键注意事项 #

• 确保App.Controllers层不直接引用DbContext所在类库，仅引用App.Business层的接口。
• 若之前尝试Repository失败，检查以下几点：
  • 是否正确注册了接口与实现类的依赖关系
  • Repository构造函数是否正确接收DbContext实例
  • 控制器注入的是否是接口而非具体实现类

内容的提问来源于stack exchange，提问作者Antoine Doublet