每次發(fā)送過(guò)來(lái)的數(shù)據(jù)，會(huì)包含多個(gè)傳感器的值，每個(gè)傳感器的數(shù)據(jù)都要存到數(shù)據(jù)庫(kù)，如果每次都調(diào)用dao去保存，那性能比較低，應(yīng)該進(jìn)行優(yōu)化，要用到mybatis的批量操作

通常大家都會(huì)使用mybatis的 <foreach>標(biāo)簽去執(zhí)行批量的insert操作，這種做法是有問(wèn)題的，foreach標(biāo)簽中在做字符串的拼接的時(shí)候，對(duì)于字符串的最大長(zhǎng)度是有限制的，如果你的數(shù)據(jù)特別多，這時(shí)拼接會(huì)報(bào)錯(cuò)，一般的培訓(xùn)機(jī)構(gòu)或網(wǎng)上的教程都不會(huì)指明這一點(diǎn)。應(yīng)該采用另外的辦法，就是mybatis的batch操作。

網(wǎng)上的例子

@Autowired private SqlSessionFactory sqlSessionFactory;@Transactional(rollbackFor = Exception.class) @Override public void batchTest() {SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH);CountryMapper mapper = sqlSession.getMapper(CountryMapper.class);List<Country> countries = mapper.selectAll();for (int i = 0; i < countries.size(); i++) {Country country = countries.get(i);country.setCountryname(country.getCountryname() + "Test");mapper.updateByPrimaryKey(country);//每 50 條提交一次if((i + 1) % 50 == 0){sqlSession.flushStatements();}}sqlSession.flushStatements(); }

自己的流程：

1）注入工廠類(lèi)

//批量插入 @Autowired private SqlSessionFactory sqlSessionFactory;

2）根據(jù)工廠類(lèi)得到批量操作的session：指定這個(gè)參數(shù)ExecutorType.BATCH

SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH);

3）執(zhí)行你的 dao的sava操作

deviceGatherDao.save(deviceGather);//。。。很多的save

4）執(zhí)行提交

sqlSession.flushStatements();

?

總結(jié)

以上是生活随笔為你收集整理的数据采集提升性能篇-使用Mybatis的批量操作api导入数据的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。