併發插入資料百萬條

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)
}}

@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()+"條記錄");
}}

@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秒...