前言
在我们做后端服务dao层开发，特别是大数据批量插入的时候，这时候普通的orm框架(mybatis、hibernate、jpa)就无法满足程序对性能的要求了。当然我们又不可能使用原生的jdbc进行操作，那样尽管效率会高，但是复杂度会上升。
综合考虑我们使用spring中的jdbctemplate和具名参数namedparameterjdbctemplate来进行批量操作。
改造前
在开始讲解之前，我们首先来看下之前的jpa是如何批量操作的。
实体类user：
|
1
2
3
4
5
6
7
|
public class appstudent {
private integer id;
private integer classid;
private string name;
private integer age;
//伪代码、省略构造和get、set方法
}
|
dynamicquery伪代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
@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提供的主要方法:
- execute方法：可以用于执行任何sql语句，一般用于执行ddl语句；
- update方法及batchupdate方法：update方法用于执行新增、修改、删除等语句；batchupdate方法用于执行批处理相关语句；
- query方法及queryforxxx方法：用于执行查询相关语句；
- call方法：用于执行存储过程、函数相关语句。
我们只需要在使用jdbctemplate类中使用@autowired进行注入即可：
|
1
2
|
@autowired
private jdbctemplate jdbctemplate;
|
批量插入操作：
|
1
2
3
4
5
6
7
8
|
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进行注入即可：
|
1
2
|
@autowired
private namedparameterjdbctemplate namedparameterjdbctemplate;
|
批量插入操作：
|
1
2
3
4
5
6
7
8
9
10
11
|
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()来对比打印一下具体改造前后的执行时间。
|
1
2
3
4
|
long start = system.currenttimemillis();
//改造前后代码、自行补充
long end = system.currenttimemillis();
system.out.println("花费时间:"+(end-start));
|
快肯定是快了，至于快多少，那就要根据数据量以及机器配置来做相关的对比了。
项目源码：https://gitee.com/52itstyle/spring-data-jpa
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持快网idc。
原文链接：https://blog.52itstyle.com/archives/2675/
相关文章
- 64M VPS建站：怎样选择合适的域名和SSL证书？ 2025-06-10
- 64M VPS建站：怎样优化以提高网站加载速度？ 2025-06-10
- 64M VPS建站：是否适合初学者操作和管理？ 2025-06-10
- ASP.NET自助建站系统中的用户注册和登录功能定制方法 2025-06-10
- ASP.NET自助建站系统的域名绑定与解析教程 2025-06-10
