例子
代码如下 | 复制代码 |
String sql = "insert into record(id, record, insetDate) values (sequence_record.nextval, ?, sysdate)"; Connection connection = DBConnection.getConnection(); PreparedStatement pstmt = connection.prepareStatement(sql); //每次提交最大条数 final int batchSize = 5000; int count = 0; for (Record record: recordList) { pstmt.setString(1, record.getRecord()); pstmt.addBatch(); if(++count % batchSize == 0) { pstmt.executeBatch(); } } //提交剩余的数据 pstmt.executeBatch(); pstmt.close(); connection.close(); |