往mysql的表中批量插入数据,要求是:如果没有重复的记录就是正常插入数据,如果有重复的那就把这条表中原有记录的某个字段值,加上需要插入数据的对应字段值;

我这里判断数据充重不重复是根据记录中orderAccount字段来判断的,一样的表示重复,反之不重复;

这就需要在用orderAccount这个字段在当前表中建立一个联合索引,为了建立这个联合索引我在网上找了很多资料,都是

alter table t_aa add unique index(aa,bb);

我试过很多遍都没用,都说版本语法不对,我目前的版本好像是mysql 5.5啥的,具体也不确定;

然后我找到了一个方法,就是在建立表的语句中加入联合索引成功了:

drop table if exists purchase_stock;

/*==============================================================*/
/* Table: purchase_stock                                        */
/*==============================================================*/
create table purchase_stock
(
   stock_id             int(10) not null auto_increment,
   order_account        varchar(30),
   custom_name          varchar(30),
   carton_name          varchar(20),
   material_science     varchar(30),
   flute_type           varchar(20),
   purchase_spec        varchar(40),
   width_line           varchar(20),
   line_type            int(2),
   out_num              int(10),
   stock_num            int(10),
   price                double(5,2),
   fake                 int(5),
   reservoir            varchar(20),
   pallet_number        int(10),
   n                    varchar(20),
   primary key (stock_id),
UNIQUE KEY (order_account)
);

至此就把字段orderAccount设置为该表的联合索引了;

准备工作做好了就是开始贴代码了

mapper.java片段代码:

    /**
     * 批量添加纸板库存记录
     * @param purStocks
     * @return
     */
    int addPurStockS(List<PurchaseStock> purStocks);

这里就是不需要用@Param来声明需要遍历的purStocks集合(ArrayList类型),其他的一些普通参数需要声明;

mapper.xml片段代码:

<insert id="addPurStockS" parameterType="java.util.List">
    insert into purchase_stock (order_account, custom_name, carton_name, material_science, flute_type,
    purchase_spec, width_line, line_type, out_num, stock_num, price, fake)
    values
    <foreach collection="list" item="item" separator=","  index="index">
      (#{item.orderAccount,jdbcType=VARCHAR}, #{item.customName,jdbcType=VARCHAR},
      #{item.cartonName,jdbcType=VARCHAR}, #{item.materialScience,jdbcType=VARCHAR}, #{item.fluteType,jdbcType=VARCHAR},
      #{item.purchaseSpec,jdbcType=VARCHAR}, #{item.widthLine,jdbcType=VARCHAR}, #{item.lineType,jdbcType=INTEGER},
      #{item.outNum,jdbcType=INTEGER}, #{item.stockNum,jdbcType=INTEGER}, #{item.price,jdbcType=DOUBLE},
      #{item.fake,jdbcType=INTEGER})
    </foreach>
    on duplicate key update stock_num=stock_num+values(stock_num)
  </insert>

其中最后一句on duplicate key update stock_num=stock_num+values(stock_num)中的values(stock_num)就是需要插入的值的引用,不需要遍历这个值就能通过这种方式拿到;

 

Logo

更多推荐