溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
前言
在我們做后端服務Dao層開發，特別是大數據批量插入的時候，這時候普通的ORM框架(Mybatis、hibernate、JPA)就無法滿足程序對性能的要求了。當然我們又不可能使用原生的JDBC進行操作，那樣盡管效率會高，但是復雜度會上升。
綜合考慮我們使用Spring中的JdbcTemplate和具名參數namedParameterJdbcTemplate來進行批量操作。
改造前
在開始講解之前，我們首先來看下之前的JPA是如何批量操作的。
實體類User：
public class AppStudent {
private Integer id;
private Integer classId;
private String name;
private Integer age;
//偽代碼、省略構造和get、set方法
}
DynamicQuery偽代碼：
@Repository
public class DynamicQueryImpl implements DynamicQuery {
@PersistenceContext
private EntityManager em;
public EntityManager getEntityManager() {
return em;
}
//其實就是for循環、使用EntityManager的persist方法循環保存而已
@Override
public <T> void saveList(List<T> resultList) {
for (int i = 0; i < resultList.size(); i++) {
T t = resultList.get(i);
em.persist(t);
}
}
}
改造后
JdbcTemplate
JdbcTemplate提供的主要方法:
我們只需要在使用jdbcTemplate類中使用@Autowired進行注入即可：
@Autowired private JdbcTemplate jdbcTemplate;
批量插入操作：
public void batchSave(){
List<Object[]> batchArgs=new ArrayList<Object[]>();
batchArgs.add(new Object[]{1,"小明",21});
batchArgs.add(new Object[]{2,"小紅",22});
batchArgs.add(new Object[]{3,"露西",23});
String sql = "insert into user (username,password) values (?,?)";
jdbcTemplate.batchUpdate(sql, batchArgs);
}
以上基本實現了批量插入功能，但是當數據庫字段比較多的時候，再以?占位符的形式編碼的話就可能不是那么好一 一對應了，這里spring還提供了SimpleJdbcTemplate(Spring3.1+ 以后被標記為過時，到Spring 4.3則被完全移除，后面這個完全能滿足需求)和NamedParameterJdbcTemplate模板引擎。
NamedParameterJdbcTemplate
相信使用過Hibernate的同學都知道，HQL中可以使用？或者:*的方式在外部配置查詢參數。在 Spring JDBC 框架中，也提供了一種綁定 SQL 參數的方式，使用具名參數(named parameter)。
我們只需要在使用NamedParameterJdbcTemplate類中使用@Autowired進行注入即可：
@Autowired private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
批量插入操作：
public void batchSave(){
List<User> list = new ArrayList<User>();
//新增用戶
list.add(new AppStudent(1,"張三",21));
list.add(new AppStudent(1,"李四",22));
list.add(new AppStudent(1,"王二麻子",23));
//批量轉數組
SqlParameterSource[] beanSources = SqlParameterSourceUtils.createBatch(list.toArray());
String sql = "INSERT INTO app_student(class_id,name,age) VALUES (:classId,:name,:age)";
namedParameterJdbcTemplate.batchUpdate(sql, beanSources);
}
最后我們使用System.currentTimeMillis()來對比打印一下具體改造前后的執行時間。
long start = System.currentTimeMillis();
//改造前后代碼、自行補充
long end = System.currentTimeMillis();
System.out.println("花費時間:"+(end-start));
快肯定是快了，至于快多少，那就要根據數據量以及機器配置來做相關的對比了。
項目源碼：https://gitee.com/52itstyle/spring-data-jpa
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
