1.批处理
如果插入2000条记录，但现在使用sql缓存区，一次发送多条sql到数据库服务器执行。这种做法就叫 做批处理。
jdbc的批处理：
Statement批处理：
voidaddBatch(String sql) 添加sql到缓存区（暂时不发送）
int[]executeBatch() 执行批处理命令。 发送所有缓存区的sql
voidclearBatch() 清空sql缓存区
private static void testStatementBatch() {
Connection conn =null;
Statement stmt = null;
try{
//获取连接
conn = JDBCUtil.getConn();
//获取statement对象
stmt = conn.createStatement();
//每次给stmt这个命令行中添加20条sql语句，一次性进行发送
for (int i = 1; i <=2000; i++) {
String sql = "insert into stu values("+i+",‘周杰伦‘);";
//将这个sql先暂时添加在stmt的命令行中
stmt.addBatch(sql);
if (i%20==0) {
//批量发送sql
stmt.executeBatch();
//清空stmt的命令行列表
stmt.clearBatch();
}
}
}catch(Exception e){
e.printStackTrace();
}finally{
//释放资源
JDBCUtil.close(conn, stmt, null);
}
}
PreparedStatement批处理：
voidaddBatch() 添加参数到缓存区
int[]executeBatch() 执行批处理命令。 发送所有缓存区的sql
voidclearBatch() 清空sql缓存区
private static void testPreparedStatementBatch() {
Connection conn = null;
PreparedStatement stmt = null;
try{
conn = JDBCUtil.getConn();
//创建一个动态的sql语句
String sql = "insert into stu values(?,?);";
stmt = conn.prepareStatement(sql);
//型数据库插入2000条数据，一次插入一条
for (int i = 1; i <=2000; i++) {
stmt.setInt(1, i);
stmt.setString(2, "刘德华");
stmt.addBatch();
//判断每20条发送一次
if (i%20==0) {
stmt.executeBatch();
//清空缓存区
stmt.clearBatch();
}
}
}catch(Exception e){
e.printStackTrace();
}finally{
//释放资源
JDBCUtil.close(conn, stmt, null);
}
}
2.jdbc处理大数据文件
字符：
存储字符内容： mysql： char(0-255) varchar(0-65535) 长度有限的。 65535
大容量的字符字段：
mysql： text（64K） longtext(4G字符内容)
oracle: clob longclob
字节：
mysql： blob（65kb） mediumblob（16mb） longblog（4GB）
oracle: blob
public static void main(String[] args) {
write();
read();
}
private static void read() {
Connection conn = null;
PreparedStatement stmt = null;
ResultSet rs = null;
try{
conn = JDBCUtil.getConn();
String sql = "select * from attachment where id=?;";
stmt = conn.prepareStatement(sql);
//给参数赋值
stmt.setInt(1, 1);
rs = stmt.executeQuery();
//遍历结果集
while (rs.next()) {
//读取第2个字段
InputStream is = rs.getBinaryStream(2);
FileOutputStream fos = new FileOutputStream("D://2015.jpg");
byte[] chs = new byte[1024];
int len;
while ((len=is.read(chs))!=-1) {
fos.write(chs, 0, len);
}
//释放资源
fos.close();
is.close();
}
}catch(Exception e){
e.printStackTrace();
}finally{
//释放资源
JDBCUtil.close(conn, stmt, rs);
}
}
private static void write() {
Connection conn = null;
PreparedStatement stmt = null;
try{
conn = JDBCUtil.getConn();
String sql = "insert into attachment values(?,?);";
//预编译sql
stmt = conn.prepareStatement(sql);
//给sql参数赋值
stmt.setInt(1, 2);
//数据库默认要求，写入文件的大小是1m，如果存入数据库的文件大于这个容量就会 抛 出异常
stmt.setBlob(2, new FileInputStream("D://2016.mp3"));
//发送参数并执行sql
int count = stmt.executeUpdate();
System.out.println(count);
}catch(Exception e){
e.printStackTrace();
}finally{
//释放资源
JDBCUtil.close(conn, stmt, null);
}
}
3.事务
定义：把多条sql语句看做一个事务，要么一起成功，要么一起失败
事务的操作命令：
set autocommit =0 / 1; 设置是否自动提交事务
1： 表示自动提交事务，每执行一条sql语句，自动提交事务。
0： 表示关闭自动提交事务。
commit; 提交事务，一旦提交事务不能回滚
rollback; 回滚事务。回滚到事务的起始点。
事务操作：
Connection.setAutoCommit(false) 开启事务
Connection.commit(); 成功执行，最后提交事务
Connection.rollback(); 一旦遇到错误，回滚事务
事务的四大特性：
原子性： 要么一起成功过，要么一起失败
一致性： 数据库应该从一个一致性的状态到另一个一致性的状态，保持不变
隔离性： 多个并发事务直接应该可以相互隔离
持久性：事务一旦提交，应该永久保持下来。
public static void main(String[] args) {
Connection conn =null;
PreparedStatement stmt = null;
//扣除张三账户余额2000元
String delSql = "update account set balance=balance-2000 where name=‘张三‘;";
//增加李四账户余额2000
String addSql = "update account set balance=balance+2000 where name=‘李四‘;";
try{
conn = JDBCUtil.getConn();
//开启事务
conn.setAutoCommit(false);//将自动提交设置为手动提交
stmt = conn.prepareStatement(delSql);
//执行sql语句
stmt.executeUpdate();
//int i = 1/0;//假设在这里抛出了一个异常
stmt =conn.prepareStatement(addSql);
stmt.executeUpdate();
//手动提交
conn.commit();
System.out.println("转账成功");
}catch(Exception e){
e.printStackTrace();
//回滚
try {
conn.rollback();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}finally{
//释放资源
JDBCUtil.close(conn, stmt, null);
}
}