- 论坛徽章:
- 0
|
急!java如何批量插入大量数据,用数组吗?
不用导文件的方式,因为用sqlldr导数据,主键是一个序列,这样就不能用direct=true的方式来倒,而且表不为空时也不能用direct=true的方式,只能用普通方式倒,30000条耗时>;30秒,这样比较慢,不满足要求。我计划用java的batch insert方式来做,但时间也不理想。计划用java array insert 来做。具体代码:
oracle.sql.ARRAY ora_array1=null,ora_array2=null,ora_array3=null,ora_array4=null;
try {
oradb.beginConnect();
oradb.conn.setAutoCommit(false); // If some fail, we want to rollback the rest
PreparedStatement stmt = oradb.conn.prepareStatement(
"INSERT INTO product_tmp VALUES (?,?,?,?)" ;
try {
// Create an oracle.sql.ARRAY object to hold the values
// java.lang.Stringname
oracle.sql.ArrayDescriptor arrayDesc1 =
oracle.sql.ArrayDescriptor.createDescriptor("number_array",
oradb.conn);
oracle.sql.ArrayDescriptor arrayDesc2 =
oracle.sql.ArrayDescriptor.createDescriptor("string_array",
oradb.conn);
oracle.sql.ArrayDescriptor arrayDesc3 =
oracle.sql.ArrayDescriptor.createDescriptor("string_array",
oradb.conn);
oracle.sql.ArrayDescriptor arrayDesc4 =
oracle.sql.ArrayDescriptor.createDescriptor("STRING_ARRAY",
oradb.conn);
int array1[] = new int[30000];
String array2[] = new String[30000];
String array3[] = new String[30000];
String array4[] = new String[30000];
Array t[] = new Array[30000];
for (int i = 0; i < 30000; i++) {
array1 = 444;
array2 = "115S0003A";
array3 = "ic";
array4 = "136";
}
ora_array1 = new oracle.sql.ARRAY(arrayDesc1, oradb.conn, array1);
ora_array2 = new oracle.sql.ARRAY(arrayDesc2, oradb.conn, array2);
ora_array3 = new oracle.sql.ARRAY(arrayDesc3, oradb.conn, array3);
ora_array4 = new oracle.sql.ARRAY(arrayDesc4, oradb.conn, array4);
}
catch (Exception ex) {
ex.printStackTrace(out);
}
stmt.setArray(1, ora_array1);
stmt.setArray(2, ora_array2);
stmt.setArray(3, ora_array3);
stmt.setArray(4, ora_array4);
/*
stmt.setInt(1,333);
stmt.setString(2, "115S0003A" ;
stmt.setString(3, "ic" ;
stmt.setString(4, "136" ;
stmt.addBatch( );
stmt.setInt(1,333);
stmt.setString(2, "115S0003A" ;
stmt.setString(3, "ic" ;
stmt.setString(4, "136" ;
*/
stmt.addBatch();
int[] upCounts = stmt.executeBatch();
oradb.conn.commit();
}
catch (Exception ex) {
}
oradb.closeConnection();
这里有几篇参考资料:
http://archives.postgresql.org/pgsql-jdbc/2003-07/msg00179.php
http://jakarta.apache.org/commons/dbutils/xref/org/apache/commons/dbutils/QueryRunner.html
http://javaalmanac.com/egs/java.sql/BatchUpdate.html
http://javaalmanac.com/egs/java.sql/CanBatch.html
http://javaalmanac.com/egs/java.sql/InsertArrayPs.html
http://www.zdnet.com.cn/developer/code/story/0,2000081534,39224104,00.htm
http://asktom.oracle.com/pls/ask/f?p=4950:8:::::F4950_P8_DISPLAYID:8908169959941 |
|