在ABP中,你可以使得Entity直接继承接口 IHasConcurrencyStamp
然后再EF中的XXXDbContextModelCreatingExtensions中的ConfigureByConvention会看到如下代码
public static void TryConfigureConcurrencyStamp(this EntityTypeBuilder b){if (b.Metadata.ClrType.IsAssignableTo<IHasConcurrencyStamp>()){b.Property("ConcurrencyStamp").IsConcurrencyToken().HasMaxLength(40).HasColumnName("ConcurrencyStamp");}}
上面表示有这个字段ConcurrencyStamp的时候,设置为IsConcurrencyToken,这东西和RowVersion都是为了处理并发写入的问题
举个例子有一个数据A.age X读取的时候为1,Y读取的时候为1,这个时候X提交修改为3,然后Y又提交修改为2,按照默认这个提交是可以完成的,不过对于Y来说,我是从1修改到2,而实际是3修改为2,所以应该要引发异常!
某一个模型要引入这个IHasConcurrencyStamp 我们只需要这个操作
/// <summary>/// 工作流规则/// </summary>[Comment("工作流规则")]public class LineRoute : Entity<int>,IHasConcurrencyStamp{// ... /// <summary>/// ConcurrencyStamp/// </summary>public string ConcurrencyStamp { get; set; }// ...}
然后我们在EF中的XXXDbContext.cs中执行重写
/// <summary>/// 重写修改的时候,注意有好多个/// </summary>/// <returns></returns>public override int SaveChanges(){this.ChangeTracker.DetectChanges();var modity = this.ChangeTracker.Entries().Where(x => x.State == EntityState.Modified || x.State == EntityState.Added).Select(x => x.Entity).ToList();foreach (var item in modity){item?.GetType().GetProperty("ConcurrencyStamp")?.SetValue(item, Guid.NewGuid().ToString());}return base.SaveChanges();}
以上的代码意思是遍历有变动的Entitys,如果有这个字段ConcurrencyStamp,则执行新的值得写入
注意SaveChanges有好多个,每一个都需要重写,不然就漏了
以上修改后,就实现了并发修改的问题了!
RowVersion据说目前只支持MSSQL,每次写入或者更新会修改一个新的值,ConcurrencyStamp可以看作是他的妥协版本,需要用户手动设置,然后在生成的SQL语句中,会附带比如
update xxx set xxxx xxx where id=xxx and ConcurrencyStamp=xxx 从而实现对写入的校验!