1、JDBC 取得数据库自动生成的主键

获取自增长的键值：

（1）在创建PreparedStatement对象时

原来：

PreparedStatement pst = conn.preparedStatement(sql);

现在：

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

（2）原来执行更新

原来：

int len = pst.executeUpdate();

现在：

int len = pst.executeUpdate();

ResultSet rs = pst.getGeneratedKeys();

if(rs.next()){

Object key = rs.getObject(第几列);//获取自增长的键值

}

package com.atguigu.other;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.Statement;import java.util.Scanner;import org.junit.Test;import com.atguigu.utils.JDBCUtils;public class TestGetGenericKey {@Testpublic void add() throws Exception {Scanner input = new Scanner(System.in);System.out.println("请输入姓名：");String name = input.nextLine();System.out.println("请输入性别：");String gender = input.nextLine();System.out.println("请输入领导编号：");int mid = input.nextInt();System.out.println("请输入部门编号：");int did = input.nextInt();String sql = "INSERT INTO emp VALUES(NULL,?,?,?,?)";// 参数，占位符，通配符，表示这个地方需要设置值// 2、获取连接Connection conn = JDBCUtils.getConnection();// 3、准备一个PreparedStatement：预编译sql// 执行添加语句，如果需要获取自增长的键值，那么在此处要告知mysql服务器，在创建PreparedStatement对象时，增加一个参数//autoGeneratedKeys - 指示是否应该返回自动生成的键的标志，它是 Statement.RETURN_GENERATED_KEYS 或 Statement.NO_GENERATED_KEYS 之一PreparedStatement pst = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);// 4、把?用具体的值进行代替pst.setString(1, name);pst.setString(2, gender);pst.setInt(3, mid);pst.setInt(4, did);// 5、执行sqlint len = pst.executeUpdate();ResultSet rs = pst.getGeneratedKeys();if(rs.next()){System.out.println("新员工编号是：" + rs.getObject(1));}// 6、释放资源JDBCUtils.closeQuietly(pst, conn);}}

当需要成批插入或者更新记录时。可以采用Java的批量更新机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率。

JDBC的批量处理语句包括下面两个方法：

addBatch()：添加需要批量处理的SQL语句或参数

executeBatch()：执行批量处理语句；

通常我们会遇到两种批量执行SQL语句的情况：

多条SQL语句的批量处理；

一个SQL语句的批量传参；

注意：

JDBC连接MySQL时，如果要使用批处理功能，请再url中加参数?rewriteBatchedStatements=true

PreparedStatement作批处理插入时使用values（使用value没有效果）

2.1 Statement

void addBatch(String sql)：添加需要批量处理的SQL语句

int[] executeBatch()；执行批量处理语句；

2.2 PreparedStatement

void addBatch()将一组参数添加到此 PreparedStatement 对象的批处理命令中

int[] executeBatch()；执行批量处理语句；

2.3 关于效率测试

测试：插入100000条记录

（1）Statement不使用批处理

（2）PreparedStatement不使用批处理

（3）Statement使用批处理

（4）PreparedStatement使用批处理（效率最高）

（4）>（3）>（1）>（2）

2.4 示例代码

package com.atguigu.other;import java.sql.Connection;import java.sql.PreparedStatement;import org.junit.Test;import com.atguigu.utils.JDBCUtils;public class TestBatch {/** 没有使用批处理*/@Testpublic void testNoBatch() throws Exception {long start = System.currentTimeMillis();//批处理//添加500件商品String sql = "INSERT INTO t_goods (pname,price) VALUES(?,?)";Connection conn = JDBCUtils.getConnection();PreparedStatement pst = conn.prepareStatement(sql);for (int i = 1; i <= 100; i++) {String pname = "商品" + i;double price = i;pst.setString(1, pname);pst.setDouble(2, price);int len = pst.executeUpdate();System.out.println("第" +i +"条添加：" + (len>0?"成功":"失败"));}long end = System.currentTimeMillis();System.out.println("耗时：" + (end-start));}@Testpublic void testBatch()throws Exception {long start = System.currentTimeMillis();String sql = "INSERT INTO t_goods (pname,price) VALUES(?,?)";Connection conn = JDBCUtils.getConnection();PreparedStatement pst = conn.prepareStatement(sql);for (int i = 1; i <= 100; i++) {String pname = "商品" + i;double price = i;pst.setObject(1, pname);pst.setObject(2, price);pst.addBatch();//添加到批处理中}int[] executeBatch = pst.executeBatch();//一批命名同时执行for (int i = 0; i < executeBatch.length; i++) {System.out.println("第" +i +"条添加：" + (executeBatch[i]>0?"成功":"失败"));}JDBCUtils.closeQuietly(pst, conn);long end = System.currentTimeMillis();System.out.println("耗时：" + (end-start));}}

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 常量之一：

Connection.TRANSACTION_READ_UNCOMMITTED（=1）

Connection.TRANSACTION_READ_COMMITTED（=2）、

Connection.TRANSACTION_REPEATABLE_READ（=4）

Connection.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 {@Testpublic 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();}}}}