欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

SpringBoot JdbcTemplate批量操作的示例代码

程序员文章站 2023-12-11 19:58:58
前言 在我们做后端服务dao层开发,特别是大数据批量插入的时候,这时候普通的orm框架(mybatis、hibernate、jpa)就无法满足程序对性能的要求了。当然我们...

前言

在我们做后端服务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提供的主要方法:

  1. execute方法:可以用于执行任何sql语句,一般用于执行ddl语句;
  2. update方法及batchupdate方法:update方法用于执行新增、修改、删除等语句;batchupdate方法用于执行批处理相关语句;
  3. query方法及queryforxxx方法:用于执行查询相关语句;
  4. 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));

快肯定是快了,至于快多少,那就要根据数据量以及机器配置来做相关的对比了。

项目源码:

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

上一篇:

下一篇: