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 값과 일치하면 업데이트할 필드 이름이 그 이후의 값을 가져오도록 합니다
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!