C#中如何配置数据库的上下文代理?用于拦截操作?

通过重写SaveChanges或使用拦截器可实现EF Core操作拦截:1. 重写SaveChanges实现自动填充审计字段,如CreatedAt和UpdatedAt;2. 使用DbCommandInterceptor记录SQL执行日志或监控性能;3. 通过ChangeTracker跟踪实体状态变化。根据需求选择合适方式,二者可结合使用。

C#中如何配置数据库的上下文代理?用于拦截操作?

在C#中,特别是使用Entity Framework Core(EF Core)时,所谓的“上下文代理”通常指的是通过拦截数据库上下文的操作来实现如日志记录、性能监控或自动处理某些字段(如创建时间、更新时间)等功能。EF Core本身不直接使用“代理”这个词来描述拦截机制,但可以通过 DbContext 的 SaveChanges 拦截使用 EF Core 的拦截器(Interceptors) 来实现类似效果。

1. 使用 SaveChanges 重写进行操作拦截

最简单的方式是在自定义的 DbContext 中重写 SaveChangesSaveChangesAsync 方法,在数据保存前进行拦截处理。

常见用途包括:

  • 自动设置创建时间、更新时间
  • 记录谁创建或修改了数据
  • 软删除处理(将 IsDeleted 设为 true 而非真正删除)

// 示例:重写 SaveChanges 实现自动字段填充

 public class appDbContext : DbContext {     public override int SaveChanges()     {         UpdateAuditFields();         return base.SaveChanges();     }      public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)     {         UpdateAuditFields();         return base.SaveChangesAsync(cancellationToken);     }      private void UpdateAuditFields()     {         var entities = ChangeTracker.Entries()             .Where(e => e.Entity is IAuditable && (e.State == EntityState.Added || e.State == EntityState.Modified));          foreach (var entry in entities)         {             if (entry.State == EntityState.Added)             {                 ((IAuditable)entry.Entity).CreatedAt = DateTime.UtcNow;             }             ((IAuditable)entry.Entity).UpdatedAt = DateTime.UtcNow;         }     } } 

其中 IAuditable 是一个接口:

C#中如何配置数据库的上下文代理?用于拦截操作?

可画AI

Canva可画魔力工作室,一站式AI智能设计工具平台

C#中如何配置数据库的上下文代理?用于拦截操作?174

查看详情 C#中如何配置数据库的上下文代理?用于拦截操作?

 public interface IAuditable {     DateTime CreatedAt { get; set; }     DateTime UpdatedAt { get; set; } } 

2. 使用 EF Core 内置拦截器(Interceptors)

EF Core 提供了更强大的拦截机制,可以在不修改 DbContext 的情况下,全局监听数据库操作,比如 SQL 执行、连接打开、事务提交等。

拦截器适用于:

  • 记录所有 SQL 执行日志
  • 性能监控(慢查询检测)
  • 自动重试逻辑

// 示例:实现一个命令拦截器

 public class CommandLoggingInterceptor : DbCommandInterceptor {     public override InterceptionResult<DbDataReader> ReaderExecuting(         DbCommand command,         CommandEventData eventData,         InterceptionResult<DbDataReader> result)     {         Console.WriteLine($"执行SQL: {command.CommandText}");         return result;     } } 

// 在 Program.cs 或 Startup 中注册拦截器

 services.AddDbContext<AppDbContext>(options =>     options.UseSqlServer(connectionString)            .AddInterceptors(new CommandLoggingInterceptor())); 

3. 实体状态变更的细粒度控制

除了 SaveChanges 拦截,还可以通过 ChangeTracker 监听实体状态变化,例如判断哪些字段被修改、做差异对比等。

 var entries = ChangeTracker.Entries()     .Where(e => e.State == EntityState.Modified);  foreach (var entry in entries) {     Console.WriteLine($"实体 {entry.Entity.GetType().Name} 被修改");     foreach (var prop in entry.Properties)     {         if (prop.IsModified)         {             Console.WriteLine($"  字段 {prop.Metadata.Name} 从 {prop.OriginalValue} 变为 {prop.CurrentValue}");         }     } } 

基本上就这些。根据需求选择合适的方式:如果只是处理审计字段,重写 SaveChanges 最简单;如果要做全局监控或日志,推荐使用 Interceptors。两者可结合使用,灵活又强大。

相关标签:

app sqlserver c# sql 接口 数据库

上一篇
下一篇
text=ZqhQzanResources