国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > Java > 正文

SpringBoot JdbcTemplate批量操作的示例代碼

2024-07-14 08:40:16
字體:
來源:轉載
供稿:網友

前言

在我們做后端服務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偽代碼:

@Repositorypublic 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提供的主要方法:

  1. execute方法:可以用于執行任何SQL語句,一般用于執行DDL語句;
  2. update方法及batchUpdate方法:update方法用于執行新增、修改、刪除等語句;batchUpdate方法用于執行批處理相關語句;
  3. query方法及queryForXXX方法:用于執行查詢相關語句;
  4. call方法:用于執行存儲過程、函數相關語句。

我們只需要在使用jdbcTemplate類中使用@Autowired進行注入即可:

@Autowiredprivate 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進行注入即可:

@Autowiredprivate 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

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VeVb武林網。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 乐平市| 绵阳市| 宁南县| 芷江| 仪征市| 大化| 宾川县| 疏附县| 德江县| 原平市| 平邑县| 宜川县| 阜平县| 伊宁县| 白沙| 聂拉木县| 阳朔县| 万年县| 塔城市| 江川县| 南宁市| 花莲市| 红河县| 芦溪县| 桂林市| 礼泉县| 青田县| 阳曲县| 舞阳县| 镇雄县| 大洼县| 肇州县| 宣武区| 英吉沙县| 宜黄县| 泰兴市| 九龙县| 青冈县| 凤冈县| 康保县| 康保县|