返回顶部

收藏

jdbc批量数据插入的代码

更多
1899942 ,一    
1899944 ,二  
1899946 ,三 
1899948 ,四  
1899950 ,五    
1899952 ,六    
1899954 ,和  
1899956 ,在 
1899958 ,的  
1899960 ,对 
1899962 ,需 
1899964 ,大规模  
1899966 ,压力 
1899968 ,大城市 
。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。 
有几万条这样的数据需要插入数据库 

public class Main { 
public static void main(String[] args) throws Exception{ 
String sql = "insert into mobile_place(number,place) values(?,?)"; 
int count = 0;//计数器 
Connection conn = JDBCUtil.getConnection(); 
PreparedStatement pstmt = conn.prepareStatement(sql); 
try { 
InputStreamReader is = new InputStreamReader(new FileInputStream(new File("D:/CC.txt")),"utf-8"); 
BufferedReader br = new BufferedReader(is); 
while(br.readLine() != null){ 
conn.setAutoCommit(false);//设置数据手动提交,自己管理事务 
count++;//没读取一行数据,计数器+1 
String str = br.readLine().toString().trim();//读取一行数据 
String s1 = str.substring(0, str.indexOf(","));//取逗号以前的一段 
String s2 = str.substring(str.indexOf(",")+1,str.length());//取逗号之后的一段 
pstmt.setString(1, s1); 
pstmt.setString(2, s2); 
pstmt.addBatch();//用PreparedStatement的批量处理 

if(count%500==0){//当增加了500个批处理的时候再提交 
pstmt.executeBatch();//执行批处理 
conn.commit();//提交 
conn.close();//关闭数据库 
conn = JDBCUtil.getConnection();//重新获取一次连接 
conn.setAutoCommit(false); 
pstmt = conn.prepareStatement(sql); 
} 
System.out.println("已插入"+count+"条数据"); 
} 
if(count%500!=0){//while循环外的判断,为了防止上面判断后剩下最后少于500条的数据没有被插入到数据库 
pstmt.executeBatch(); 
conn.commit(); 
} 
pstmt.close(); 
conn.close(); 
} catch (Exception e) { 
e.printStackTrace(); 
} 
} 
} 
500可以自己增大,执行效率很高。比单挑执行再插入快多了 

getConnection()为获取数据库连接 
public static Connection getConnection(){ 
try { 
Class.forName("com.mysql.jdbc.Driver"); 
} catch (ClassNotFoundException e) { 
e.printStackTrace(); 
} 
try { 
conn = DriverManager.getConnection(url, userName, password); 
} catch (SQLException e) { 
e.printStackTrace(); 
} 
return conn; 
}

标签:java

收藏

0人收藏

支持

0

反对

0

相关聚客文章
  1. K-Res 发表 2018-08-22 14:50:50 屏蔽Cesium的默认双击追踪选中entity行为
  2. 刘莉莉 发表 2018-08-22 11:49:19 ColdFusion再爆远程代码执行漏洞 CVE-2018-4939
  3. wenming.gapo 发表 2018-08-22 11:56:25 Android Native Crash 收集
  4. changyuan.xu 发表 2018-08-22 12:47:04 如何使用Spring Boot的Profiles
  5. zhuangli 发表 2018-08-22 14:24:24 跳过构造函数创建 Java 对象(测试)
  6. puefu.he 发表 2018-08-22 14:54:38 郑州达内实训整理了一部分Java代码资料
  7. gonwan 发表 2018-08-21 16:44:26 A Spring Cloud Toy Project
  8. zhuangli 发表 2018-08-21 08:13:53 初识NIO之Java小Demo
  9. yanxinchi 发表 2018-08-21 08:46:11 【JVM命令及问题排查】
  10. yanxinchi 发表 2018-08-21 11:07:53 Java基础 — 异常
  11. yanxinchi 发表 2018-08-21 11:07:53 Java基础 — 异常
  12. yanxinchi 发表 2018-08-21 11:07:53 Java基础 — 异常

发表评论