>  기사  >  Java  >  springboot는 mybatis를 어떻게 통합하여 데이터베이스 업데이트 일괄 처리를 구현합니까?

springboot는 mybatis를 어떻게 통합하여 데이터베이스 업데이트 일괄 처리를 구현합니까?

WBOY
WBOY앞으로
2023-05-12 20:52:181357검색

    springboot는 mybatis를 통합하여 데이터베이스 업데이트 일괄 처리를 구현합니다

    1. 매퍼 인터페이스에 메소드를 작성합니다

    /**
     * 修改book表中的销量和库存
     * 要使用批处理
     */
    Integer batchBookCountStork(@Param("bookList") List<CartItem> bookList);

    2. 해당 업데이트 SQL 문을 mapper.xml

    <update id="batchBookCountStork" parameterType="java.util.List">
        UPDATE t_book
        <set>
            <foreach collection="bookList" item="book" index="index" open="`sales` = CASE `book_id`" close="END,">
                WHEN #{book.bookId} THEN sales+#{book.count}
            </foreach>
            <foreach collection="bookList" item="book" index="index" open="`stock` = CASE `book_id`" close="END,">
                WHEN #{book.bookId} THEN stock-#{book.count}
            </foreach>
        </set>
        <where>
            <foreach collection="bookList" item="book" index="index" open="`book_id` IN(" close=")" separator=",">
                #{book.bookId}
            </foreach>
        </where>
      </update>

    3에 작성합니다. file 명령문 흐름은 다음과 같습니다.

    update t_book(表名)
    set sales(这个是数据库的销量字段名) = case book_id(这个是数据库的id字段名)
        when bookid(从list集合中取出来的) then sales+(从集合中取出的数据)
        ...(这里可以一直进行拼接)
      end,
        stock(这个是数据库的库存字段名) = CASE book_id(这个是数据库的id字段名)
        when bookid(从list集合中取出来的) then stock-(从集合中取出数据)
        ...(这里可以一直进行拼接)
      end,
    where `book_id`(这个是数据库的id字段名) IN(bookid(从list集合中取出来),bookid(从list集合中取出来)...)

    4. 이 SQL 문의 의미:

    컬렉션을 통해 이동한 id 값에 따라 테이블의 데이터를 업데이트하고, 업데이트할 필드 이름을 설정한 후 필드를 허용합니다. 업데이트할 값은 이 테이블의 기본 키 ID와 일치해야 합니다. 바인딩, 기본 키 ID가 목록에서 가져온 ID 값과 일치하면 업데이트할 필드 이름이 그 이후의 값을 가져오도록 합니다

    Mybatis 일괄 업데이트 데이터베이스 MybatisBatchUtils 배치 삽입업데이트 스프링 부트

    MybatisBatchUtils

        int cnt = mybatisBatchUtils.batchUpdateOrInsert(addList, UiConfigDetailMapper.class,
                                (item, uiConfigDetailMapper) -> uiConfigDetailMapper.insertSelective(item));
    package cn.XXX.dao.serivce.common;
    
    import com.XXX.doctorusercenter.exception.BusinessException;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.ibatis.session.ExecutorType;
    import org.apache.ibatis.session.SqlSession;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.Resource;
    import java.util.List;
    import java.util.function.BiFunction;
    
    
    @Slf4j
    @Component
    public class MybatisBatchUtils {
    
        /**
         * 每次处理1000条
         */
        private static final int BATCH_SIZE = 1000;
    
        @Resource
        private SqlSessionFactory sqlSessionFactory;
    
        /**
         * 批量处理修改或者插入
         *
         * @param data        需要被处理的数据
         * @param mapperClass Mybatis的Mapper类
         * @param function    自定义处理逻辑
         * @return int 影响的总行数
         */
        public <T, U, R> int batchUpdateOrInsert(List<T> data, Class<U> mapperClass, BiFunction<T, U, R> function)  {
            int i = 1;
            SqlSession batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH);
            try {
                U mapper = batchSqlSession.getMapper(mapperClass);
                int size = data.size();
                for (T element : data) {
                  function.apply(element, mapper);
                    if ((i % BATCH_SIZE == 0) || i == size) {
                        batchSqlSession.flushStatements();
                    }
                    i++;
                }
                // 非事务环境下强制commit,事务情况下该commit相当于无效
                batchSqlSession.commit(true);
            } catch (Exception e) {
                batchSqlSession.rollback();
                // throw new BusinessException(e.getMessage());
                log.error("batchUpdateOrInsert", e);
            } finally {
                batchSqlSession.close();
            }
            return i - 1;
        }
    }

    위 내용은 springboot는 mybatis를 어떻게 통합하여 데이터베이스 업데이트 일괄 처리를 구현합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

    성명:
    이 기사는 yisu.com에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제