JDBC管理事务-概述

JDBC控制事务:

  1.事务:一个包含多个步骤的业务操作,如果这个业务操作被事务管理,则这多个步骤要么同时成功,要么同时失败

  2.操作:

    1.开启事务

    2.提交事务

    3.回滚事务

   3.使用Connection对象管理事务

    开启事务:setAutoCommit(boolean  autoCommit):调用该方法设置参数为false,即开启事务

    提交事务:commit();

    回滚事务:rollback();

 

JDBC管理事务-实现

    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement prep1 = null;
        PreparedStatement prep2 = null;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();//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对象
            prep1 = conn.prepareStatement(sql1);
            prep2 = conn.prepareStatement(sql2);
            //4.给?设置参数
            prep1.setDouble(1, 500);
            prep1.setInt(2, 1);
            //----------------------------------------
            prep2.setDouble(1, 500);
            prep2.setInt(2, 1);
            //5.执行sql
            prep1.executeUpdate();
//            //手动制造异常
            int i = 3/0;

            prep2.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            JDBCUtils.close(prep1, conn);
            JDBCUtils.close(prep2, null);
        }
    }

 

 

 

当代码执行完第一条sql之后程序报错,第二条sql没有执行,张三的金额已经减了,但是李四的金额没有增加。

所以我们要使用事务来解决

 

 

 

 

解决方式:

    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement prep1 = null;
        PreparedStatement prep2 = 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对象
            prep1 = conn.prepareStatement(sql1);
            prep2 = conn.prepareStatement(sql2);
            //4.给?设置参数
            prep1.setDouble(1, 500);
            prep1.setInt(2, 1);
            //----------------------------------------
            prep2.setDouble(1, 500);
            prep2.setInt(2, 1);
            //5.执行sql
            prep1.executeUpdate();
//            //手动制造异常
            int i = 3/0;

            prep2.executeUpdate();

            //提交事务
            conn.commit();
        } catch (Exception e) {
            //事务回滚
            try {
                if (conn != null)
                    conn.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        }finally {
            JDBCUtils.close(prep1, conn);
            JDBCUtils.close(prep2, null);
        }
    }

执行代码后代码

 

 

因为开启事务了,所以报错什么的他会回滚到你开事务之前的数据

 

原文地址:http://www.cnblogs.com/qihaokuan/p/16815467.html

1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长! 2. 分享目的仅供大家学习和交流,请务用于商业用途! 3. 如果你也有好源码或者教程,可以到用户中心发布,分享有积分奖励和额外收入! 4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解! 5. 如有链接无法下载、失效或广告,请联系管理员处理! 6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需! 7. 如遇到加密压缩包,默认解压密码为"gltf",如遇到无法解压的请联系管理员! 8. 因为资源和程序源码均为可复制品,所以不支持任何理由的退款兑现,请斟酌后支付下载 声明:如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性