问题描述
每次循环会select出几千--几万不等的数据，然后对其处理后再更新回去。经过计算，每分钟才处理3000条数据左右，太慢了，请大家帮着查看。where条件很简单，应该不存在索引问题。是不是和数据库链接的建立有关系？请大家多多指教。代码大概如下： Statement stmt_Select = con.createStatement(); Statement stmt_Update = con.createStatement(); while (***) { String sql = "select a, b, c from tablename where ......."; stmt_Select.close(); stmt_Select=con.createStatement(); stmt_Update.close(); stmt_Update=con.createStatement(); rs = stmt_Select.executeQuery(sql); int i = 0; while (rs.next()){ // 这里会对select出来的值进行两次md5加密等 i = i + stmt_Update.executeUpdate("update tablename set a=......); } rs.close(); }
解决方案
建议批量的去执行更新、插入的操作
解决方案二：
建议你使用Updatable statement，给你一段我以前写过的代码吧，这段代码用来处理14万条记录，具体时间记不太清了，不过效率还是挺高的：String sql = "select ccrq,dt_factory_date from ajdq";Connection con = DbUtil._CONNECTION;//获得数据库连接Statement st = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);ResultSet rs = st.executeQuery(sql);int i=0;while(rs.next()){String date = rs.getString(1);Date d = DateUtil.parse(date);if(d!=null){rs.updateTimestamp(2, new Timestamp(d.getTime()));rs.updateRow();i++;System.out.print(".");if(i%100==0){System.out.println(i);con.commit();}}}rs.close();st.close();System.out.println();System.out.println(i);con.commit();con.close();
解决方案三：
建议写个存储过程处理，你的业务也不算复杂。与数据库交互必然会耗费很多时间的。
解决方案四：
PreparedStatement引用 PreparedStatement pstmt = con.prepareStatement("UPDATE EMPLOYEES SET SALARY = ? WHERE ID = ?"); pstmt.setBigDecimal(1, 153833.00) pstmt.setInt(2, 110592)
解决方案五：
stmt_Select.close(); stmt_Select=con.createStatement(); stmt_Update.close(); stmt_Update=con.createStatement(); 不要在循环里面频繁的close， 全部放在rs.close()之前参考如下stmt_Select.close();stmt_Update.close();rs.close();