事务处理

/**
 * 事务处理
 * 事务具备原子性和持久化的特性
 *
 * 能够将多条增删改语句作为一个整体一起提交，完成持久化
 * 如果其中有任意一条执行失败，整个事务都将会回滚
 */
public class Demo9 {

    public static void main(String[] args)throws Exception {

        Class.forName("com.mysql.jdbc.Driver");
        Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/geekhome", "root", "tjhilu");
        //将事务的自动提交方法更改为手动提交
        con.setAutoCommit(false);
        //设置回滚点
        Savepoint point = con.setSavepoint();

        PreparedStatement pstmt = con.prepareStatement("update account set balance=balance-200 where cardid=1");
        pstmt.executeUpdate();

        if(true){
            //回滚事务
            //con.rollback();
            //根据设置的回滚点位置，进行事务回滚
            con.rollback(point);
            throw new RuntimeException("转账失败");
        }

        PreparedStatement pstmt2 = con.prepareStatement("update account set balance=balance+200 where cardid=2");
        pstmt2.executeUpdate();

        //提交事务：为了多条语句绑定生效，所以设置默认不提交，执行结束后统一提交
        con.commit();

        pstmt.close();
        con.close();
    }
}