欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

MySql使用case when then end where 关键字执行批量更新(batchUpdate)时的避坑指南

程序员文章站 2024-01-14 21:59:28
...

前一段做一个批量更新的需求,数据的来源是一个Excel文件,列有值的话,就更新,没值的话,就忽略。

首先可以使用mybatis-plus的com.baomidou.mybatisplus.extension.service包下的IService接口里面的批量方法

但它的实现原理是伪批量,所以我参照系统中之前的批量更新写法,写了一个Mysql自带的批量更新,Map.xml中的代码如下:

<!--  批量修改product_online表(线上商品池)Excel中某列数据有值,所有行的该列数据都必须得有值,否则会被设置为该类型的默认值 -->
    <update id="batchUpdateProductOnline" parameterType="java.util.List">
        UPDATE product_online
        <trim prefix="set" suffixOverrides=",">
            <trim prefix="product_name = case" suffix="end,"> <!-- 线上商品名称 -->
                <foreach collection="list" item="item">
                    <if test='item.productName != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.productName,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="product_specific = case" suffix="end,"> <!-- 规格 -->
                <foreach collection="list" item="item">
                    <if test='item.productSpecific != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.productSpecific,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="product_unit = case" suffix="end,"> <!-- 单位 -->
                <foreach collection="list" item="item">
                    <if test='item.productUnit != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.productUnit,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="weight = case" suffix="end,"> <!-- 毛重 -->
                <foreach collection="list" item="item">
                    <if test='item.weight != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.weight,jdbcType=DECIMAL}
                    </if>
                </foreach>
            </trim>
            <trim prefix="origin_place = case" suffix="end,"> <!-- 产地 -->
                <foreach collection="list" item="item">
                    <if test='item.originPlace != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.originPlace,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="shelf_life = case" suffix="end,"> <!-- 保质期 -->
                <foreach collection="list" item="item">
                    <if test='item.shelfLife != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.shelfLife,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="product_brief = case" suffix="end,"> <!-- 商品简述 -->
                <foreach collection="list" item="item">
                    <if test='item.productBrief != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.productBrief,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="storage_type = case" suffix="end,"> <!-- 储藏方式 -->
                <foreach collection="list" item="item">
                    <if test='item.storageType != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.storageType,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="is_return = case" suffix="end,"> <!-- 是否支持退换货 -->
                <foreach collection="list" item="item">
                    <if test='item.isReturn != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.isReturn,jdbcType=TINYINT}
                    </if>
                </foreach>
            </trim>
            <trim prefix="sub_title = case" suffix="end,"> <!-- 商品副标题 -->
                <foreach collection="list" item="item">
                    <if test='item.subTitle != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.subTitle,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="keywords = case" suffix="end,"> <!-- 商品关键词 -->
                <foreach collection="list" item="item">
                    <if test='item.keywords != null'>
                        when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.keywords,jdbcType=VARCHAR}
                    </if>
                </foreach>
            </trim>
            <trim prefix="updated_time = case" suffix="end,"> <!-- 更新时间 -->
                <foreach collection="list" item="item">
                    when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.updatedTime}
                </foreach>
            </trim>
            <trim prefix="updated_by = case" suffix="end,"> <!-- 操作人 -->
                <foreach collection="list" item="item">
                    when product_code = #{item.productCode,jdbcType=VARCHAR} then #{item.updatedBy,jdbcType=VARCHAR}
                </foreach>
            </trim>
        </trim>
        <where>  <!-- 使用 case when then end语句 批量更新时,where条件是必须的,不然默认会更新所有的,把原值覆盖成默认值!! -->
            <foreach collection="list" separator="or" item="item">
                product_code = #{item.productCode,jdbcType=VARCHAR}
            </foreach>
        </where>
    </update>

但这种方式有两个大坑!!

1号坑:使用 case when then end语句 批量更新时,where条件是必须的,不然默认会更新所有的,把原值覆盖成数据库类型的默认值!!

2号坑:我的数据来源是一个Excel文件,比如说Excel文件*100行数据,其中只要有一行数据 在第3列有值,那么批量更新的时候,这100行数据的第3列都必须得有值,不然的话,数据库会把其他第3列的值覆盖成数据库类型的默认值!!

鉴于这两个坑的存在,我在批量更新前,就必须得先去数据库中查,得到查询结果的List,然后对每个列进行非空检验,如果为空,就把数据库中的值赋给该列,这样就可以避免 误操作篡改数据了。

这个功能上线后,我心里还是很忐忑的,必经update操作一定要谨慎,但最近观察一段时间的使用后,生产上没出现数据问题,哈哈