EF Core 7中使用EFCore.BulkExtensions时DbCommandInterceptor不生效

EFCore.BulkExtensions的BulkInsertOrUpdateAsync这类批量操作是直接生成原生SQL语句执行，不会将待操作的实体添加到EF Core的ChangeTracker中，所以你在DbCommandInterceptor里通过eventData.Context.ChangeTracker.Entries<ITimeEntity>()获取不到任何实体条目，自然无法修改时间字段。

针对你的Upsert场景，有三种可行的实现方式，按需选择：

方案1：利用EFCore.BulkExtensions的内置配置 #

BulkExtensions支持在批量操作时配置字段的生成规则，直接指定时间字段使用MySQL的时间函数，无需手动修改实体：

var bulkConfig = new BulkConfig
{
    // 配置插入时的字段规则：CreationDate和ModificationDate用UTC时间
    InsertGeneratedColumns = new List<string> { nameof(Client.CreationDate), nameof(Client.ModificationDate) },
    // 配置更新时的字段规则：仅更新ModificationDate
    UpdateGeneratedColumns = new List<string> { nameof(Client.ModificationDate) },
    // 指定使用MySQL的UTC时间函数
    ColumnInputExpr = new Dictionary<string, string>
    {
        { nameof(Client.CreationDate), "UTC_TIMESTAMP()" },
        { nameof(Client.ModificationDate), "UTC_TIMESTAMP()" }
    }
};

await _context.BulkInsertOrUpdateAsync(clients, bulkConfig);

注意：ColumnInputExpr会让批量操作时直接在SQL中使用指定的函数值，而非实体中的原有值，确保时间是数据库端的UTC时间。

方案2：手动预处理实体（适合数据量较小场景） #

如果需要在应用层控制时间值，可以先区分出需要插入和更新的实体，再分别设置时间字段：

// 先查询数据库中已存在的Client Id
var existingIds = await _context.Clients.Where(c => clients.Select(x => x.Id).Contains(c.Id))
                                       .Select(c => c.Id)
                                       .ToListAsync();

foreach (var client in clients)
{
    if (existingIds.Contains(client.Id))
    {
        // 更新操作：仅设置ModificationDate
        client.ModificationDate = DateTime.UtcNow;
    }
    else
    {
        // 插入操作：设置两个时间字段
        client.CreationDate = DateTime.UtcNow;
        client.ModificationDate = DateTime.UtcNow;
    }
}

// 执行批量Upsert
await _context.BulkInsertOrUpdateAsync(clients);

缺点：需要额外查询一次数据库，数据量较大时会影响性能。

方案3：数据库层面配置（最省心的全局方案） #

直接在MySQL数据库中设置默认值和触发器，无论通过EF Core还是其他方式操作数据，都能自动维护时间字段：

1. 修改表结构，给CreationDate设置默认值

ALTER TABLE Clients 
MODIFY COLUMN CreationDate DATETIME DEFAULT UTC_TIMESTAMP(),
MODIFY COLUMN ModificationDate DATETIME;

2. 创建更新触发器

DELIMITER //
CREATE TRIGGER trg_Clients_Update
BEFORE UPDATE ON Clients
FOR EACH ROW
BEGIN
    SET NEW.ModificationDate = UTC_TIMESTAMP();
END //
DELIMITER ;

之后在EF Core的实体配置中，将这两个字段设置为数据库生成：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Client>(entity =>
    {
        entity.Property(c => c.CreationDate)
              .HasDefaultValueSql("UTC_TIMESTAMP()")
              .ValueGeneratedOnAdd();

        entity.Property(c => c.ModificationDate)
              .ValueGeneratedOnUpdate();
    });
}

这样无论是批量Upsert还是普通的Add/Update操作，时间字段都会自动被维护，无需在代码中额外处理。

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