JDBC对事务的操作

事务的操作"/>

JDBC对事务的操作

1 什么叫数据库事务？

• 事务：一组逻辑操作单元，使数据从一种状态变换为另一种状态。
• 一组逻辑操作单元：一个或多个DML操作。

2 事务处理的原则：

保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。

• 当在一个事务中执行多个操作时，要么所有事务都被提交（commit），那么这些修改就永久地保存下来
• 要么数据库管理系统将放弃所做的所有修改，整个事务回滚（rollback）到最初的状态。

3 数据一旦提交，就不能回滚

4 哪些操作会导致数据的自动提交？

• DDL操作一旦执行，就会自动提交
• set autocommit = false 对DDL操作无效
• DML默认情况下，一旦执行，就会自动提交。
• 我们通过set autocommit = false的方式取消DML操作的自动提交。
• 默认关闭连接时，会自动的提交数据。

5 JDBC对事务的操作的代码

主要用到的方法：

• 关闭事务自动提交：conn.setAutoCommit(false);
• 开启事务： conn.setAutoCommit(true);
• 提交数据 （事务）： connmit();
• 事务回滚：conn.rollback();

/*** ClassName: TransactionTest* Description:** @Create 2023/10/31 15:18* @Version 1.0*/
public class TransactionTest {/*** 针对数据表 user_table* AA向BB转钱*/@Testpublic void testUpdate() {String sql1 = "update user_table set balance = balance-1000 where user = ?";update(sql1, "AA");// 模仿网络延迟System.out.println(10 / 0);String sql2 = "update user_table set balance = balance+1000 where user = ?";update(sql2, "BB");System.out.println("转账成功！！");}/********************************未考虑数据库事务的转正操作*************************/// 通用的 增删改 操作-- version 1.0public int update(String sql, Object... args) { // sql中占位符的个数与可变形参的个数相同// 1 获取数据库连接Connection conn = null;PreparedStatement ps = null;try {conn = JDBCUtil.getConnection();// 2 预编译sql语句，返回PreparedStatement的实例ps = conn.prepareStatement(sql);// 3 填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]); // 注意参数错误，sql中是从1 开始 数组从0开始}// 4 执行sql语句// boolean execute = ps.execute();// if (!execute) System.out.println("执行成功！！！");// 返回影响了几行数据return ps.executeUpdate();} catch (Exception e) {e.printStackTrace();} finally {// 5 资源关闭JDBCUtil.closeResource(conn, ps);}return 0;}/********************************增加数据库事务的转正操作*************************//*** 针对数据表 user_table* AA向BB转钱*/@Testpublic void testUpdate2() {Connection conn = null;try {conn = JDBCUtil.getConnection();// 1 关闭事务自动提交conn.setAutoCommit(false);String sql1 = "update user_table set balance = balance-1000 where user = ?";update(conn, sql1, "AA");// 模仿网络延迟//System.out.println(10 / 0);String sql2 = "update user_table set balance = balance+1000 where user = ?";update(conn, sql2, "BB");System.out.println("转账成功！！");// 2 提交数据 （事务）connmit();} catch (Exception e) {// 3 若执行失败，事务回滚try {conn.rollback();} catch (SQLException ex) {throw new RuntimeException(ex);}e.printStackTrace();} finally {JDBCUtil.closeResource(conn, null);}}// 通用的 增删改 操作-- version 2.0 增加事务public int update(Connection conn, String sql, Object... args) { // sql中占位符的个数与可变形参的个数相同PreparedStatement ps = null;try {// 2 预编译sql语句，返回PreparedStatement的实例ps = conn.prepareStatement(sql);// 3 填充占位符for (int i = 0; i < args.length; i++) {ps.setObject(i + 1, args[i]); // 注意参数错误，sql中是从1 开始 数组从0开始}// 4 执行sql语句// boolean execute = ps.execute();// if (!execute) System.out.println("执行成功！！！");// 返回影响了几行数据return ps.executeUpdate();} catch (Exception e) {e.printStackTrace();} finally {// 修改起为自动提交// 主要针对于使用数据库连接池的使用try {conn.setAutoCommit(true);} catch (SQLException e) {throw new RuntimeException(e);}// 5 资源关闭JDBCUtil.closeResource(null, ps);}return 0;}
}