SpringBoot開發案例之JdbcTemplate批量操作

  • 2019 年 12 月 9 日
  • 筆記

前言

在我們做後端服務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提供的主要方法:

  • execute方法：可以用於執行任何SQL語句，一般用於執行DDL語句；
  • update方法及batchUpdate方法：update方法用於執行新增、修改、刪除等語句；batchUpdate方法用於執行批處理相關語句；
  • query方法及queryForXXX方法：用於執行查詢相關語句；
  • call方法：用於執行存儲過程、函數相關語句。

我們只需要在使用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

Tags:

VirMach 便宜 VPS