尚硅谷JDBC
|
package com.atguigu.other;
import java.sql.Connection; import java.sql.PreparedStatement;
import org.junit.Test;
import com.atguigu.utils.JDBCUtils;
public class TestBatch { /* * 没有使用批处理 */ @Test public 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)); }
@Test public 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));
} }
|
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 常量之一：
- 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 {
@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(); } } } }
|
本教程由尚硅谷教育大数据研究院出品，如需转载请注明来源。