package jdbc;

import jdbc.util.JDBCUtils;

import java.sql.SQLException;

import java.sql.*;

/**

* @author ： CodeWater

* @create ：2022-03-09-10:49

* @Function Description ：事务操作

*/

public class JdbcDemo10 {

public static void main(String[] args) {

Connection conn = null;

PreparedStatement pstmt1 = null;

PreparedStatement pstmt2 = null;

try {

conn = JDBCUtils.getConnection();

//开启事务，也就是手动提交，取消自动

conn.setAutoCommit(false);

//张三给李四转500

String sql1 = "update account set balance = balance - ? where id = ?";

String sql2 = "update account set balance = balance + ? where id = ?";

pstmt1 = conn.prepareStatement(sql1);

pstmt2 = conn.prepareStatement(sql2);

pstmt1.setDouble(1, 500);

pstmt1.setInt(2, 1);

pstmt2.setDouble(1, 500);

pstmt2.setInt(2, 2);

pstmt1.executeUpdate();

//制造异常

int i = 3 / 0;

pstmt2.executeUpdate();

conn.commit();

} catch (Exception e) {

//rollback

try {

if (conn != null) {

conn.rollback();

}

} catch (SQLException e1) {

e1.printStackTrace();

}

e.printStackTrace();

} finally {

JDBCUtils.close(pstmt1, conn);

JDBCUtils.close(pstmt2, conn);

}

}

}