Entity Framework Core 实现MySQL 的TimeStamp/RowVersion 并发控制
将通用的序列号生成器库 从SQL Server迁移到Mysql 遇到的一个问题,就是TimeStamp/RowVersion并发控制类型在非Microsoft SQL Server数据库中的实现。SQL Server timestamp 数据类型与时间和日期无关。SQL Server timestamp 是二进制数字,它表明数据库中数据修改发生的相对顺序。实现 timestamp 数据类型最初是为了支持 SQL Server 恢复算法。每次修改页时,都会使用当前的 @@DBTS 值对其做一次标记,然后 @@DBTS 加1。这样做足以帮助恢复过程确定页修改的相对次序,但是 timestamp 值与时间没有任何关系。 而在MySQL中,TIMESTAMP列类型提供一种类型,你可以使用它自动地用当前的日期和时间标记INSERT或UPDATE的操作。如果你有多个TIMESTAMP列,只有第一个自动更新。
在Entity Framework 中采用IsConcurrencyToken配置后RowVersion即自动用于where子句中用于比较Row Version, 我们也需要使用这个特性实现并发控制,Ak.Ini的博文http://www.cnblogs.com/akini/archive/2013/01/30/2882767.html ,我们按照这篇文章的方法在Entity framework core上面解决并发控制问题。
定义的序列号类型:
[Table("DbServerSequence")]
public class DbServerSequence : ISequence
{
public DbServerSequence()
{
}
public DbServerSequence(SequenceOptions options):this()
{
StartAt = options.StartAt;
CurrentValue = StartAt;
Increment = options.Increment;
MaxValue = options.MaxValue;
MinValue = options.MinValue;
Cycle = options.Cycle;
}
public String Key { get; set; }
public long StartAt { get; set; }
public int Increment { get; set; }
public long MaxValue { get; set; }
public long MinValue { get; set; }
public bool Cycle { get; set; }
public long CurrentValue { get; set; }
[ConcurrencyCheck]
public DateTime RowVersion { get; set; }
public DateTime DateCreated { get; set; }
}
其中RowVersion 是用作并发控制的,针对Mysql 不允许byte[]类型上标记TimeStamp/RowVersion,这里使用DateTime类型。
数据库表定义如下(自MySQL 5.6.5版本开始,DEFAULT CURRENT_TIMESTAMP 和 ON UPDATE CURRENT_TIMESTAMP 选项也可以应用到Datetime类型的列):
DROP TABLE IF EXISTS `dbserversequence`;
CREATE TABLE `dbserversequence` (
`Key` varchar(128) NOT NULL,
`StartAt` bigint(20) NOT NULL,
`Increment` int(11) NOT NULL,
`MaxValue` bigint(20) NOT NULL,
`MinValue` bigint(20) NOT NULL,
`Cycle` bit(1) NOT NULL,
`CurrentValue` bigint(20) NOT NULL,
`RowVersion` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`DateCreated` datetime NOT NULL,
PRIMARY KEY (`Key`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
在 SequenceDbContext 的OnModelCreating 重写如下,主要是配置并发控制字段:
protected override void OnModelCreating(ModelBuilder builder)
{
base.OnModelCreating(builder);
builder.Entity<DbServerSequence>(e =>
{
e.HasKey(x => x.Key);
e.Property(x => x.RowVersion).IsRowVersion().IsConcurrencyToken();
});
}
这个方案同时适用各种数据库,尤其是类似MySql和Postgresql这种不支持默认RowVersion字段的数据库。 最新的代码放在https://github.com/geffzhang/Sequence/tree/dotnetcore
相关文章:
通用的序列号生成器库
原文地址:http://www.cnblogs.com/shanyou/p/6241612.html
.NET社区新闻,深度好文,微信中搜索dotNET跨平台或扫描二维码关注
赞赏
人赞赏
Entity Framework Core 实现MySQL 的TimeStamp/RowVersion 并发控制相关推荐
- Entity Framework Core 执行SQL语句和存储过程
无论ORM有多么强大,总会出现一些特殊的情况,它无法满足我们的要求.在这篇文章中,我们介绍几种执行SQL的方法. 表结构 在具体内容开始之前,我们先简单说明一下要使用的表结构. public clas ...
- Entity Framework Core 批处理语句
在Entity Framework Core (EF Core)有许多新的功能,最令人期待的功能之一就是批处理语句.那么批处理语句是什么呢?批处理语句意味着它不会为每个插入/更新/删除语句发送单独的请 ...
- Entity Framework Core 命名约定
注意:我使用的是 Entity Framework Core 2.0 (2.0.0-preview2-final).正式版发布时,功能可能存在变动.Entity Framework 迁移允许从模型生成 ...
- Entity Framework Core 软删除与查询过滤器
注意:我使用的是 Entity Framework Core 2.0 (2.0.0-preview2-final).正式版发布后,功能可能存在变动. 继续探索Entity Framework Core ...
- Entity Framework Core生成的存储过程在MySQL中需要进行处理及PMC中的常用命令
在使用Entity Framework Core生成MySQL数据库脚本,对于生成的存储过程,在执行的过程中出现错误,需要在存储过程前面添加 delimiter // 附:可以使用Visual Stu ...
- ABP .Net Core Entity Framework迁移使用MySql数据库
一.迁移说明 ABP模板项目Entity Framework Core默认使用的是Sql Server,也很容易将数据库迁移到MySQL,步骤如下. 二.迁移MySQL步骤 1. 下载项目 请到 ht ...
- 全球首发免费的MySql for Entity Framework Core
Background 一时兴起,想实现.NET Core下的MySQL ADO层和与Entity Framework Core对接,同时也是非常鄙视某厂商借着目前Oracle官方没有对.NET Cor ...
- abp mysql .net core_ABP .Net Core Entity Framework迁移使用MySql数据库
一.迁移说明 ABP模板项目Entity Framework Core默认使用的是Sql Server,也很容易将数据库迁移到MySQL,步骤如下. 二.迁移MySQL步骤 1. 下载项目 请到 ht ...
- abp.net mysql_ABP .Net Core Entity Framework迁移使用MySql数据库
一.迁移说明 ABP模板项目Entity Framework Core默认使用的是Sql Server,也很容易将数据库迁移到MySQL,步骤如下. 二.迁移MySQL步骤 1. 下载项目 请到 ht ...
最新文章
- 某程序员求助:因考虑不周,签字确认后又拒了虾皮offer,被hr告知进入黑名单,永不录用!以后还能进虾皮吗?...
- Cacti 自定义脚本监控
- 弹出框的鼠标拖拽事件
- glCullFace,GL_CULL_FACE
- python的函数式编程玩法+年末小感
- 计算机网络应用基础第一章试题,计算机网络应用基础第一章测试题
- Java版本的Bot Framework SDK
- java中 wait()和sleep()的差异
- 文件上传java前端怎么写_做一个文件上传,前端是ajax提交数据后台是java,这个错误怎么办...
- Gartner最新数据报告 WP系统仅剩1%
- TypeScript入坑
- python 小案例
- 判断目录下的文件是否为图片
- python模拟账号登录_用Python(Tornado)模拟登录小米帐号
- 在网页HTML中嵌入QQ、MSN、旺旺、Gtalk快速对话框代码
- 公众号的服务器位置和ip地址,怎么查看公众号服务器ip地址吗
- Android编译时技术(二)ASM 基础使用之代码生成
- 世界各国首都经纬度-json
- URAL 1069 Prufer Code 优先队列
- “修真院”修行九九八十一难(1)
热门文章
- AM335x kernel4.4.12 LCD 时钟翻转设置记录
- 《Python CookBook2》 第一章 文本 - 检查字符串中是否包含某字符集合中的字符 简化字符串的translate方法的使用...
- Windows下MinGW编译vim7.4
- ios gb2312转utf-8
- 响应式设计(Response Web Design)浅谈
- Linux 远程开机(walk on lan)
- .NET的两种部署模式,了解一下
- 腾讯急招多名.NET Core,5年30k!
- 再来说说我喜欢的 Dotnet 5.0 C# 9
- Dapr + .NET 实战(五)Actor