springbootmysql事物_SpringBoot事务详细简介
重要概念
⾃动提交模式
对于mysql数据库,默认情况下,数据库处于⾃动提交模式。每⼀条语句处于⼀个单独的事务中,在这条语句执⾏完毕时,如果执⾏成功则隐式的提交事务,如果执⾏失败则隐式的回滚事务。对于正常的事务管理,是⼀组相关的操作处于⼀个事务之中,因此必须关闭数据库的⾃动提交模式,下⾯是查看⽅式:
查看是否⾃动提交命令(ON表⽰开启⾃动提交,值为1,OFF表⽰关闭⾃动提交,值为0):show variables like 'autocommit';
关闭⾃动提交后,则⽤户将⼀直处于某个事务中,直到执⾏⼀条commit提交或rollback语句才会结束当前事务重新开始⼀个新的事务。DataSource connection = Connection();
connection.setAutoCommit(false);
事务隔离级别
隔离级别是指若⼲个并发的事务之间的隔离程度。TransactionDefinition 接⼝中定义了五个表⽰隔离级别的常量:
1、TransactionDefinition.ISOLATION_DEFAULT:这是默认值,表⽰使⽤底层数据库的默认隔离级别。对⼤部分数据库⽽⾔,通常这值就是TransactionDefinition.ISOLATION_READ_COMMITTED。
2、TransactionDefinition.ISOLATION_READ_UNCOMMITTED:该隔离级别表⽰⼀个事务可以读取另⼀个事务修改但还没有提交的数据。该级别不能防⽌脏读,不可重复读和幻读,因此很少使⽤该隔离级别。⽐如PostgreSQL实际上并没有此级别。
3、TransactionDefinition.ISOLATION_READ_COMMITTED:该隔离级别表⽰⼀个事务只能读取另⼀个事务已经提交的数据。该级别可以防⽌脏读,这也是⼤多数情况下的推荐值。
4、TransactionDefinition.ISOLATION_REPEATABLE_READ:该隔离级别表⽰⼀个事务在整个过程中可以多次重复执⾏某个查询,并且每次返回的记录都相同。该级别可以防⽌脏读和不可重复读。
5、TransactionDefinition.ISOLATION_SERIALIZABLE:所有的事务依次逐个执⾏,这样事务之间就完全不可能产⽣⼲扰,也就是说,该级别可以防⽌脏读、不可重复读以及幻读。但是这将严重影响程序的性能。通常情况下也不会⽤到该级别。
事务传播⾏为
所谓事务的传播⾏为是指,如果在开始当前事务之前,⼀个事务上下⽂已经存在,此时有若⼲选项可以指定⼀个事务性⽅法的执⾏⾏为。在TransactionDefinition定义中包括了如下⼏个表⽰传播⾏为的常量:
1、TransactionDefinition.PROPAGATION_REQUIRED:如果当前存在事务,则加⼊该事务;如果当前没有事务,则创建⼀个新的事务。这是默认值。
2、TransactionDefinition.PROPAGATION_REQUIRES_NEW:创建⼀个新的事务,如果当前存在事务,则把当前事务挂起。
3、TransactionDefinition.PROPAGATION_SUPPORTS:如果当前存在事务,则加⼊该事务;如果当前没有事务,则以⾮事务的⽅式继续运⾏。
4、TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以⾮事务⽅式运⾏,如果当前存在事务,则把当前事务挂起。
5、TransactionDefinition.PROPAGATION_NEVER:以⾮事务⽅式运⾏,如果当前存在事务,则抛出异常。
6、TransactionDefinition.PROPAGATION_MANDATORY:如果当前存在事务,则加⼊该事务;如果当前没有事务,则抛出异常。
7、TransactionDefinition.PROPAGATION_NESTED:如果当前存在事务,则创建⼀个事务作为当前事务的嵌套事务来运⾏;如果当前没有事务,则该取值等价于TransactionDefinition.PROPAGATION_REQUIRED。
保护点(Savepoints)
⾸先要知道savepoint就是为回退做的,savepoint的个数没有限制,savepoint和虚拟机中快照类似. savepoint是事务中的⼀点。⽤于取消部分事务,当结束事务时,会⾃动的删除该事务中所定义的所有保存点。
当执⾏rollback时,通过指定保存点可以回退到指定的点。
回退事务的⼏个重要操作
1、设置保存点 savepoint a
2、取消保存点a之后事务 rollback to a
3、取消全部事务 rollback
注意:这个回退事务,必须是没有commit前使⽤的;public class UserRepository {
private DataSource masterDataSource;
private Connection connection = null;
@Autowired
public void setMasterDataSource(DataSource masterDataSource) {
this.masterDataSource = masterDataSource;
}
@Transactional
public boolean save(User user) {
try {
connection = Connection();
connection.setAutoCommit(false);
//设置保护点
Savepoint saveUser = connection.setSavepoint("saveUser");
PreparedStatement prepareStatement = connection.prepareStatement("insert into user(id,name,age) values(?,?,?)"); prepareStatement.setLong(1, Id());
prepareStatement.setString(2, Name());
prepareStatement.setInt(3, Age());
try {
update(user);
} catch (Exception e) {
System.out.println("出错了。。"+e);
//回滚⾄保护点
}
connectionmit();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
php mysql教程视频return true;
}
public boolean update(User user) {
System.out.println("save user:"+user);
try {
PreparedStatement prepareStatement = connection.prepareStatement("update user set name = ? ,age = ? where id = ?)"); prepareStatement.setLong(3, Id());
prepareStatement.setString(1, "王⼤拿");
prepareStatement.setInt(2, 100/0);
connectionmit();
} catch (SQLException e) {
e.printStackTrace();
}
return true;
}
}
以上内容整理若有错误请指正,谢谢!
更多Mysql相关问题请访问PHP中⽂⽹:Mysql视频教程

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。