JDBC进阶

一、获取自增长键值

当我们通过JDBC往数据库的表格中添加一条记录，其中有一个字段是自增的，那么在JDBC这边怎么在添加之后直接获取到这个自增的值。

注意：
JDBC中默认不允许获取自增的主键，需要在connection.prepareStatement()中设置参数Statement.RETURN_GENERATED_KEYS 表示允许获取自增的主键

实现步骤：

• statement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
• statement.executeUpdate();
• resultSet = statement.getGeneratedKeys();
• resultSet.next();
• int id = resultSet.getInt(1);

案例分析：
提供两张表：
t_class（cid,cname）
t_student(sid,sname,age,gender,birthday,cid)

• 添加班级信息
• 获取添加的班级的cid
• 修改选择此班级学生的cid为添加的班级的cid

demo:

  @Testpublic void testGetPrimaryKey(){Connection connection = null;PreparedStatement statement = null;ResultSet resultSet = null;try {connection = JDBCUtil.getConnection();String sql = "insert into t_user values(null,?,?,?,?)";statement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);statement.setObject(1, "zhangsan");statement.setObject(2, "123456");statement.setObject(3, 23);statement.setObject(4, "男");statement.executeUpdate();//以结果集的方式获取自增的主键resultSet = statement.getGeneratedKeys();resultSet.next();int id = resultSet.getInt(1);System.out.println(id);} catch (Exception e) {throw new RuntimeException(e);} finally {JDBCUtil.close(resultSet, statement, connection);}}

二、批处理

• statement.addBatch();将SQL语句攒为一批
• statement.executeBatch();批处理
• 注意：要实现批处理，必须在连接地址后添加一个参数rewriteBatchedStatements=true

案例分析：

public class TestBatch {public static void main(String[] args) throws Exception{//例如：在部门表t_department中添加1000条模拟数据//1、注册驱动Class.forName("com.mysql.jdbc.Driver");//2、获取连接Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true", "root", "123456");//3、执行sqlString sql = "insert into t_department values(null,?,?)";PreparedStatement pst = conn.prepareStatement(sql);//设置？的值for (int i = 1; i <=1000; i++) {pst.setObject(1, "模拟部门"+i);pst.setObject(2, "模拟部门的简介"+i);pst.addBatch();//添加到批处理一组操作中，攒一块处理
/*			if(i % 500 == 0){//有时候也攒一部分，执行一部分//2.执行pst.executeBatch();//3.清空pst.clearBatch();}*/}pst.executeBatch();//4、关闭pst.close();conn.close();}
}

三、事务

• mysql默认每一个连接是自动提交事务的。

• 如果有多条语句想要组成一个事务一起执行的话，在JDBC这边怎么实现。

  • 在执行之前，设置手动提交事务：Connection的对象.setAutoCommit(false)
  • 成功：Connection的对象.commit(); 失败：Connection的对象.rollback();
  • 在关闭Connection的对象之前，把连接对象设置回自动提交：Connection的对象.setAutoCommit(true)

注意：

因为我们现在的连接是建立新的连接，那么如果没有还原为自动提交，没有影响。
但是我们后面实际开发中，每次获取的连接，不一定是新的连接，而是从连接池中获取的旧的连接，而且你关闭也不是真关闭， 而是还给连接池，供别人接着用。以防别人拿到后，以为是自动提交的，而没有commit，最终数据没有成功。

案例分析：

场景：
提供两张表
t_book(id,name,stock,price)
t_vip(id,username,balance)
vip买书，库存足够的，但是余额不够

• 查询图书的价格
• 更新图书的库存
• 查询用户的余额判断是否足够购买
• 更新用户的余额

格式：

 * try{*     //关闭自动提交事务*     connection.setAutoCommit(false);*     //核心操作*     //提交事务*     connection.commit();* } catch(){*     //回滚事务*     connection.rollback();* }

案例实现：

 @Testpublic void TransactionTest() {Connection connection = null;PreparedStatement ps = null;ResultSet resultSet = null;Double price = 0.0;Double balance = 0.0;try {connection = JDBCUtils.getConnection3();//取消自动提交connection.setAutoCommit(false);//查询图书的价格String sql = "select price from t_book where id =?";ps = connection.prepareStatement(sql);ps.setObject(1, 1);resultSet = ps.executeQuery();if (resultSet.next()) {price = resultSet.getDouble(1);}System.out.println("price = " + price);//查询用户余额String sql1 = "select balance from t_vip where id=?";ps = connection.prepareStatement(sql1);ps.setObject(1, 1);resultSet = ps.executeQuery();if (resultSet.next()) {balance = resultSet.getDouble(1);}System.out.println("balance = " + balance);//判断用户余额是否足够购买这本书if (balance > price) {//更新图书的库存String sql2 = "update t_book set stock=stock-1 where id=1";ps = connection.prepareStatement(sql2);ps.executeUpdate();//更新用户的余额String sql3 = "update t_vip set balance=? where id=1";ps = connection.prepareStatement(sql3);ps.setObject(1, balance - price);int i = ps.executeUpdate();//不满足则抛出异常} else {throw new RuntimeException();}//成功就提交connection.commit();connection.setAutoCommit(false);} catch (Exception e) {//捕捉到异常则回滚try {connection.rollback();} catch (SQLException ex) {throw new RuntimeException(ex);}throw new RuntimeException(e);} finally {JDBCUtils.closeAll(resultSet, ps, connection);}}

四、数据库连接池

1、什么是数据库连池
连接对象的缓冲区。负责申请，分配管理，释放连接的操作。

2、为什么要使用数据库连接池
不使用数据库连接池，每次都通过DriverManager获取新连接，用完直接抛弃断开，连接的利用率太低，太浪费。
对于数据库服务器来说，压力太大了。我们数据库服务器和Java程序对连接数也无法控制，很容易导致数据库服务器崩溃。
我们就希望能管理连接。
我们可以建立一个连接池，这个池中可以容纳一定数量的连接对象，一开始，我们可以先替用户先创建好一些连接对象，
等用户要拿连接对象时，就直接从池中拿，不用新建了，这样也可以节省时间。然后用户用完后，放回去，别人可以接着用。
可以提高连接的使用率。当池中的现有的连接都用完了，那么连接池可以向服务器申请新的连接放到池中。
直到池中的连接达到“最大连接数”，就不能在申请新的连接了，如果没有拿到连接的用户只能等待。

public class TestPool {public static void main(String[] args) throws SQLException {//1、创建数据源（数据库连接池）对象DruidDataSource ds =new DruidDataSource();//2、设置参数//(1)设置基本参数ds.setDriverClassName("com.mysql.cj.jdbc.Driver");ds.setUrl("jdbc:mysql://localhost:3306/test");ds.setUsername("root");ds.setPassword("123456");//(2)设置连接数等参数ds.setInitialSize(5);//一开始提前申请好5个连接，不够了，重写申请ds.setMaxActive(10);//最多不超过10个，如果10都用完了，还没还回来，就会出现等待ds.setMaxWait(1000);//用户最多等1000毫秒，如果1000毫秒还没有人还回来，就异常了//3、获取连接for (int i = 1; i <=15; i++) {Connection conn = ds.getConnection();System.out.println("第"+i+"个：" + conn);//如果这里没有关闭，就相当于没有还
//			conn.close();#这里关闭，是还回池中}}
}