MySQL三十五：JBDC操作事务

package lesson04;

import lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestTransaction {
    public static void main(String[] args) throws SQLException {
        Connection conn=null;
        PreparedStatement st=null;
        ResultSet rs=null;

        try {
          conn = JdbcUtils.getConnection();
          //关闭数据库的自动提交功能
            conn.setAutoCommit(false);

            String sql1="update accout set money=money-100 where name='A' ";
            st = conn.prepareStatement(sql1);
            st.executeUpdate(sql1);
            String sql2="update accout set money=money+100 where name='B' ";
            st = conn.prepareStatement(sql2);
            st.executeUpdate(sql2);

            //业务完毕，提交事务
            conn.commit();
            System.out.println("提交成功！");



        } catch (SQLException throwables) {

                conn.rollback(); //如果失败回滚事务

            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }


}