EF Core泛型仓储使用FindAsync/FirstOrDefaultAsync查询数据库的问题

问题背景 #

我尝试实现一个用于CRUD操作的泛型仓储，以下是对应的接口与实现代码：

接口定义 #

public interface IGenericRepository<T> where T : class
{
    Task<IEnumerable<T>> GetAllAsync();
    Task<T?> GetByIdAsync(int id);
    void Insert(T obj);
    void Update(T obj);
    void Delete(object id);
    Task SaveAsync();
}

仓储实现 #

using Microsoft.EntityFrameworkCore;  
using Sirjan.Models;

public class GenericRepository<T> : IGenericRepository<T> where T : class  
{
    public SirjanContext? _context = null;
    public DbSet<T>? table = null;

    public GenericRepository()
    {
        this._context = new SirjanContext();
        table = _context.Set<T>();
    }

    public GenericRepository(SirjanContext _context)
    {
        this._context = new SirjanContext();
        table = _context.Set<T>();
    }

    public async Task<IEnumerable<T>> GetAllAsync()
    {
        return await table!.ToListAsync();
    }

    public async Task<T?> GetByIdAsync(int id)
    {
        var item = await table.FirstOrDefaultAsync(i=> i.Id = id);
        if(item == null)
        return null;            
    }

    public void Insert(T obj)
    {
        table!.Add(obj);
    }

    public void Update(T obj)
    {
        table!.Attach(obj);
        _context!.Entry(obj).State = EntityState.Modified;
    }

    public void Delete(object id)
    {
        T existing = table!.Find(id)!;
        table.Remove(existing);
    }

    public async Task SaveAsync()
    {
       await _context!.SaveChangesAsync();
    } 
}

遇到的错误 #

1. GetByIdAsync编译错误 #

使用var item = await table.FirstOrDefaultAsync(i=> i.Id == id);时出现错误：

'T' does not contain a definition for 'Id' and no accessible extension method 'Id' accepting a first argument of type 'T' could be found (are you missing a using directive or an assembly reference?)

2. Delete方法中Find无法处理关联表 #

涉及一对多关联表时，var item = await table.Find(id);无法正常工作。

解决方案 #

解决Id属性访问问题 #

泛型约束仅限定T : class，编译器无法确认所有实体都包含Id属性，需定义统一的基类或接口规范实体结构：

步骤1：定义基类/接口

// 抽象基类方案
public abstract class BaseEntity
{
    public int Id { get; set; }
}

// 接口方案
public interface IBaseEntity
{
    int Id { get; set; }
}

步骤2：修改泛型约束

更新接口与仓储类的泛型约束，限定T必须继承/实现上述基类或接口：

// 接口修改
public interface IGenericRepository<T> where T : class, IBaseEntity // 或 BaseEntity
{
    // 原有方法保持不变
}

// 仓储类修改
public class GenericRepository<T> : IGenericRepository<T> where T : class, IBaseEntity // 或 BaseEntity
{
    // 原有代码不变，此时i.Id可被编译器识别
}

// 所有实体类需实现IBaseEntity或继承BaseEntity
// 示例：
public class Product : BaseEntity
{
    // 其他业务属性
}

修复GetByIdAsync语法错误

原代码中i.Id = id是赋值操作，需改为判断相等的i.Id == id，同时补全方法返回逻辑：

public async Task<T?> GetByIdAsync(int id)
{
    return await table!.FirstOrDefaultAsync(i => i.Id == id);
}

解决Find方法无法处理关联表的问题 #

Find仅能根据主键查询，且默认不加载关联数据，可通过以下两种方式解决：

方案1：显式加载关联数据

针对需要关联数据的场景，可在特定实体的仓储子类中重写方法，使用Include加载导航属性：

public class ProductRepository : GenericRepository<Product>
{
    public ProductRepository(SirjanContext context) : base(context) { }

    public async Task<Product?> GetByIdWithCategoriesAsync(int id)
    {
        return await table!.Include(p => p.Categories).FirstOrDefaultAsync(p => p.Id == id);
    }
}

方案2：用FirstOrDefault替代Find

若主键为int类型，直接使用FirstOrDefault配合Id查询，同时按需添加关联数据加载逻辑：

public void Delete(object id)
{
    int intId = Convert.ToInt32(id);
    var existing = table!.FirstOrDefault(i => i.Id == intId);
    if(existing != null)
        table.Remove(existing);
}

额外优化点 #

1. 修复构造函数依赖注入问题：当前带参数的构造函数未使用传入的上下文，而是重新实例化，会导致依赖注入失效，修改为：

public GenericRepository(SirjanContext _context)
{
    this._context = _context; // 直接使用传入的上下文实例
    table = _context.Set<T>();
}

2. 完善空值检查：避免过度使用非空断言!，添加空值校验确保上下文和DbSet有效：

public GenericRepository(SirjanContext context)
{
    _context = context ?? throw new ArgumentNullException(nameof(context));
    table = _context.Set<T>() ?? throw new InvalidOperationException($"无法获取实体类型 {typeof(T)} 的DbSet");
}

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