java 原生sql批量插入,Java对象集合转MySQL批量插入语句
Mybatis的批量插入确实很好用,但是当数据量特别大的时候可能一次批量插入2000条数据就死翘翘了。怎么办呢?当然是原生sql是最快的啦,10000条数据秒入无压力。下面是将对象集合拼接成批量插入MySQL的简单工具类。
package com.aijiao.util;
import org.apache.commons.lang3.StringUtils;
import org.springframework.util.CollectionUtils;
import java.lang.reflect.Field;
import java.util.List;
public class SqlJointUtils {
private static final String UNDERLINE = "_";
private static final String SINGLR_QUOTES = "'";
private static final String COMMA = ",";
private static final String LEFT_BRACKET = "(";
private static final String RIGHT_BRACKET = ")";
/**
* 批量插入
*
* @param list 对象集合
* @param tableName 表名
* @param 实体类类型
* @return java.lang.String
*/
public static String jointBatchInsert(List list, String tableName) {
if (CollectionUtils.isEmpty(list)) {
return null;
}
T t = list.get(0);
String jointSqlColumnName = jointSqlColumnName(t.getClass(), tableName);
StringBuffer sb = new StringBuffer(jointSqlColumnName);
for (int i = 0; i < list.size(); i++) {
sb.append(LEFT_BRACKET);
Object o = list.get(i);
Class> aClass = o.getClass();
Field[] fields = aClass.getDeclaredFields();
for (int j = 0; j < fields.length; j++) {
Field field = fields[j];
try {
field.setAccessible(true);
Object o1 = field.get(o);
Class> type = field.getType();
String name = type.getSimpleName();
if (name.equals("String")) {
String s = (String) o1;
if (StringUtils.isBlank(s)) {
s = null;
sb.append(s + COMMA);
} else {
sb.append(SINGLR_QUOTES + s + SINGLR_QUOTES + COMMA);
}
} else if (name.equals("Integer")) {
Integer integer = (Integer) o1;
if (integer == null) {
integer = 0;
}
sb.append(integer + COMMA);
} else if (name.equals("date")) {
sb.append("now(),");
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
//将最后一个“,”暨倒数第一个字符替换为“)”
sb.replace(sb.length() - 1, sb.length() - 1, RIGHT_BRACKET);
}
//去掉会后一个“,”
return sb.substring(0, sb.length() - 1);
}
/**
* 拼接sql插入字段名
*
* @param c 实体类类型
* @param tableName 表名
* @return java.lang.String
*/
public static String jointSqlColumnName(Class c, String tableName) {
StringBuffer sb = new StringBuffer();
sb.append("insert into " + tableName + LEFT_BRACKET);
Field[] fields = c.getDeclaredFields();
for (int i = 0; i < fields.length; i++) {
Field field = fields[i];
String name = field.getName();
String s = fieldConvertColumn(name);
sb.append(s + COMMA);
}
return sb.substring(0, sb.length() - 1) + ") values";
}
/**
* java对象属性名转数据库字段名
*
* @param s 属性名
* @return java.lang.String
*/
static String fieldConvertColumn(String s) {
StringBuffer sb = new StringBuffer();
for (int i = 0; i < s.length(); i++) {
char c = s.charAt(i);
if (Character.isUpperCase(c)) {
sb.append(UNDERLINE);
}
sb.append(c);
}
return sb.toString().toLowerCase();
}
}
目前只对字符串类型、时间和整型类型做了处理,后续将优化。
主键未处理,后续将优化
java 原生sql批量插入,Java对象集合转MySQL批量插入语句相关推荐
- java sql 排序_JAVA像SQL一样对List对象集合进行排序
在开始之前,我先卖个关子提一个问题:假设我们有一个Movie类,这个类有三个成员变量分别是starred(是否收藏), title(电影名称), rating(评分).你知道怎么对一个Movie对象组 ...
- java util包排序_实现java.util.Comparator接口,对对象集合进行多属性组合排序
Commons - BeanUtils 提供了很多功能,其中一个很有用的是对对象集合进行排序,如Collections.sort(peoples, new BeanComparator("a ...
- java mysql插入数据乱码_java向mysql数据库插入数据显示乱码的问题
在做一个java web工程时,有时会碰到在向数据库添加数据库时,结果出现乱码"???"的问题.针对该问题的主要解决办法就是: 一.确保是否添加了字符集过滤器: 在java web ...
- avro和java原生序列化的区别,java原生序列化和Kryo序列化性能比较
简介 最近几年,各种新的高效序列化方式层出不穷,不断刷新序列化性能的上限,最典型的包括: 专门针对Java语言的:Kryo,FST等等 跨语言的:Protostuff,ProtoBuf,Thrift, ...
- java的sql的like_[Java教程]SQL like 模糊查询, in
[Java教程]SQL like 模糊查询, in 0 2018-09-14 11:00:38 [{"互联网":["网络媒体","微博", ...
- java原生怎么发请求,java原生http请求post
java原生http请求post,需要的朋友可以参考下. import java.io.BufferedReader; import java.io.InputStream; import java. ...
- html 插入多媒体对象,如何在word中插入多媒体对象
内容提要:本文介绍如何在word中插入多媒体对象,比如MP3.电影和动画等. word是我们在办公软件中使用频率较高的软件,如何在Word中插入多媒体对象,比如MP3.电影和动画等,让我们制作的文件成 ...
- PHP向数据库循环插入数据,php实现向mysql批量插入数据
现在有这样一个表,我们想往这个表里面插入大量数据该如何实现呢?CREATE TABLE IF NOT EXISTS `user_info` ( `id` int(11) NOT NULL AUTO_I ...
- mysql怎么插入时间_如何在MySQL中插入日期?
在MySQL中插入日期的方法:首先打开脚本文件:然后通过[INSERT INTO tablename (col_name, col_date) VALUE ('DATE: Auto CURDATE() ...
最新文章
- Adobe推出HTML5动画设计工具Edge
- Qt 数据库操作(一)
- 量化交易系统综述——互联网金融之二
- Python笔记——基本数据结构:列表、元组及字典
- Enterprise search Callstack in runtime
- 数据持久化------Archiving(归档,解档)
- DFS--POJ 1190 生日蛋糕
- printf 宏 调试技巧
- 吴恩达作业6:梯度检验
- 语法糖 python_Python___语法糖
- 洞察SaaS:中国SaaS的前世今生
- 自动完成代码,提高工作效率
- grub的说明与配置方法
- 东北大学oj平台python答案_东北大学大数据班R实训第三次作业
- 百度贴吧 “只看某人” 小工具
- 通达信版弘历软件指标_背离王 通达信副图源码 为弘历软件破释公式
- 腾讯云如何申请免费服务器试用
- 二 TreeGrid的绑定
- ABAQUS均匀受力,边界条件对称,但结果云图不对称
- 分销开源微信小程序-真正意义上的开源
热门文章
- 多协议注入工具t50
- 构建伪Update服务器工具isr-evilgrade
- iOS 10应用开发基础教程
- Arduino Yun的硬件——Arduino Yun快速入门教程
- linux usr local权限,OS X权限被拒绝/ usr/local/lib
- java8 collect 类型转换_java8新特性之list转换
- [unreal4入门系列之七] UE4中的Actor类和Pawn类
- 周杰伦300多万NFT被黑客盗走,上链加密艺术就这??
- 《是男人就下100层》真的有隐藏剧情!B站up主数月破解,原作者点赞致谢
- 明晚直播丨上海名师王召强:高考大变脸后,中小学语文怎么学?