Table of Contents

数据与发件箱

EF Core

public class TodoDbContext : DbContext, ILedonDbContext { /* ... */ }

实现 ILedonDbContext 即被自动注册，并在启动时（先于所有模块初始化）自动建库/迁移——有挂起迁移走 Migrate，否则 EnsureCreated。

builder.Services.AddLedonData(o => o.AutoMigrate = false);   // 自己管理 schema 时关闭

领域事件（保存后自动分发）

实体实现 IHasDomainEvents（或继承 Entity），SaveChangesAsync 成功后事件经 IEventBus 自动分发：

public class Widget : Entity
{
    public int Id { get; set; }
    public string Name { get; set; } = string.Empty;

    public void Create(string name)
    {
        Name = name;
        AddDomainEvent(new WidgetCreated(name));
    }
}

// 处理器照常写（约定自动发现注入）
public class WidgetCreatedHandler : IEventHandler<WidgetCreated> { /* ... */ }
  • 事件在数据提交后分发（处理器能看到已提交的数据）；
  • 分发失败只记日志不重滚（数据已提交）；需要可靠投递用发件箱；
  • 关闭：AddLedonData(o => o.DispatchDomainEvents = false)。

查询：规约 / 分页 / 动态排序

// 1) 规约：把"查什么"封装成可复用对象
public class CheapWidgetsSpec : Specification<Widget>
{
    public CheapWidgetsSpec()
    {
        Where(w => w.Price <= 20);
        OrderBy(w => w.Price);
        Include(w => w.Tags);
    }
}

var cheap = await db.Widgets.ApplySpecification(new CheapWidgetsSpec()).ToListAsync(ct);

// 2) 分页（自动算总数）
var page = await db.Widgets.OrderBy(w => w.Name).ToPagedResultAsync(page: 1, pageSize: 20, ct);
// page.Items / page.TotalCount / page.TotalPages / HasNext...

// 3) 动态排序（API 的 ?sort= 参数；无效字段名退化为默认排序，不 500）
var sorted = db.Widgets.ApplyOrdering("Price desc", w => w.Name);

通用仓储（可选）

框架不强制仓储层；想要时按实体自动注册：

builder.Services.AddLedonData(o => o.UseRepositories = true);

public class WidgetService(IRepository<Widget> widgets)
{
    public Task<Widget?> GetAsync(int id) => widgets.GetByIdAsync(id);                 // 默认不跟踪
    public Task<Widget?> GetForUpdateAsync(int id) => widgets.GetByIdForUpdateAsync(id); // 跟踪，随后可改
    public Task<IReadOnlyList<Widget>> CheapAsync() =>
        widgets.ListAsync(new CheapWidgetsSpec());
    public async Task CreateAsync(Widget w) { await widgets.AddAsync(w); await widgets.SaveChangesAsync(); }
}
  • 读接口默认 AsNoTracking：GetByIdAsync / ListAsync / FirstOrDefaultAsync / PagedAsync；
  • 需要修改时用 GetByIdForUpdateAsync / FirstOrDefaultForUpdateAsync（跟踪查询），或直接 Query() 自行组合；
  • 按主键查询同样尊重全局查询过滤器（软删除/多租户），不会因为本地已追踪实体而绕过过滤；
  • 复合主键传数组：GetByIdAsync(new object?[] { tenantId, id })，顺序与 HasKey 定义一致；
  • 主键类型不受限制（int / long / Guid / string / 复合键）。

仓储与 DbContext 可混用（同一作用域、同一变更追踪）——复杂查询直接注入 DbContext 即可。

审计字段与软删除

实现标记接口即约定生效（AddLedonData(o => o.EnableAuditing = true) 后自动填充时间戳/操作人）：

public class Order : IAudited          // CreatedAt/CreatedBy/ModifiedAt/ModifiedBy 自动填充
{
    public Guid Id { get; set; }
    public DateTime CreatedAt { get; set; }
    public string? CreatedBy { get; set; }
    public DateTime? ModifiedAt { get; set; }
    public string? ModifiedBy { get; set; }
}

public class Customer : IAudited, ISoftDelete   // 删除操作自动转换为 IsDeleted = true 更新
{
    public bool IsDeleted { get; set; }
    // ...
}
  • 操作人来源：注册 IAuditUserAccessor 实现（Web 场景用 Ledon.Security 的 ICurrentUser 适配）；不注册则只填时间戳；
  • 软删除转换默认开启（AutoSoftDelete），行不出库；
  • 查询过滤需显式启用（与多租户一致的显式边界，避免"查出来的行数悄悄变少"）：
protected override void OnModelCreating(ModelBuilder modelBuilder) =>
    modelBuilder.ApplySoftDeleteFilters();   // ISoftDelete 实体自动加 !IsDeleted 过滤
  • DbContext 发现尊重 [DisableAutoDiscovery]（测试夹具/仅手动注册的上下文不参与自动发现）。

连接弹性

builder.Services.AddLedonData(o => o.EnableRetryOnFailure = true);   // 瞬断重试（默认 3 次）

自动定位数据库提供程序的 EnableRetryOnFailure 扩展（SqlServer/Npgsql 等）；提供程序没有该扩展时静默跳过（如 SQLite 不支持瞬断重试）。也可在自行配置 DbContext 时手动调用 optionsBuilder.EnableRetryOnFailure()。

发件箱（Outbox）

跨进程/要求可靠投递的集成事件，事件与业务数据同事务落库，调度器随后投递（至少一次语义）：

public class OrderDbContext : OutboxDbContext;   // 继承即获得 OutboxMessages

// 业务事务：事件与数据同一次 SaveChanges
outbox.Add(new OrderPlaced(orderId));
await db.SaveChangesAsync();

投递语义、重试与搁置策略详见后台队列与发件箱。

相关主题

编辑本文