sevilin_s
sevilin_s
采纳率100%
2017-03-07 08:11

Statement executeBatch()批量提交效率好低 求高手答疑

已采纳

数据大概一共有10W条左右,不固定,
每条sql固定格式都不太一样,
分别是对不同的表做的新增或则修改的操作
所以无法用模板?的形式操作
下面是代码
其中设置的是每1000条数据提交一次
然后这1000条数据却需要大概12S左右,
整个数据跑下来十几分钟
如果是每3000条提交一次,时间也大概是40S左右,
感觉不应该这么慢啊
数据库为Oracle..
求高手指点一下优化方案

Session session = baseDAO.getSessionFactory().openSession();
Connection conn = session.connection();
Statement stmt = null;

try {
    conn.setAutoCommit(false);    // 关闭自动提交
    stmt = conn.createStatement();

    for(int i=0; i<sqlList.size(); i++){
        stmt.addBatch(sqlList.get(i));
        //System.out.println(sqlList.get(i));

        if (i % 1000 == 0 && i != 0) {
            long startTime = System.currentTimeMillis();
            stmt.executeBatch();
            conn.commit();
            stmt.clearBatch();
            System.out.println("executeBatch 执行使用了 :"+(System.currentTimeMillis() - startTime )/1000 + " 秒");
        }
    }

    // 执行批处理语句  
    stmt.executeBatch(); // 执行剩下的不到1000条的数据 
    conn.commit(); 
    conn.setAutoCommit(true);//在把自动提交打开
} catch (SQLException he) {
    he.printStackTrace();
    try {
        conn.rollback();
    } catch (SQLException e) {
        e.printStackTrace();
    }
} finally {
    if (stmt != null) {
        try {
            stmt.close();
        } catch (SQLException sqlex) {
            System.err.println(this.getClass().getName()
                            + ".mymethod - 不能关闭数据库连接: " + sqlex.toString());
        }
    }
    if (conn != null) {
        try {
            conn.close();
        } catch (SQLException sqlex) {
            System.err.println(this.getClass().getName()
                    + ".mymethod - 不能关闭数据库连接: " + sqlex.toString());
        }
    }

    session.close();
}

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

1条回答

相关推荐