首页 > > 网络编程 > Mysql >

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

2018-06-17 22:54:09来源：未知阅读 ()

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

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

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"+"  插入完成");
	}	
}

测试代码

package tenThreadInsert;

public class Test {

	public static void main(String[] args) {
		for (int i = 1; i <=10; i++) {
		      new MyThread().start();
			}
	}

}

运行结果：