Chinaunix

标题: 急！java如何批量插入大量数据，用数组吗？ [打印本页]

---

作者: yyuxyz    时间: 2004-05-12 22:05
标题: 急！java如何批量插入大量数据，用数组吗？
如果用循环就不必了，那样时间太长，现在要求10秒内3万条。能否用数组一

次插入？

---

作者: yyuxyz    时间: 2004-05-13 13:25
标题: 急！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

---

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)

Powered by Discuz! X3.2