ASP.NET Web应用程序+实体框架4.0并发检查

Question

我有一个这样的实体：

public class Player 
{ 
    [Required] 
    [Key] 
    public int Id { get; set; } 
    [Required] 
    public string FirstName { get; set; } 
    public string LastName { get; set; } 
    public string NativeCountry { get; set; } 
    [ConcurrencyCheck] 
    public DateTime LastModified { get; set; } 
    public virtual int TeamId { get; set; } 

    //navigational property 
    public virtual Team Team { get; set; } 
    public virtual ICollection<Tournament> Tournaments { get; set; } 
} 

这是我如何配置球员实体：

public PlayerConfiguration() 
{ 
    Property(e => e.Id).IsRequired(); 
    Property(e => e.FirstName).IsRequired().IsConcurrencyToken(true); 
    Property(e => e.NativeCountry).IsOptional(); 
    Property(e => e.LastModified).IsOptional().IsConcurrencyToken(true); 

    HasRequired(e => e.Team).WithMany(s => s.Players).HasForeignKey(f => f.TeamId); 
} 

重写OnModelCreating

protected override void OnModelCreating(DbModelBuilder modelBuilder) 
{ 
    Configuration.ValidateOnSaveEnabled = false; 
    Configuration.LazyLoadingEnabled = true; 

    modelBuilder.Configurations.Add(new PlayerConfiguration()); 
    modelBuilder.Configurations.Add(new TeamConfiguration()); 
    modelBuilder.Configurations.Add(new TournamentConfiguration()); 

    modelBuilder.Entity<Player>().ToTable("Player"); 
    modelBuilder.Entity<Team>().ToTable("Team"); 
    modelBuilder.Entity<Tournament>().ToTable("Tournament"); 

    base.OnModelCreating(modelBuilder); 
} 

某处我这样做来更新播放器：

db.Entry<Player>(player).State = System.Data.EntityState.Modified; 
try 
{ 
    db.SaveChanges(); 
} 
catch (DbUpdateConcurrencyException ex) 
{ 

} 

当我尝试使用两个浏览器同时更新任何给定的播放器时，没有任何反应。我不想使用TimeStamp注释，因为它会花费我一个额外的 列。如何使用现有的DateTime LastModified列来跟踪并发性。 我甚至尝试将FirstName（和其他）作为ConcurrencyToken，但是再次没有发生。 这个[ConcurrencyCheck]如何在asp.net web应用程序中工作？ 请帮忙..

Answer 1

它看起来像你的代码不会改变LastModified属性，所以你仍然使用相同的并发令牌。这是人们使用Timestamp列的原因，因为时间戳是由数据库自动处理的，您不必处理它。

要使用并发令牌，您的实体必须遵循非常严格的规则。

• 您的实体必须保持并发标记的旧值（如果是ASP.NET，它需要向客户端发送并发令牌，并使用修改后的数据接收它）。
• 如果您不使用数据库生成的并发令牌（时间戳或行版本），则每次要更改记录时都必须手动设置它
• 如果使用分离的实体，则只能设置新的令牌您将实体上下文，否则你会在您每次尝试保存更新的数据

这里时间得到异常的示例代码，以验证并发检查工作原理：

class Program 
{ 
    static void Main(string[] args) 
    { 
     using (var context = new Context()) 
     { 
      context.Database.Delete(); 
      context.Database.CreateIfNotExists(); 

      context.Players.Add(new Player { FirstName = "ABC", LastName = "EFG", NativeCountry = "XYZ", LastModified = DateTime.Now}); 
      context.SaveChanges(); 
     } 

     using (var context = new Context()) 
     { 
      var player = context.Players.First(); 

      // Break here, go to database and change LastModified date 
      player.LastModified = DateTime.Now; 
      // If you changed LastModified date you will get an exception 
      context.SaveChanges(); 
     } 
    } 
} 

Answer 2

这是我做的到使其工作：

球员实体：

[ConcurrencyCheck] 
public DateTime LastModified { get; set; } 

在我的代码

，形式的onLoad，调用此函数：

private static DateTime TimeStamp; 
protected void LoadData() 
    { 
     Player player = new PlayerRepository().First(plyr => plyr.Id == Id); 
     if (player != null) 
     { 
      TimeStamp = player.LastModified; 
      //rest of the code 
     } 
    } 

，并于即保存按钮的点击，同时更新实体：

protected void btnSave_Click(object sender, EventArgs e) 
    { 
     var playerRepo = new PlayerRepository(); 
     var teamRepo = new TeamRepository(); 

      if (Page.IsValid) 
      { 
      Player player; 
      if (this.Id == 0)//add 
      { 
       player = new Player(); 
       //rest of the code 
      } 
      else //edit 
       player = playerRepo.First(p => p.Id == Id); 

      player.LastModified = DateTime.Now; 

      //custom logic 
      if (this.Id == 0) // add 
      { 
       playerRepo.Add(player); 
       playerRepo.SaveChanges(); 
      } 
      else // edit 
      { 
       try 
       { 
        playerRepo.OriginalValue(player, "LastModified", TimeStamp); 
        playerRepo.SaveChanges(); 
       } 
       catch (DbUpdateConcurrencyException ex) 
       { 
        //custom logic 
       } 

      } 
     } 

和AbstractRepository中的OriginalValue是这样的：

public void OriginalValue(TEntity entity, string propertyName, dynamic value) 
    { 
     Context.Entry<TEntity>(entity).OriginalValues[propertyName] = value; 
    } 

所以明确我必须将ConcurrencyCheck标记列的OriginalValue更改为较旧的列。