oceanbase批量插入和更新事宜

java + jdk1.8 + ob v4 + mybatis框架,在批量插入或更新时一直不生产,有没有好的解决办法?
数据库连接串有配置:rewriteBatchedStatements=TRUE&allowMultiQueries=TRUE&useLocalSessionState=TRUE&useUnicode=TRUE

session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);
PlyRiskPersonDAO plyRiskPersonDAO = session.getMapper(PlyRiskPersonDAO.class);
for(int i=0; i<riskPersonList.size(); i++){
plyRiskPersonDAO.updateByPrimaryKeyCipher(riskPersonList.get(i));
if((i+1) % 300 ==0){
session.flushStatements();
session.commit();
}
}
session.flushStatements();
session.commit();

sql
update ply_risk_person set
UPDATED_BY =#{updatedBy,jdbcType=VARCHAR} ,
UPDATED_DATE =sysdate ,

1 个赞