首页 > 数据库> 文章详细

EntityFramework系列：MySql的RowVersion

2020-01-11 09:02:22 阅读：296 来源： 互联网

标签：RowVersion EntityFramework Version MySql var SaveChanges Row

无需修改实体和配置，在MySql中使用和SqlServer一致的并发控制。修改RowVersion类型不可取，修改为Timestamp更不可行。Sql Server的RowVersion生成一串唯一的二进制保证Row的版本，无关TimeStamp，更无论TimeStamp的精度问题。使用MySql触发器只能解决uuid的插入的默认值和更新的随机值，由于MySql的自身为了防止无限递归的策略，它的触发器无法在当前表的触发器中更新当前表，所以触发器无法实现更新在SqlServer中由数据库生成的RowVersion字段的值。所以MySql中的RowVersion只能由应用程序赋值。

在EF中采用IsConcurrencyToken配置后RowVersion即自动用于where子句中用于比较Row Version，通过重写SaveChanges方法在每次添加和更新时设置RowVersion的值即可实现在更新时同时比较Row Version的当前版本和更新Row Version的目的，同时可以正确的取回更新后的Row Version值。

1.定义并发控制字段

public interface IRowVersion
{
    byte[] RowVersion { get; set; }
}

2.配置并发控制字段

protected override void OnModelCreating(DbModelBuilder modelBuilder)
{
    modelBuilder.Conventions.Remove<PluralizingTableNameConvention>();
    modelBuilder.Configurations.AddFromAssembly(typeof(MySqlDbContext).Assembly);
    modelBuilder.Properties().Where(o => typeof(IRowVersion).IsAssignableFrom(o.DeclaringType)&&o.PropertyType==typeof(byte[])&&o.Name=="RowVersion")
        .Configure(o => o.IsConcurrencyToken().HasDatabaseGeneratedOption(DatabaseGeneratedOption.None));
    Database.SetInitializer(new MySqlDbInitializer());
}

3.手动对RowVersion赋值

public override int SaveChanges()
{
    this.ChangeTracker.DetectChanges();
    var objectContext = ((IObjectContextAdapter)this).ObjectContext;
    foreach (ObjectStateEntry entry in objectContext.ObjectStateManager.GetObjectStateEntries(EntityState.Modified | EntityState.Added))
    {
        var v = entry.Entity as IRowVersion;
        if (v != null)
        {
            v.RowVersion = System.Text.Encoding.UTF8.GetBytes(Guid.NewGuid().ToString());
        }
    }
    return base.SaveChanges();
}

4.检查生成的Sql语句

UPDATE `Customer` SET `PhoneNumber`=@gp1, `RowVersion`=@gp2 WHERE (`Id` = 1) AND (`RowVersion` = @gp3)

-- @gp1: '635655975120384389' (Type = String, IsNullable = false, Size = 18)
-- @gp2: 'System.Byte[]' (Type = Object, IsNullable = false, Size = 36)
-- @gp3: 'System.Byte[]' (Type = Object, IsNullable = false, Size = 36)

5.查看数据中的RowVersion

6.准备测试代码

public static void Test()
{
    var db1 = GetContext();
    var customer1 = db1.Set<Customer>().FirstOrDefault();
    customer1.PhoneNumber="t1";
    using (var db2 = GetContext())
    {
        var customer2 = db2.Set<Customer>().FirstOrDefault();
        customer2.PhoneNumber = "t2";
        db2.SaveChanges();
    }
    db1.SaveChanges();
}

7.查看测试结果：

总结：

1.需要唯一版本号的生成支持，Sql Server（Compact）本身支持，MySql的uuid函数也支持。

2.需要设置Insert时的RowVersion默认值和更新RowVersion版本号，Sql Server（Compact）本身支持，MySql只支持不能用于RowVersion的TimeStamp的默认值和自动更新。因此在MySql中只能在应用中设置Row Version。

这个方案同时适用各种数据库，尤其是类似MySql和Sqlite这种不支持默认RowVersion字段的数据库。希望你不是找了好久才找到这个解决方案。

标签：RowVersion,EntityFramework,Version,MySql,var,SaveChanges,Row
来源： https://www.cnblogs.com/zhaoshujie/p/12178918.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9