我正在研究使用 Spring Boot 在 Java 中实现的 REST API。我使用嵌入式内存数据库 H2 数周时间,但在某些时候我注意到事务隔离存在问题。
更准确地说,我有一个表,我需要在其中跟踪“重复”记录。重复项只是一条记录,对于表列的定义明确的子集,该记录等于另一条记录。所以,基本上,当我插入一条新记录时,我首先检查它是否重复并相应地标记它。 boolean 列“重复”用于此目的。
例如,假设 B 和 C 是我为了定义重复项而检查的列。这是一个有效的状态:
|一个|乙 |丙 |重复|
| - | - | - | ---------- |
| × |是 | z |假 |
| z |是 | z |真 |
| × |是 |是 |假 |
| × |是 |是 |真 |
|是 |是 |是 |真 |
虽然这不是一个有效的状态:
|一个|乙 |丙 |重复|
| - | - | - | ---------- |
| × |是 | z |假 |
| z |是 | z |真 |
| × |是 |是 |假 |
| × |是 |是 |真 |
|是 |是 |是 |假 |
...因为第 3 行和第 5 行对于 B 和 C 具有相同的值,所以必须将两者之一标记为重复。
换句话说,我的要求是将碰巧已经使用过值的任何行标记为重复。对于给定的一组值,只允许一行有 duplicate == false。
但是,我的基于 Spring 的实现没有按预期工作。例如,插入 100 行具有相同值的行应该会产生 99 次重复,只有 1 次不重复。但是当我尝试并行执行这些插入时,没有检测到很多重复项。
我尝试了几个修复程序,在某些时候我开始认为 H2 没有正确实现 SERIALIZABLE 隔离级别。我创建了一个小应用程序来演示它:
@RestController
public class NewFooCtrl {
@Autowired
private FooRepo repo;
@RequestMapping(value = "/foo", method = RequestMethod.POST)
@Transactional(isolation = Isolation.SERIALIZABLE)
public void newFoo(@RequestBody Foo foo) {
List<Foo> foos = repo.findByBar(foo.getBar());
if (foos.isEmpty()) foo.setDuplicate(false);
else foo.setDuplicate(true);
repo.save(foo);
}
}
注意:我省略了明显的代码,例如模型和存储库。 Foo 模型有一个标识符(类型 UUID)、一个 bar 属性(类型 String)和一个 duplicate 属性(类型 boolean)。重复检查基于 bar 属性。
对于 H2,我有很多遗漏的重复项(通常为 10%)。使用 MySQL 我总能得到正确的结果(即标记为重复的行数 恰好 N - 1,其中 N 是插入的行数)。唯一的问题是只有一小部分插入成功(最多从 1% 到 30%)。
我遇到了大量与死锁相关的异常。这是为什么?这么简单的代码怎么会造成死锁呢。我的意思是,这只是一个选择,然后是一个插入。
有什么建议吗?
最佳答案
应用程序本身不应检查事务中的重复键。将其留给具有唯一索引的数据库引擎,如果发生异常则捕获异常,然后使用另一个标识符重试。
如果你真的想在应用层面解决这个问题,也许你应该在打开事务后立即手动锁定表。隔离级别可以自动为您执行此操作,但性能成本很高(您可能不希望这样)。
另一种解决方案是乐观锁定,使用 @Version 注释,但这样您将无法保证标识符的唯一性。
很难诊断您的死锁问题,但它通常出现在您有递归事务(一个事务在另一个事务中打开)时。检查你的 beans @Scope,它们会产生这样的问题。此外,确保您只有一个 TransactionManager 和一个 EntityManager bean。
关于java - Spring JPA + MySQL 和死锁,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44597153/
我的瘦服务器配置了nginx,我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例,但找不到好的解决方案。有没有人能做到这一点? 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器,例如server{listen80;server
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
如何将send与+=一起使用?a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法,而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:
文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目,Java开发。基于数据库增量日志解析,提供增量数据订阅&消费。Git地址:https://github.co
这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/
HashMap中为什么引入红黑树,而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道,在JDK1.8以及之前,针对HashMap有什么不同。JDK1.7的时候,HashMap的底层实现是数组+链表JDK1.8的时候,HashMap的底层实现是数组+链表+红黑树我们要思考一个问题,为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好???2.链表上述的截图其实就是链表的结构,我们来看下链表的增删改查的时间复杂度增:因为链表不是线性结构,所以每次添加的时候,只需要移动一个节点,所以可以理解为复杂度是N(1)删:算法时间复杂度跟增保持一致查:既然是非线性结构,所以查询某一个节点的时候
遍历文件夹我们通常是使用递归进行操作,这种方式比较简单,也比较容易理解。本文为大家介绍另一种不使用递归的方式,由于没有使用递归,只用到了循环和集合,所以效率更高一些!一、使用递归遍历文件夹整体思路1、使用File封装初始目录,2、打印这个目录3、获取这个目录下所有的子文件和子目录的数组。4、遍历这个数组,取出每个File对象4-1、如果File是否是一个文件,打印4-2、否则就是一个目录,递归调用代码实现publicclassSearchFile{publicstaticvoidmain(String[]args){//初始目录Filedir=newFile("d:/Dev");Datebeg