溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

SpringBoot JdbcTemplate批量操作的示例代碼

發(fā)布時(shí)間：2020-10-18 18:38:28 來源：腳本之家 閱讀：177 作者：柒''''s 欄目：編程語言

前言

在我們做后端服務(wù)Dao層開發(fā)，特別是大數(shù)據(jù)批量插入的時(shí)候，這時(shí)候普通的ORM框架(Mybatis、hibernate、JPA)就無法滿足程序?qū)π阅艿囊罅?。?dāng)然我們又不可能使用原生的JDBC進(jìn)行操作，那樣盡管效率會(huì)高，但是復(fù)雜度會(huì)上升。

綜合考慮我們使用Spring中的JdbcTemplate和具名參數(shù)namedParameterJdbcTemplate來進(jìn)行批量操作。

改造前

在開始講解之前，我們首先來看下之前的JPA是如何批量操作的。

實(shí)體類User：

public class AppStudent {
 private Integer id;
 private Integer classId;
 private String name;
 private Integer age;
 //偽代碼、省略構(gòu)造和get、set方法
}

DynamicQuery偽代碼：

@Repository
public class DynamicQueryImpl implements DynamicQuery {

 @PersistenceContext
 private EntityManager em;

 public EntityManager getEntityManager() {
  return em;
 }
 //其實(shí)就是for循環(huán)、使用EntityManager的persist方法循環(huán)保存而已
 @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提供的主要方法:

  1. execute方法：可以用于執(zhí)行任何SQL語句，一般用于執(zhí)行DDL語句；
  2. update方法及batchUpdate方法：update方法用于執(zhí)行新增、修改、刪除等語句；batchUpdate方法用于執(zhí)行批處理相關(guān)語句；
  3. query方法及queryForXXX方法：用于執(zhí)行查詢相關(guān)語句；
  4. call方法：用于執(zhí)行存儲(chǔ)過程、函數(shù)相關(guān)語句。

我們只需要在使用jdbcTemplate類中使用@Autowired進(jìn)行注入即可：

@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);
}

以上基本實(shí)現(xiàn)了批量插入功能，但是當(dāng)數(shù)據(jù)庫字段比較多的時(shí)候，再以?占位符的形式編碼的話就可能不是那么好一 一對(duì)應(yīng)了，這里spring還提供了SimpleJdbcTemplate(Spring3.1+ 以后被標(biāo)記為過時(shí)，到Spring 4.3則被完全移除，后面這個(gè)完全能滿足需求)和NamedParameterJdbcTemplate模板引擎。

NamedParameterJdbcTemplate

相信使用過Hibernate的同學(xué)都知道，HQL中可以使用？或者:*的方式在外部配置查詢參數(shù)。在 Spring JDBC 框架中，也提供了一種綁定 SQL 參數(shù)的方式，使用具名參數(shù)(named parameter)。

我們只需要在使用NamedParameterJdbcTemplate類中使用@Autowired進(jìn)行注入即可：

@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));
 //批量轉(zhuǎn)數(shù)組
 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()來對(duì)比打印一下具體改造前后的執(zhí)行時(shí)間。

long start = System.currentTimeMillis();
//改造前后代碼、自行補(bǔ)充
long end = System.currentTimeMillis();
System.out.println("花費(fèi)時(shí)間:"+(end-start));

快肯定是快了，至于快多少，那就要根據(jù)數(shù)據(jù)量以及機(jī)器配置來做相關(guān)的對(duì)比了。

項(xiàng)目源碼：https://gitee.com/52itstyle/spring-data-jpa

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手