批量制造數(shù)據(jù)的方法有很多種芋酌，也有許多專業(yè)的工具，但是都算不上高效同云，針對MySQL的批量插入數(shù)據(jù)炸站，目前認(rèn)為最高效的方式是通過執(zhí)行JAVA代碼（通過設(shè)置事務(wù)為非自動(dòng)提交旱易，以executeBatch批處理提交大量插入事務(wù)）來實(shí)現(xiàn)，但是JAVA的靈活參數(shù)化和大用戶量分布式并發(fā)執(zhí)行如暖，絕對沒有LoadRunner方便盒至。
所以我們可以利用LoadRunner+JAVA的方式枷遂，來實(shí)現(xiàn)高效登淘、高可靠封字、持續(xù)性的批量造數(shù)據(jù)阔籽，既利用LoadRunner的Java_Vuser：
1笆制、在loadrunner中新建腳本（本文以LoadRunner11為例）在辆，要求選擇協(xié)議類型為Java->Java Vuser
2匆篓、在Run-time Settings設(shè)置JDK路徑鸦概，由于LoadRunner11不支持jdk1.8，所以推薦引用jdk1.6
3甩骏、需要mysql的java驅(qū)動(dòng)窗市，可以到MySQL官網(wǎng)下載"mysql-connector-Java",并通過Run-time Settings引用JAR包
4、在Java Vuser輸入以下樣例代碼：
/*
* LoadRunner Java script. (Build: _build_number_)
* Script Description:? ? ? ? ? ? ? ?
*/
import lrapi.lr;
import java.beans.Statement;?
import java.sql.Connection;?
import java.sql.DriverManager;?
import java.sql.PreparedStatement;?
import java.sql.ResultSet;?
import java.sql.SQLException;
public class Actions
{
? ? private Connection conn = null;?
? ? PreparedStatement statement = null;
? ? // connect to MySQL?
? ? void connSQL() {?
? ? ? ? String url = "jdbc:mysql://172.16.1.67:3306/test?characterEncoding=UTF-8";?
? ? ? ? String username = "root";?
? ? ? ? String password = "123456"; // 加載驅(qū)動(dòng)程序以連接數(shù)據(jù)庫?
? ? ? ? try {?
? ? ? ? ? ? Class.forName("com.mysql.jdbc.Driver" );?
? ? ? ? ? ? conn = DriverManager.getConnection( url,username, password );?
? ? ? ? ? ? }?
? ? ? ? //捕獲加載驅(qū)動(dòng)程序異常?
? ? ? ? catch ( ClassNotFoundException cnfex ) {?
? ? ? ? ? ? System.err.println(?
? ? ? ? ? ? "裝載 JDBC/ODBC 驅(qū)動(dòng)程序失敗饮笛。" );?
? ? ? ? ? ? cnfex.printStackTrace();?
? ? ? ? }?
? ? ? ? //捕獲連接數(shù)據(jù)庫異常?
? ? ? ? catch ( SQLException sqlex ) {?
? ? ? ? ? ? System.err.println( "無法連接數(shù)據(jù)庫" );?
? ? ? ? ? ? sqlex.printStackTrace();?
? ? ? ? }?
? ? }?
? ? // disconnect to MySQL?
? ? void deconnSQL() {?
? ? ? ? try {?
? ? ? ? ? ? if (conn != null)?
? ? ? ? ? ? ? ? conn.close();?
? ? ? ? } catch (Exception e) {?
? ? ? ? ? ? System.out.println("關(guān)閉數(shù)據(jù)庫問題 ：");?
? ? ? ? ? ? e.printStackTrace();?
? ? ? ? }?
? ? }
public int init() throws Throwable {
connSQL();
return 0;
}//end of init
public int action() throws Throwable {
? ? String sql = "insert into MySqlTest(ID, DataName, InsertTime, UpdateTime, DataType,DataSet) values(REPLACE(uuid(), '-', ''),?,now(),null,1,'LoadRunner')";
? ? ? ? ? ? conn.setAutoCommit(false);
? ? statement = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
? ? lr.start_transaction("Insert");
? ? for(int i=0;i<1000;i++){//每1000條記錄為一組事務(wù)咨察，每個(gè)虛擬用戶至少執(zhí)行一組批量插入事務(wù)
? ? ? ? ? ? ? ? statement.setString(1,"Test-A2B-");//用LoadRunner的方式設(shè)置隨機(jī)數(shù)參數(shù)
? ? ? ? ? ? ? ? statement.addBatch();
? ? }
? ? statement.executeBatch();
? ? ? ? ? ? conn.commit();
? ? lr.end_transaction("Insert", lr.AUTO);
return 0;
}//end of action
public int end() throws Throwable {
deconnSQL();
return 0;
}//end of end
}
5、將以上腳本放到Loadrunner中執(zhí)行（場景設(shè)置100用戶福青，每個(gè)用戶只執(zhí)行一次扎拣，同時(shí)執(zhí)行，這樣就確保只插入10萬條記錄），經(jīng)過測試二蓝，發(fā)現(xiàn)最多16秒就完成10萬條記錄的插入（平均執(zhí)行的時(shí)間是11.658秒）誉券。
7踊跟、也可以將for循環(huán)去掉，通過loadrunner的action循環(huán)1000次來實(shí)現(xiàn)
但是這樣改變后速度要比用for循環(huán)慢多了钠龙，經(jīng)過測試發(fā)現(xiàn)插入10萬條數(shù)據(jù)沈矿，需要33秒（平均執(zhí)行一次action是0.027秒），為什么呢，仔細(xì)對照就發(fā)現(xiàn)是因?yàn)閍ction里包括了conn.commit()，也就是說每次循環(huán)都執(zhí)行事務(wù)提交图贸，批量1000條插入變成了單條插入撒汉。把腳本改動(dòng)一下：
public int init() throws Throwable {
? ? connSQL();
? ? String sql = "insert into MySqlTest(ID, DataName, InsertTime, UpdateTime, DataType,DataSet) values(REPLACE(uuid(), '-', ''),?,now(),null,1,'LoadRunner')";
? ? conn.setAutoCommit(false);
? ? statement = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
? ? return 0;
}//end of init
public int action() throws Throwable {? ?
? ? lr.start_transaction("action");
? ? ? ? ? ? ? ? statement.setString(1,"Test-A2B-");?
? ? ? ? ? ? ? ? statement.addBatch();? ?
? ? lr.end_transaction("action", lr.AUTO);
? ? return 0;
}//end of action
public int end() throws Throwable {
? ? statement.executeBatch();
? ? conn.commit();
? ? deconnSQL();
? ? return 0;
}//end of end
這么一改動(dòng)，就把prepareStatement和commit都放到循環(huán)action之外，相當(dāng)于一個(gè)用戶執(zhí)行完1000條預(yù)插入記錄后增拥，才進(jìn)行commit提交猾封，速度立馬提高，經(jīng)過測試铅搓，10萬條記錄批量insert只要15秒（平均執(zhí)行一次action是0.001秒）多望。
8、如果要插入更多的數(shù)據(jù)，只需要用更多的用戶和執(zhí)行更長的并發(fā)時(shí)間就能輕松實(shí)現(xiàn)维蒙，而且參數(shù)化方便局待，如果單臺壓力機(jī)承受不了纽门，還可以分布式部署多臺壓力機(jī)愤钾。
????????注：以上是批量插入數(shù)據(jù)的腳本，有人會(huì)將批量更新也放到腳本中執(zhí)行，這時(shí)候就要避免行級鎖在高并發(fā)時(shí)引起死鎖，所以強(qiáng)調(diào)更新條件應(yīng)該使用主鍵。
