什么是事务
- 事务是由N步数据库操作序列组成的逻辑执行单元,这系列操作要么全执行,要么全放弃执行。
• 事务的特性(ACID)
- 原子性(Atomicity):事务是应用中不可再分的最小执行体。
- 一致性(Consistency):事务执行的结果,须使数据从一个一致性状态,变为另一个一致性状态。
- 隔离性(Isolation):各个事务的执行互不干扰,任何事务的内部操作对其他的事务都是隔离的。
- 持久性(Durability):事务一旦提交,对数据所做的任何改变都要记录到永久存储器中。
事务的隔离性
• 常见的并发异常
- 第一类丢失更新、第二类丢失更新。
- 脏读、不可重复读、幻读。
• 常见的隔离级别
- Read Uncommitted:读取未提交的数据。
- Read Committed:读取已提交的数据。
- Repeatable Read:可重复读。
- Serializable:串行化
第一类丢失更新 :某一个事务的回滚, 导致另外一个事务已更新的数据丢失了。
第二类丢失更新 :某一个事务的提交, 导致另外一个事务已更新的数据丢失了。
脏读 :某一个事务, 读取了另外一个事务未提交的数据
不可重复读 :某一个事务, 对同一个数据前后读取的结果不一致
幻读 :某一个事务, 对同一个表前后查询到的行数不一致
锁
• 悲观锁(数据库)
- 共享锁(S锁) 事务A对某数据加了共享锁后,其他事务只能对该数据加共享锁,但不能加排他锁。
- 排他锁(X锁) 事务A对某数据加了排他锁后,其他事务对该数据既不能加共享锁,也不能加排他锁。
• 乐观锁(自定义)
- 版本号、时间戳等 在更新数据前,检查版本号是否发生变化。若变化则取消本次更新,否则就更新数据(版本号+1)。
Spring事务管理 • 声明式事务
- 通过XML配置,声明某方法的事务特征。
- 通过注解,声明某方法的事务特征。
• 编程式事务 - 通过 TransactionTemplate 管理事务, 并通过它执行数据库的操作
案例代码
1. // REQUIRED: 支持当前事务(外部事务),如果不存在则创建新事务. 2. // REQUIRES_NEW: 创建一个新事务,并且暂停当前事务(外部事务). 3. // NESTED: 如果当前存在事务(外部事务),则嵌套在该事务中执行(独立的提交和回滚),否则就会REQUIRED一样. 4. @Transactional(isolation = Isolation.READ_COMMITTED, propagation = Propagation.REQUIRED) 5. public Object save1() { 6. // 新增用户 7. User user = new User(); 8. user.setUsername("alpha"); 9. user.setSalt(CommunityUtil.generateUUID().substring(0, 5)); 10. user.setPassword(CommunityUtil.md5("123" + user.getSalt())); 11. user.setEmail("alpha@qq.com"); 12. user.setHeaderUrl("http://image.nowcoder.com/head/99t.png"); 13. user.setCreateTime(new Date()); 14. userMapper.insertUser(user); 15. 16. // 新增帖子 17. DiscussPost post = new DiscussPost(); 18. post.setUserId(user.getId()); 19. post.setTitle("Hello"); 20. post.setContent("新人报道!"); 21. post.setCreateTime(new Date()); 22. discussPostMapper.insertDiscussPost(post); 23. 24. //这步报错,观测是否回滚 25. Integer.valueOf("abc"); 26. 27. return "ok"; 28. } 29. 30. public Object save2() { 31. transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED); 32. transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); 33. 34. return transactionTemplate.execute(new TransactionCallback<Object>() { 35. @Override 36. public Object doInTransaction(TransactionStatus status) { 37. // 新增用户 38. User user = new User(); 39. user.setUsername("beta"); 40. user.setSalt(CommunityUtil.generateUUID().substring(0, 5)); 41. user.setPassword(CommunityUtil.md5("123" + user.getSalt())); 42. user.setEmail("beta@qq.com"); 43. user.setHeaderUrl("http://image.nowcoder.com/head/999t.png"); 44. user.setCreateTime(new Date()); 45. userMapper.insertUser(user); 46. 47. // 新增帖子 48. DiscussPost post = new DiscussPost(); 49. post.setUserId(user.getId()); 50. post.setTitle("你好"); 51. post.setContent("我是新人!"); 52. post.setCreateTime(new Date()); 53. discussPostMapper.insertDiscussPost(post); 54. 55. //这步报错,观测是否回滚 56. Integer.valueOf("abc"); 57. 58. return "ok"; 59. } 60. }); 61. }