概述
try {
String sql = "INSERT INTO USER (id,name) VALUES(?,?)";
Connection conn = null;
PreparedStatement pstm =null;
conn=CommonUtils.getConnection();
pstm = conn.prepareStatement(sql);
for(int i = 0; i < 10000; i++) {
pstm.setString(1, i);
pstm.setString(2, “小王”);
pstm.addBatch();if(i%1000==0){ //可以设置3000,5000等执行一次。
pstm.executeBatch();
}
}pstm.executeBatch();
conn.commit();
CommonUtils.connClose(conn,pstm);
}catch (Exception e) {
e.printStackTrace();
}
package com.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class CommonUtils {
public static Connection getConnection(){
String url =PropUtils.get("jdbc.url");
String user =PropUtils.get("jdbc.username");
String password =PropUtils.get("jdbc.password");
String driver=PropUtils.get("jdbc.driver");
Connection conn = null;
try {
Class.forName(driver);
conn = DriverManager.getConnection(url, user, password);
}catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
}
return conn;
}
public static void connClose(Connection conn,PreparedStatement pstm){
if(pstm!=null){
try {
pstm.close();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}
}
最后
以上就是受伤荔枝为你收集整理的批处理快速插入数据的全部内容,希望文章能够帮你解决批处理快速插入数据所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复