你的位置:首页 > 软件开发 > 数据库 > 干货~多线程下1分钟完成1000万条数据插入到数据库中

干货~多线程下1分钟完成1000万条数据插入到数据库中

发布时间:2016-08-17 09:00:18
环境:准备测试前,我查看了一下我公司的电脑是4核的(四个子窗口) 废话少说,直接附上代码和结果吧package tenThreadInsert;import java.sql.Connection;import java.sql.DriverManager;import ja ...

 

 环境:准备测试前,我查看了一下我公司的电脑是4核的(四个子窗口)

干货~多线程下1分钟完成1000万条数据插入到数据库中

 

废话少说,直接附上代码和结果吧

package tenThreadInsert;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;import java.util.Date;public class MyThread extends Thread{				public void run() {					 String url = "jdbc:mysql://127.0.0.1/teacher"; 					 String name = "com.mysql.jdbc.Driver"; 					 String user = "root"; 					 String password = "123456"; 					Connection conn = null; 					try {						Class.forName(name);						conn = DriverManager.getConnection(url, user, password);//获取连接 						conn.setAutoCommit(false);//关闭自动提交,不然conn.commit()运行到这句会报错					} catch (ClassNotFoundException e1) {						e1.printStackTrace();					} catch (SQLException e) {						e.printStackTrace();					}				// 开始时间				Long begin = new Date().getTime();				// sql前缀				String prefix = "INSERT INTO test_teacher (t_name,t_password,sex,description,pic_url,school_name,regist_date,remark) VALUES ";				try {					// 保存sql后缀					StringBuffer suffix = new StringBuffer();					// 设置事务为非自动提交					conn.setAutoCommit(false);					// 比起st,pst会更好些					PreparedStatement pst = (PreparedStatement) conn.prepareStatement("");//准备执行语句					// 外层循环,总提交事务次数					for (int i = 1; i <= 10; i++) {						suffix = new StringBuffer();						// 第j次提交步长						for (int j = 1; j <= 100000; j++) {							// 构建SQL后缀							suffix.append("('" +i*j+"','123456'"+ ",'男'"+",'教师'"+",'www.bbb.com'"+",'Java大学'"+",'"+"2016-08-16 14:43:26"+"','备注'" +"),");						}						// 构建完整SQL						String sql = prefix + suffix.substring(0, suffix.length() - 1);						// 添加执行SQL						pst.addBatch(sql);						// 执行操作						pst.executeBatch();						// 提交事务						conn.commit();						// 清空上一次添加的数据						suffix = new StringBuffer();					}					// 头等连接					pst.close();					conn.close();				} catch (SQLException e) {					e.printStackTrace();				}				// 结束时间				Long end = new Date().getTime();				// 耗时				System.out.println("100万条数据插入花费时间 : " + (end - begin) / 1000 + " s"+" 插入完成");	}	}

原标题:干货~多线程下1分钟完成1000万条数据插入到数据库中

关键词:数据库

*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。