gfwleak/k18-ntcs-web-ntc
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

asn统计updatesql，不分批次提交

Browse Source
This commit is contained in:
duandongmei
2019-01-27 18:07:43 +06:00
parent 10e0064556
commit a7914aafac
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/nis/web/task/StatisticASNIpNumer.java
View File

@@ -111,15 +111,11 @@ public class StatisticASNIpNumer {
SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class); SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class);
SqlSession batchSqlSession = null; SqlSession batchSqlSession = null;
try { try {
batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, true);
for(Entry<Integer,Map<String,Long>> e: asnNumerMap.entrySet()) { for(Entry<Integer,Map<String,Long>> e: asnNumerMap.entrySet()) {
batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
((AsnGroupInfoDao) batchSqlSession.getMapper(AsnGroupInfoDao.class)).updateIpNum(e.getValue().get("v4"),e.getValue().get("v6"),e.getKey()); ((AsnGroupInfoDao) batchSqlSession.getMapper(AsnGroupInfoDao.class)).updateIpNum(e.getValue().get("v4"),e.getValue().get("v6"),e.getKey());
if(index!= 0 && index%20000==0){
batchSqlSession.commit();
}
index++; index++;
} }
batchSqlSession.commit();
}catch (Exception e) { }catch (Exception e) {
logger.error("修改ASN IP个数失败", e); logger.error("修改ASN IP个数失败", e);
} finally { } finally {