Spring Hibernate 批量操做數據庫

此文章純屬我的代碼記錄片斷不喜勿噴

網上搜了好多發現Hibernate 批量操做都沒有什麼較好的解決方案，最後使用JdbcTemplate 解決的。

解決方案一(Hibernate）

批量插入代碼：

@Override
    public Integer insertBatchApiCase(List<ApiCase> list) {
        Session session = wyqWCWWriteHibernateTemplate.getSessionFactory().openSession();
        Transaction transaction = session.beginTransaction();
        for (int i = 0; i < list.size(); i++) {
            ApiCase apiCase = list.get(i);
            apiCase.setId((Integer) session.save(apiCase));
            if (i % 100 == 0) {
                session.flush();
                session.clear();
            }
        }
        transaction.commit();
        return list.size();
    }

最終Hibernate 執行的時候還會是一條一條的執行的。

解決方案二(JdbcTemplate）

批量插入代碼：

@Override
public Integer insertJdbcTemplateBatchCaseAnalyze(final List<CaseAnalyze> list) {
    final String batch = new String(System.currentTimeMillis()+"");
    String sql = "INSERT INTO case_analyze (user_id, case_category_type) VALUES (?, ?);";

    writeJdbcTemplate.batchUpdate(sql, list, 500, new ParameterizedPreparedStatementSetter<CaseAnalyze>() {
        @Override
        public void setValues(PreparedStatement ps, CaseAnalyze argument) throws SQLException {
            ps.setObject(1,argument.getUserId());
            ps.setObject(2,argument.getCaseCategoryType());
        }
    });

    return list.size();
}


private List<ApiCase> findApiCaseBatch(Integer userId,String batch){
	String SQL = "SELECT * FROM api_case WHERE user_id =? AND last_update_time =? ";
	return writeJdbcTemplate.query(SQL,new Object[]{userId,batch},new BeanPropertyRowMapper(ApiCase.class));
}

這個地方應該能夠優化的因爲開發進度緊因此你們懂得。