网站开发技术联系方式,沈阳seo博客,龙宜推广公司是正规吗,举报网站建设情况背景
因为Mybatis-Plus的saveBatch()方法的批量插入其实也是循环插入#xff0c;而不是真正的一个SqlSession完成的批插#xff0c;效率很低。所以我们在写批量插入的时候是自己实现了一个工具类去生成批量插入的sql再去执行#xff0c;但是会遇到有些文本里有单引号导致插…背景
因为Mybatis-Plus的saveBatch()方法的批量插入其实也是循环插入而不是真正的一个SqlSession完成的批插效率很低。所以我们在写批量插入的时候是自己实现了一个工具类去生成批量插入的sql再去执行但是会遇到有些文本里有单引号导致插入失败的情况因此需要优化这个工具类
优化工具类
先贴一下优化后的工具类的代码
/*** 构建批量插入语句 insert 语句** param clazz 实体类class* param beanList 要插入的带值的对象集合* param ignoreFields 需要忽略的属性名集合*/public static T String getInsertString(ClassT clazz, CollectionT beanList, String... ignoreFields) {StringBuilder insertSql new StringBuilder();String className clazz.getSimpleName();insertSql.append(insert into ).append(StrUtil.toUnderlineCase(className)).append(();Field[] allFields FieldUtils.getAllFields(clazz);// 构建字段StringBuilder columnSql new StringBuilder();for (Field field : allFields) {// 构建非static的属性String name field.getName();if (!isIgnore(ignoreFields, name)) {if (!Modifier.isStatic(field.getModifiers())) {columnSql.append(StrUtil.toUnderlineCase(name)).append(,);}}}insertSql.append(StrUtil.removeSuffix(columnSql.toString(), ,)).append()).append( values );// 循环构建参数for (T t : beanList) {StringBuilder paramsSql new StringBuilder();paramsSql.append(();// 根据字段构建参数for (Field field : allFields) {// 构建非static的属性String name field.getName();if (!isIgnore(ignoreFields, name)) {if (!Modifier.isStatic(field.getModifiers())) {Object fieldValue ReflectUtil.getFieldValue(t, field.getName());/* 根据格式转换数据 */if (fieldValue instanceof String) {String fieldValueStr (String) ReflectUtil.getFieldValue(t, name);//防止值里面有导致插入数据失败if (StringUtils.isNotBlank(fieldValueStr)) {fieldValueStr fieldValueStr.replaceAll(, );paramsSql.append().append(fieldValueStr).append(,);} else {paramsSql.append(null,);}} else if (fieldValue instanceof Enum) {paramsSql.append().append(ReflectUtil.getFieldValue(t, name)).append(,);} else if (fieldValue instanceof Date) {Date dateValue (Date) ReflectUtil.getFieldValue(t, name);paramsSql.append().append(DateUtil.format(dateValue, DatePattern.NORM_DATETIME_PATTERN)).append(,);} else if (fieldValue instanceof LocalDateTime) {LocalDateTime dateValue (LocalDateTime) ReflectUtil.getFieldValue(t, name);paramsSql.append().append(DateUtil.format(dateValue, DatePattern.NORM_DATETIME_PATTERN)).append(,);} else {paramsSql.append(ReflectUtil.getFieldValue(t, name)).append(,);}}}}insertSql.append(StrUtil.removeSuffix(paramsSql.toString(), ,)).append()).append(,);}return StrUtil.removeSuffix(insertSql.toString(), ,);}
处理方案
对于’这种特殊符号可以直接将一个单引号修改为两个单引号在执行sql语句的时候两个单引号会被像转移字符一样处理成一个单引号入库这样即不会报错也可以保留文本的原始内容
