设为首页 加入收藏

TOP

Java Jdbc减少与Oracle之间交互提升批量处理性能,到底该如何优化才好?(一)
2014-11-24 12:02:32 来源: 作者: 【 】 浏览:145
Tags:Java Jdbc 减少 Oracle 之间 交互 提升 批量 处理 性能 到底 如何 优化
不拾掇Java有好几年了(N>3吧),之所以写这篇文章其实是纯粹是为了给开发人员一些好的使用jdbc真正去减少交互和提升批量处理batch update性能的例子; 如果你是DBA,那么工作之余你可以把这篇文章推荐给开发看一下, 也许这些例子他已经知道了, 倘若他不知道,那么也算一种福利了。
能考虑到在应用程序client和 数据库服务器DB server间减少交互时间,批量更新处理的绝对是有助于重构和优化代码的好同志; 但这种优化一定要注意方法,如果是自行去重新发明一种轮子的话, 效果往往是不如人意的。
例如Tom Kytes曾在他的著作里提到这样2个例子,他去协助开发的2家企业的在研发应用的过程中,分别通过应用程序自己去在Oracle中实现了user profile和advanced queue的功能, 有一定经验的朋友肯定会知道这2样功能其实Oracle Enterprise Edition企业版软件都是原生态支持的,而自己在DB中去实现它们,最终结果自然是项目的失败。
类似的有朋友在开发过程中,为了优化Oracle JDBC中的批量更新update操作,想到了这样的方式,例如要插入INSERT 15000行数据,则在JAVA层面 将15000条INSERT语句拼接在一个PL/SQL block里,这15000条SQL涉及到的变量仍使用PreparedStatement.setXXX方法带入,其在JAVA层面的SQL STRING,如:
begin
--我是一个拼接起来的SQL匿名块
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
insert into insertit values( , , , );
.....................
commit ; end;
如上15000个INSERT拼接成一个PL/SQL block,一次性PreparedStatement.execute()提交给DB,通过这样来减少Jdbc Thin Client与DB Server之间的交互。先不说别的,光在JAVA里循环控制拼接SQL的写法多少是要花点时间的。
这种写法和 JDBC里PreparedStatement.setExecuteBatch、或者PreparedStatement+addBatch()+executeBatch()的执行效率究竟如何呢?
我们在一个简单的JAVA程序里测试这三者写法的实际性能,并窥探其在DB中的表现,以下为JAVA代码(多年不写,就勿纠结代码风格):
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package apptest;
import oracle.jdbc.*;
import java.sql.*;
/**
*
* @author xiangbli
*/
public class Apptest {
/**
* @param args the command line arguments
*/
public static void main(String[] args) throws SQLException {
// TODO code application logic here
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
}catch(Exception e){}
Connection cnn1=DriverManager.getConnection("jdbc:oracle:thin:@192.168.56.101:1521:cdb1", " c##maclean", "oracle");
Statement stat1=cnn1.createStatement();
cnn1.setAutoCommit(false);
ResultSet rst1=stat1.executeQuery("select * from v$version");
while(rst1.next())
{
System.out.println(rst1.getString(1));
}
long startTime = System.currentTimeMillis();
long stopTime = System.currentTimeMillis();
String str="begin \n --我是一个拼接起来的SQL匿名块 \n";
int i;
for(i=0;i<=15000; i++)
{
str= str.concat(" insert into insertit values( , , , ); \n");
}
str=str.concat(" commit ; end; ");
System.out.print(str);
cnn1.createStatement().execute("alter system flush shared_pool");
System.out.print("\n alter system flush shared_pool 已刷新共享池,避免SQL游标缓存 影响第一次测试 \n");
PreparedStatement pstmt = cnn1.prepareStatement(str);
int j;
for (j=0;j<=15000;j++)
{
pstmt.setInt(1+j*4, 1);
pstmt.setInt(2+j*4, 1);
pstmt.setIn
首页 上一页 1 2 3 4 5 下一页 尾页 1/5/5
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇单独hibernate 生成表 下一篇使用Comparator进行两个Object的..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: