1. Management transaction
(1) Open the transaction setAutoCommit
Call this method to set the parameter to false, that is, open the transaction.
Open the transaction before executing sql.
(2) Commit transaction: commit()
When all sql has finished executing the commit transaction.
(3) Rollback transaction: rollback()
Roll back the transaction in catch.
2. Example
public static void main(String[] args) { Connection conn = null; PreparedStatement pstmt1 = null; PreparedStatement pstmt2 = null; try { //1.获取连接 conn = JDBCUtils.getConnection(); //开启事务 conn.setAutoCommit(false); //2.定义sql //2.1 张三 - 500 String sql1 = "update account set balance = balance - ? where id = ?"; //2.2 李四 + 500 String sql2 = "update account set balance = balance + ? where id = ?"; //3.获取执行sql对象 pstmt1 = conn.prepareStatement(sql1); pstmt2 = conn.prepareStatement(sql2); //4. 设置参数 pstmt1.setDouble(1,500); pstmt1.setInt(2,1); pstmt2.setDouble(1,500); pstmt2.setInt(2,2); //5.执行sql pstmt1.executeUpdate(); // 手动制造异常 int i = 3/0; pstmt2.executeUpdate(); //提交事务 conn.commit(); } catch (Exception e) { //事务回滚 try { if(conn != null) { conn.rollback(); } } catch (SQLException e1) { e1.printStackTrace(); } e.printStackTrace(); }finally { //关闭资源 JDBCUtils.close(pstmt1,conn); JDBCUtils.close(pstmt2,null); }
The above is the detailed content of How to use Connection to manage transactions in java. For more information, please follow other related articles on the PHP Chinese website!