zoukankan      html  css  js  c++  java
  • 加入tkmybatis,进行批量插入

    首先模仿接口insertList接口:

    /**
     * Created by kun.zuo
     * Created by time 2020/12/29
     * Vsrsion 1.0
     */
    public class SpecialBatchProvider  extends MapperTemplate {
    
        public SpecialBatchProvider(Class mapperClass, MapperHelper mapperHelper) {
            super(mapperClass, mapperHelper);
        }
    
        public String batchInseetList(MappedStatement ms) {
            Class entityClass = getEntityClass(ms);
            //开始拼sql
            StringBuilder sql = new StringBuilder();
            sql.append(SqlHelper.insertIntoTable(entityClass, tableName(entityClass)));
            sql.append(SqlHelper.insertColumns(entityClass, false, false, false));
            sql.append(" VALUES ");
            sql.append("<foreach collection="list" item="record" separator="," >");
            sql.append("<trim prefix="(" suffix=")" suffixOverrides=",">");
            //获取全部列
            Set<EntityColumn> columnList = EntityHelper.getColumns(entityClass);
            //当某个列有主键策略时,不需要考虑他的属性是否为空,因为如果为空,一定会根据主键策略给他生成一个值
            for (EntityColumn column : columnList) {
                if (column.isInsertable()) {
                    //出现类型com.microsoft.sqlserver.jdbc.SQLServerException: 操作数类型冲突: varbinary
                    if(column.getJavaType() == Double.class){
                        String record = column.getColumnHolder("record");
                        record = record.substring(0,record.length()-1)+",jdbcType=DECIMAL"+"}";
                        sql.append(record+ ",");
                    }else {
                        sql.append(column.getColumnHolder("record") + ",");
                    }
                }
            }
            sql.append("</trim>");
            sql.append("</foreach>");
            return sql.toString();
        }
    }
    /**
     * Created by kun.zuo
     * Created by time 2020/12/29
     * Vsrsion 1.0
     */
    @RegisterMapper
    public interface SpecialBatchMapper<T> {
    
        /**
         * 批量插入数据库,所有字段都插入,包括主键
         *
         * @return
         */
        @Options(useGeneratedKeys = true, keyProperty = "id")
        @InsertProvider(type = SpecialBatchProvider.class, method = "batchInseetList")
        int batchInseetList(List<T> recordList);
    }
  • 相关阅读:
    mongo批量删除js示例
    Mongo压测介绍
    线性代数学习笔记(1)--二维向量点积本质(仅供自己理解)
    墨菲定律的正确解读
    spring cloud 2020.0.1踩坑记录-bootstrap不生效等
    记一次网络质量原因导致接口调用超时的调查过程
    .NET Debugging Demos Lab 2: Crash
    .NET Debugging Demos Lab 3: Memory
    Hang caused by GC
    .NET Debugging Demos Lab 4: High CPU hang
  • 原文地址:https://www.cnblogs.com/zuokun/p/14240717.html
Copyright © 2011-2022 走看看