Java 、mybatis、Oracle 批量新增关键代码

Java 、mybatis、Oracle 批量新增关键代码

JAVA:

Map<String, Object> param = new HashMap<String, Object>();
param.put("dbBantchList", list); // dbBantchList与xml里dbBantchList一致
addSuccNu = userInfoDao.insertDbBantch(param);

 mybatis mapper.xml配置sql,批量插入语句：

SEQ_NO  流水id 设置为自增。

经过项目检测，40万条数据批量插入，两个线程均分操作，且循环每次只批量新增2000条左右，感觉最佳。

<!-- 批量插入数据 -->
    <insert id="insertDbBantch" parameterType="java.util.Map">
        insert into TB_USER_INFO(
					SEQ_NO,
					IPP_CUST_ID,
					IPP_ZHJHAO,
					IPP_ZHJNZL,
					IPP_PHONE,
					IPP_USER_NAME,
					USER_TYPE,
					IPP_ROW_NUM,
					CREATE_DATE,
					CREATE_TIME,
					DESCRIBE,
					BEI_YONG1,
					BEI_YONG2
			) 
	select TO_CHAR(sysdate,'YYYYMMDDhh24miss')||LPAD(TO_CHAR(SEQ_TB_USER_INFO.NEXTVAL), 9, '0') SEQ_NO, t.* from(
        <foreach collection="dbBantchList" item="item" index="index" separator="UNION ALL">
            (
							select 
								#{item.IPP_CUST_ID,jdbcType=VARCHAR} IPP_CUST_ID,
								#{item.IPP_ZHJHAO,jdbcType=VARCHAR} IPP_ZHJHAO,
								#{item.IPP_ZHJNZL,jdbcType=VARCHAR} IPP_ZHJNZL,
								#{item.IPP_PHONE,jdbcType=VARCHAR} IPP_PHONE,
								#{item.IPP_USER_NAME,jdbcType=VARCHAR} IPP_USER_NAME,
								#{item.USER_TYPE,jdbcType=VARCHAR} USER_TYPE,
								#{item.IPP_ROW_NUM,jdbcType=VARCHAR} IPP_ROW_NUM,
								TO_CHAR(sysdate,'YYYY-MM-DD') CREATE_DATE,
								TO_CHAR(sysdate,'hh24:mi:ss') CREATE_TIME,
								#{item.DESCRIBE,jdbcType=VARCHAR} DESCRIBE,
								#{item.BEI_YONG1,jdbcType=VARCHAR} BEI_YONG1,
								#{item.BEI_YONG2,jdbcType=VARCHAR} BEI_YONG2
							from dual
            )
        </foreach>
        ) t
    </insert>

SQL：

CREATE TABLE TB_USER_INFO (
  SEQ_NO VARCHAR2(23 BYTE) NOT NULL ,
  IPP_CUST_ID VARCHAR2(20 BYTE) ,
  IPP_ZHJHAO VARCHAR2(20 BYTE) ,
  IPP_ZHJNZL CHAR(2 BYTE) ,
  IPP_PHONE VARCHAR2(20 BYTE) ,
  IPP_USER_NAME VARCHAR2(150 BYTE) ,
  USER_TYPE CHAR(1 BYTE) ,
  IPP_ROW_NUM VARCHAR2(10 BYTE) ,
  CREATE_DATE CHAR(10 BYTE) NOT NULL ,
  CREATE_TIME CHAR(8 BYTE) NOT NULL ,
  DESCRIBE VARCHAR2(100 BYTE) ,
  BEI_YONG1 VARCHAR2(64 BYTE) ,
  BEI_YONG2 VARCHAR2(64 BYTE) 
);

-- ----------------------------
-- Primary Key structure for table "MB_IPP_SJYH_DIFFUNAME"
-- ----------------------------
  ALTER TABLE TB_USER_INFO ADD PRIMARY KEY ("SEQ_NO");
 
 
-- ----------------------------
-- create sequence  CYCLE 1~99999999 
-- ----------------------------
-- DROP SEQUENCE TB_USER_INFO ;
CREATE SEQUENCE SEQ_TB_USER_INFO MINVALUE 1 MAXVALUE 99999999 INCREMENT BY 1 START WITH 1 CYCLE NOCACHE;