外部服务同步失败时，如何用Entity Framework Core恢复实体原始值？

要恢复数据库提交后的实体原始值，核心是在修改实体前提前保存原始状态的副本——因为调用SaveChangesAsync()后，EF Core的ChangeTracker会清空变更记录，且数据库已经写入修改后的数据，此时无法从ChangeTracker或数据库直接获取原始值。

以下是几种可行的实现方式：

1. 手动保存关键字段值（适合字段较少的场景） #

在修改实体前，单独记录需要恢复的字段原始值：

// 步骤1：获取实体后立即保存原始值
var entity = context.Set<MyEntity>().Include(x => x.RelatedEntity).Find(id);
var originalName = entity.Name;
var originalRelatedStatus = entity.RelatedEntity.Status;

// 步骤2：修改并提交数据库
entity.Name = "Changed name";
entity.RelatedEntity.Status = "Approved";
await context.SaveChangesAsync();

// 步骤3：调用外部服务
var response = externalService.Save(entity);

// 步骤4：失败时恢复
if (response.StatusCode != 200)
{
    entity.Name = originalName;
    entity.RelatedEntity.Status = originalRelatedStatus;
    await context.SaveChangesAsync();
}

2. 利用EF Core的OriginalValues保存原始状态（推荐复杂实体） #

通过EF的Entry API获取并克隆原始值集合，避免手动维护字段：

// 步骤1：获取实体后保存原始值集合
var entity = context.Set<MyEntity>().Include(x => x.RelatedEntity).Find(id);
var entityOriginalValues = context.Entry(entity).OriginalValues.Clone();
var relatedOriginalValues = context.Entry(entity.RelatedEntity).OriginalValues.Clone();

// 步骤2：修改并提交数据库
entity.Name = "Changed name";
entity.RelatedEntity.Status = "Approved";
await context.SaveChangesAsync();

// 步骤3：调用外部服务
var response = externalService.Save(entity);

// 步骤4：失败时恢复
if (response.StatusCode != 200)
{
    // 将原始值应用回实体
    entityOriginalValues.ApplyTo(entity);
    relatedOriginalValues.ApplyTo(entity.RelatedEntity);
    await context.SaveChangesAsync();
}

3. 深拷贝实体（通用场景） #

通过序列化实现实体的深拷贝，完整保存原始状态（需引入Newtonsoft.Json或System.Text.Json）：

// 步骤1：获取实体后深拷贝原始实体
var entity = context.Set<MyEntity>().Include(x => x.RelatedEntity).Find(id);
// 用Newtonsoft.Json序列化实现深拷贝
var originalEntity = JsonConvert.DeserializeObject<MyEntity>(JsonConvert.SerializeObject(entity));

// 步骤2：修改并提交数据库
entity.Name = "Changed name";
entity.RelatedEntity.Status = "Approved";
await context.SaveChangesAsync();

// 步骤3：调用外部服务
var response = externalService.Save(entity);

// 步骤4：失败时恢复
if (response.StatusCode != 200)
{
    // 覆盖当前实体的属性值
    context.Entry(entity).CurrentValues.SetValues(originalEntity);
    context.Entry(entity.RelatedEntity).CurrentValues.SetValues(originalEntity.RelatedEntity);
    await context.SaveChangesAsync();
}

注意事项 #

• 不要使用context.Entry(entity).Reload()：调用SaveChangesAsync()后数据库已写入修改后的数据，Reload只会加载修改后的值，无法恢复原始状态。
• 当前模式存在数据一致性风险：如果回滚数据库的操作也失败，会导致数据库与外部服务数据不一致。更可靠的方案是先调用外部服务（确保成功）再修改数据库，或使用分布式事务、补偿事务机制。

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