EntityFramework系列:MySql的RowVersion
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了EntityFramework系列:MySql的RowVersion,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含2872字,纯文字阅读大概需要5分钟。
内容图文
![EntityFramework系列:MySql的RowVersion](/upload/InfoBanner/zyjiaocheng/879/8385d455791e4750914c3f12bcd2917a.jpg)
无需修改实体和配置,在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字段的数据库。希望你不是找了好久才找到这个解决方案。
内容总结
以上是互联网集市为您收集整理的EntityFramework系列:MySql的RowVersion全部内容,希望文章能够帮你解决EntityFramework系列:MySql的RowVersion所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。