併發插入資料百萬條

2021-09-23 13:23:02 字數 3204 閱讀 1667

1、新聞併發入庫資料 

@apioperation(value = "測試新增新聞動態")

public void testcreate(integer start,integer count)

/**

* 測試大批量新增新聞動態介面

* @param count

* @param start

*/void testto161(integer start,integer count);

public void testto161(integer start,integer count) 

private void execadd(integer start,integer count)

}}

2、政策併發入庫資料

@apioperation(value = "測試新增政策")

public void testcreate(integer start,integer count)

/**

* 測試大批量新增介面

* @param count

* @param start

*/void testto161(integer start,integer count);

public void testto161(integer start,integer count) 

private void execadd(integer start,integer count)

policy policy = new policy();

policy.settitle("政策標題" + i);

policy.setid(uuid.randomuuid().tostring());

policy.setarticlenumber("北京人力資源保障局[2019]" + i + "號");

policy.setdraftoffice("" + i);

policy.setpublishstatus(1);

policy.setpublishdate(new date());

policy.setcontent("正文" + i);

policy.setfileid(("檔名" + i).hashcode() + "");

policy.setfilename("檔名" + i+".doc");

policy.setperformdate(new date());

policy.settopiccategory("topic" + i);

policy.setvalidity("現行有效");

policy.setvaliditygrade("地方性法規");

policy.setcreatetime(new date());

policy.setmodifytime(new date());

string json = gson.tojson(policy, policy.class);

client.prepareindex()

.setindex(/*indexconstant.policy*/"lawfullyadministration.policytest")

.settype(typeconstant.type)

.setid(policy.getid())

.setsource(json)

.execute()

.actionget();

logger.info(policy.getid() + "入庫161完成");

logger.info("當前入庫第"+policy.getdraftoffice()+"條記錄");

}}

3、報告併發入庫資料

@apioperation(value = "測試新增報告")

public void testcreate(integer start,integer count)

/**

* 測試大批量新增介面

* @param count

* @param start

*/void testto78(integer start,integer count);

private static final logger logger = logge***ctory.getlogger(reportserviceimpl.class);

@override

public void testto78(integer start,integer count)

private void execadd(integer start,integer count)

report report = new report();

report.settitle("報告標題" + i);

report.setid(uuid.randomuuid().tostring());

report.setpublishstatus(1);

report.settoporder(0);

report.setsource("報告**"+i);

report.setauthor("報告作者"+i);

report.setcontent("報告正文" + i);

report.setfileid(("報告檔名" + i).hashcode() + "");

report.setfilename("報告檔名" + i+".doc");

report.setcreatetime(new date());

report.setmodifytime(new date());

string json = gson.tojson(report, report.class);

client.prepareindex()

.setindex("lawfullyadministration.report")

.settype(typeconstant.type)

.setid(report.getid())

.setsource(json)

.execute()

.actionget();

logger.info(report.getid() + "入庫78完成");

logger.info("當前入庫第"+i+"條記錄");

}}

如何利用jdbc快速插入百萬條資料

當須要向資料庫插入百萬條資料時,利用hibernate,mybatis等持久層框架時耗時較久,此時使用jdbc插入效率會更高。此種場景特別適用於讀取檔案匯入到資料庫。可以利用批處理來加快jdbc的插入效率。string sql insert into person id,name values co...

php mysql中迅速插入百萬條測試資料的方法

1.php mktime set time limit 1000 myfile c insert.sql 需要在c盤下新建insert.sql fhandler fopen myfile wb if fhandler echo 寫入成功,耗時 mktime t 注意字段不再以逗號分割,以 t分割,條...

MySQL插入百萬條資料 個人總結1

有好多種方法。之前也總結了一些,但放到現在來看,效率都一般,於是重新思考總結這個問題 方法一 使用儲存過程procedure每次insert的時候mysql都會自動提交,然後會有其他的一些耗時的操作,所以。取消掉自動提交不就好了嘛。直接 set autocommit 0 測試結果 80萬 9.67秒...