1.JDBC程序中当一个Connection对象创建时,默认情况下是自动提交事务:每次执行一个SQL语句时,如果执行成功,就会向数据库自动提交,而不能回滚。 2.JDBC程序中为了让多个SQL语句作为一个整体执行,需要使用事务 3.调用Connection的setAutoCommit(false)可以取消自动提交事务 4.在所有的SQL语句都成功执行后,调用Connection.commit0:方法提交事务 5.在其中某个操作失败或出现异常时,调用Connection.rollback0:方法回滚事务
转账模拟
未使用事务
@Test
public void NTransaction(){
Connection connection=null;
PreparedStatement ps=null;
String sql1="update account set balance=balance-100 where id=1";
String sql2="update account set balance=balance+100 where id=2";
try {
connection=JDBCUtils.getConnection();
//执行第一句
ps=connection.prepareStatement(sql1);
ps.executeUpdate();
//这里会抛出一个异常,导致下面的语句不再执行,数据库中就会发生错误
int i=1/0;
//执行第二句
ps=connection.prepareStatement(sql2);
ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBCUtils.close(null,ps,connection);
}
}
使用事务
@Test
public void YTransaction() throws SQLException {
Connection connection=null;
PreparedStatement ps=null;
String sql1="update account set balance=balance-100 where id=1";
String sql2="update account set balance=balance+100 where id=2";
try {
connection=JDBCUtils.getConnection();
//将connection设为不自动提交,相当于开启事务
connection.setAutoCommit(false);
ps=connection.prepareStatement(sql1);
ps.executeUpdate();
//int i=1/0;
ps=connection.prepareStatement(sql2);
ps.executeUpdate();
//在这里提交事务
connection.commit();
}catch (SQLException e) {
System.out.println("发生异常,撤销操作");
//在这里回滚事务
connection.rollback();
e.printStackTrace();
}finally {
JDBCUtils.close(null,ps,connection);
}
}
批处理
1.当需要成批插入或者更新记录时。.可以采用Jav的批量更新机制,这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率。 2.JDBC的批量处理语句包括下面方法: addBatch():添加需要批量处理的SQL语句或参数 executeBatch():执行批量处理语句; clearBatch():清空批处理包的语句 3.JDBC连接MySQL时,如果要使用批处理功能,需要在配置文件的rul后面写上这一句
?rewriteBatchedStatements=true 4.批处理往往和PreparedStatement-一起搭否配使用,可以既减少编译次数,又减少运行次数,效率大太提高
@Test
public void add() throws SQLException {
Connection cc=null;
PreparedStatement ps=null;
String sql="insert into account values(null,?,?)";
cc=JDBCUtils.getConnection();
ps=cc.prepareStatement(sql);
for (int i = 1; i <=5000; i++) {
ps.setString(1,""+i);
ps.setString(2,""+i);
//传统方法ps.executeUpdate();
//批处理
ps.addBatch();
if (i%1000==0){
//每一千条处理一次
ps.executeBatch();
//清空
ps.clearBatch();
}
}
JDBCUtils.close(null,ps,cc);
}
连接池
1.传统的JDBC数据库连接使用DriverManager来获取,每次向数据库建立连接的时候都要将Connection加载到内存中,再验证IP地址,用户名和密码(0.05s~1s时间)。需要数据库连接的时候,就向数据库要求一个,频繁的进行数据库连接操作将占用很多的系统资源,容易造成服务器崩溃。 2.每一次数据库连接,使用完后都得断开,如果程序出现异常而未能关闭,将导致数据库内存泄漏,最终将导致重启数据库。 3.传统获取连接的方式,不能控制创建的连接数量,如连接过多,也可能导致内存泄漏,MySQL崩溃。 4.解决传统开发中的数据库连接问题,可以采用数据库连接池技术
原理
1.预先在缓冲池中放入一定数量的连接,当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再放回去。
2.数据库连接池负责分配、管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个。 3.当应用程序向连接池请求的连接数超过最大连接数量时,这些请求将被加入到等待队列中
连接池的种类
1.JDBC的数据库连接池使用javax.sql.DataSource来表示,DataSource只是一个接口,该接口通常由第三方提供实现 2.C3P0数据库连接池,速度相对较慢,稳定性不错(hibernate,spring) 3.DBCP数据库连接池,速度相对c3p0较快,但不稳定 4.Proxool数据库连接池,有监控连接池状态的功能,稳定性较c3pO差一点 5.BoneCP数据库连接池,速度快 6.Druid(德鲁伊)是阿里提供的数据库连接池,集DBCP、C3PO、Proxool优点于一身的数据库连接池
|