前不久寫過一篇高效大批量制造MySQL數(shù)據(jù)的文章：《如何利用LoadRunner最高效的批量制造MySQL數(shù)據(jù)》，后來有人問我嘀趟，怎么高效大批量制造Oracle數(shù)據(jù)脐区。其實(shí)是一樣的，也是用JDBC的批量插入（addBatch）方法她按，以下就提供一下我寫的腳本牛隅，以供參考：
/*
* LoadRunner Java script. (Build: _build_number_)
*
* Script Description:
*? ? ? ? ? ? ? ? ? ?
*/
import lrapi.lr;
import java.io.File;
import java.io.IOException;
import java.sql.Connection;?
import java.sql.DriverManager;?
import java.sql.PreparedStatement;?
import java.sql.SQLException;
import java.lang.StringBuffer;
import java.util.List;
import java.util.ArrayList;
public class Actions
{
//設(shè)定數(shù)據(jù)庫驅(qū)動(dòng)，數(shù)據(jù)庫連接地址酌泰、端口媒佣、名稱，用戶名陵刹，密碼?
? ? String driverName="oracle.jdbc.OracleDriver";?
? ? String url="jdbc:oracle:thin:@192.168.1.176:1521:orcl";?
? ? String user="test";? //用戶名?
? ? String password="123456";? //密碼?
? ? PreparedStatement pstmt = null;?
? ? //數(shù)據(jù)庫連接對象?
? ? Connection conn = null;
? ? public void connection(){
? ? try {
//反射Oracle數(shù)據(jù)庫驅(qū)動(dòng)程序類?
Class.forName(driverName);?
//獲取數(shù)據(jù)庫連接?
conn = DriverManager.getConnection(url, user, password);?
? ? ? ? // 關(guān)閉事務(wù)自動(dòng)提交
? conn.setAutoCommit(false);? ? ?
//輸出數(shù)據(jù)庫連接?
System.out.println(conn);
? ? } catch (ClassNotFoundException e) {?
e.printStackTrace();?
? ? } catch (SQLException e) {?
e.printStackTrace();?
? ? }
}
public void deconnection(){
? ? try{?
? ? if(pstmt != null){?
pstmt.close();?
? ? }
? ? if(conn != null){?
conn.close();?
? ? }
} catch (SQLException e) {?
? ? e.printStackTrace();?
}?
}
? ? public void addBatchData(List alist){
? ? try{
? ? for (int i = 0; i < alist.size(); i++) {
? ? pstmt.setString((i+1), alist.get(i).toString());
? }
? ? //把一個(gè)SQL命令加入命令列表
? ? pstmt.addBatch();
? ? } catch (Exception e) {?
e.printStackTrace();?
? ? }
? ? }
public int init() throws Throwable {
return 0;
}//end of init
public int action() throws Throwable {
? ? ? ? String sqlStr="insert into test_opadetail(id, opaid, pripid, uniscid, entname, enttype, enttype_cn, regorg, " +
? ? ? ? "regorg_cn, lerep, regno, certype, cerno, specause, specause_cn, abntime, decorg, decorg_cn, ismove, " +
? ? ? ? "remexcpres, remexcpres_cn, remdate, redecorg, redecorg_cn, creationtime, creatoruserid, lastmodificationtime, " +
? ? ? ? "lastmodifieruserid, deletiontime, deleteruserid, isdeleted, dom, enttype_zn, year)" +
? ? ? ? ? ? " values " +
? ? ? ? "(sys_guid(), ?, ?, ?, ?, ?, ?, '220101', '長春市工商行政管理局', 'test', ?, '', '', 1, " +
? ? ? ? "'未按規(guī)定公示年報(bào)', to_date(to_char(sysdate,'yyyy/mm/dd'),'YYYY/MM/DD'), '220101', '長春市工商行政管理局', 1," +
" '', '', '', '', '', to_date(to_char(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS'), " +
? ? ? ? "'97e6daadd18f4667be0c5c42b84b8a90', to_date(to_char(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS'), " +
? ? ? ? "'97e6daadd18f4667be0c5c42b84b8a90', '', '', 0, ?, ?, '')";
? ? List list = new ArrayList();//定義一組參數(shù)化數(shù)據(jù)
? ? list.add(lr.eval_string("{Param1}"));
? ? list.add(lr.eval_string("{Param2}"));
? ? list.add(lr.eval_string("{Param3}"));
? ? list.add("TEST"+lr.eval_string("{Param4}"));
? ? list.add(lr.eval_string("{Param5}"));
? ? list.add(lr.eval_string("{Param6}"));
? ? list.add(lr.eval_string("{Param7}"));
? ? list.add(lr.eval_string("TESTA-{Param4}"));
? ? list.add(lr.eval_string("{Param12}"));
? ? connection();
? ? StringBuffer sql = new StringBuffer();
? sql.append(sqlStr);
? lr.start_transaction("action");
? ? try{
? //創(chuàng)建該連接下的PreparedStatement對象?
? ? pstmt = conn.prepareStatement(sql.toString());
? ? for (int k=0;k<1000;k++){//一個(gè)User一批次插入1000條
? ? addBatchData(list);
? ? }
// 執(zhí)行批量更新
? pstmt.executeBatch();
} catch (Exception e) {?
e.printStackTrace();?
? ? }
? lr.end_transaction("action", lr.AUTO);
? ? deconnection();
return 0;
}//end of action
public int end() throws Throwable {?
return 0;
}//end of end
}
然后通過Loadrunner進(jìn)行多用戶并發(fā)的跑腳本默伍，快速的制造出成千上億條數(shù)據(jù)，我就是用這個(gè)方法衰琐，在測試環(huán)境中模擬出現(xiàn)場的大數(shù)據(jù)量也糊，然后去重現(xiàn)或定位系統(tǒng)當(dāng)中由于慢SQL引起的慢事務(wù)問題。
????????注：以上是批量插入數(shù)據(jù)的腳本羡宙，有人會(huì)將批量更新也放到腳本中執(zhí)行狸剃，這時(shí)候就要避免行級(jí)鎖在高并發(fā)時(shí)引起死鎖，所以強(qiáng)調(diào)更新條件應(yīng)該使用主鍵狗热。
