尚硅谷之JDBC

3、事务

JDBC程序中当一个连接对象被创建时,默认情况下是自动提交事务:每次执行一个 SQL 语句时,如果执行成功,就会向数据库自动提交,而不能回滚。

JDBC程序中为了让多个 SQL 语句作为一个事务执行:(重点)

  • 调用 Connection 对象的 setAutoCommit(false); 以取消自动提交事务
  • 在所有的 SQL 语句都成功执行后,调用 commit(); 方法提交事务
  • 在其中某个操作失败或出现异常时,调用 rollback(); 方法回滚事务
  • 若此时 Connection 没有被关闭, 则需要恢复其自动提交状态 setAutoCommit(true);

注意:

如果多个操作,每个操作使用的是自己单独的连接,则无法保证事务。即同一个事务的多个操作必须在同一个连接下

JDBC还可以通过Connection对象的:

  • int getTransactionIsolation():获取此 Connection 对象的当前事务隔离级别
  • void setTransactionIsolation(int level):试图将此 Connection 对象的事务隔离级别更改为给定的级别。可能的事务隔离级别是 Connection 接口中定义的常量。

level – 以下 Connection 常量之一:

  • TRANSACTION_READ_UNCOMMITTED(=1
  • TRANSACTION_READ_COMMITTED(=2
  • TRANSACTION_REPEATABLE_READ(=4
  • TRANSACTION_SERIALIZABLE(=8

(注意,不能使用 Connection.TRANSACTION_NONE(=0,因为它指定了不受支持的事务。)

 

package com.atguigu.other;

 

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

 

import org.junit.Test;

 

import com.atguigu.utils.DBUtils;

 

public class TestTransaction {

 

         @Test

         public void test()  {

                   int uid = 2;//谁买的

                   int[] pids = {1,2,3};//购买的商品的编号

                   int[] amount = {1,1,1};//分别每一个商品的数量

                   double[] price = {45,34,2.5};//购买时,每一件商品的价格

 

                   //如何把这些订单的数据保存到数据库中

                   //分别在订单表t_order添加一条记录:订单编号,订单时间,订单总价,用户编号

                   //在订单明细表t_detail添加几条记录:订单编号,商品编号,数量(多行),这里3行

 

                   //这些数据要么同时保存成功,要么同时失败(撤销),那么表示他们要组成一个事务

 

                   Connection conn = null;

                   try {

 

                            //手动提交事务

                            //1、获取连接对象(注册驱动省略,因为在DBUtils注册过了)

                            conn = JDBCUtils.getConnection();

                            //2、设置手动提交

                            conn.setAutoCommit(false);

 

                            String orderInsert = “INSERT INTO t_order (sumprice,uid) VALUES(?,?)”;

                            double sumprice = 0;

                            for (int i = 0; i < price.length; i++) {

                                     sumprice += price[i]*amount[i];

                            }

                            //3、执行添加语句,如果需要获取自增长的键值,那么在此处要告知mysql服务器,在创建PreparedStatement对象时,增加一个参数

                            //autoGeneratedKeys – 指示是否应该返回自动生成的键的标志,它是 Statement.RETURN_GENERATED_KEYS 或 Statement.NO_GENERATED_KEYS 之一

                            PreparedStatement pst = conn.prepareStatement(orderInsert,Statement.RETURN_GENERATED_KEYS);

 

                            pst.setObject(1, sumprice);

                            pst.setObject(2, uid);

                            pst.executeUpdate();

 

                            ResultSet rs = pst.getGeneratedKeys();

                            if(rs.next()){

                                     Object oid = rs.getObject(1);

 

                                     String detailInsert = “INSERT INTO t_details (oid,pid,amount) VALUES(?,?,?)”;

                                     PreparedStatement pst2 = conn.prepareStatement(detailInsert);

                                     for (int i = 0; i < pids.length; i++) {

                                               pst2.setObject(1, oid);

                                               pst2.setObject(2, pids[i]);

                                               pst2.setObject(3, amount[i]);

 

                                               pst2.addBatch();

                                     }

 

                                     pst2.executeBatch();

                            }

 

                            //4、提交事务

                            conn.commit();

                            System.out.println(“添加成功”);

                   }catch (Exception e) {

                            e.printStackTrace();

                            try {

                                     //如果发生异常,应该回滚

                                     if(conn!=null){

                                               System.out.println(“添加失败”);

                                               conn.rollback();

                                     }

                            } catch (SQLException e1) {

                                     e1.printStackTrace();

                            }

                   }finally{

                            try {

                                     //释放资源

                                     if(conn!=null){

                                               conn.setAutoCommit(true);

                                               conn.close();

                                     }

                            } catch (SQLException e) {

                                     e.printStackTrace();

                            }

                   }

         }

}

 

 

 


上一篇:
下一篇:
关于尚硅谷
教育理念
名师团队
学员心声
资源下载
视频下载
资料下载
工具下载
加入我们
招聘岗位
岗位介绍
招贤纳师
联系我们
电话:010-56253825
邮箱:info@atguigu.com
地址:北京市昌平区宏福科技园综合楼6层(北京校区)

 深圳市宝安区西部硅谷大厦B座C区一层(深圳校区)

上海市松江区谷阳北路166号大江商厦6层(上海校区)