public class MyBatisBatchItemWriter<T> implements ItemWriter<T>, InitializingBean {

 

/**
  * Copyright 2010-2020 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  * http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
  package org.mybatis.spring.batch;
   
  import static org.springframework.util.Assert.isTrue;
  import static org.springframework.util.Assert.notNull;
   
  import java.util.List;
   
  import org.apache.ibatis.executor.BatchResult;
  import org.apache.ibatis.session.ExecutorType;
  import org.apache.ibatis.session.SqlSession;
  import org.apache.ibatis.session.SqlSessionFactory;
  import org.mybatis.logging.Logger;
  import org.mybatis.logging.LoggerFactory;
  import org.mybatis.spring.SqlSessionTemplate;
  import org.springframework.batch.item.ItemWriter;
  import org.springframework.beans.factory.InitializingBean;
  import org.springframework.core.convert.converter.Converter;
  import org.springframework.dao.EmptyResultDataAccessException;
  import org.springframework.dao.InvalidDataAccessResourceUsageException;
   
  /**
  * {@code ItemWriter} that uses the batching features from {@code SqlSessionTemplate} to execute a batch of statements
  * for all items provided.
  * <p>
  * Provided to facilitate the migration from Spring-Batch iBATIS 2 writers to MyBatis 3.
  * <p>
  * The user must provide a MyBatis statement id that points to the SQL statement defined in the MyBatis.
  * <p>
  * It is expected that {@link #write(List)} is called inside a transaction. If it is not each statement call will be
  * autocommitted and flushStatements will return no results.
  * <p>
  * The writer is thread safe after its properties are set (normal singleton behavior), so it can be used to write in
  * multiple concurrent transactions.
  *
  * @author Eduardo Macarron
  *
  * @since 1.1.0
  */
  public class MyBatisBatchItemWriter<T> implements ItemWriter<T>, InitializingBean {
   
  private static final Logger LOGGER = LoggerFactory.getLogger(MyBatisBatchItemWriter.class);
   
  private SqlSessionTemplate sqlSessionTemplate;
   
  private String statementId;
   
  private boolean assertUpdates = true;
   
  private Converter<T, ?> itemToParameterConverter = new PassThroughConverter<>();
   
  /**
  * Public setter for the flag that determines whether an assertion is made that number of BatchResult objects returned
  * is one and all items cause at least one row to be updated.
  *
  * @param assertUpdates
  * the flag to set. Defaults to true;
  */
  public void setAssertUpdates(boolean assertUpdates) {
  this.assertUpdates = assertUpdates;
  }
   
  /**
  * Public setter for {@link SqlSessionFactory} for injection purposes.
  *
  * @param sqlSessionFactory
  * a factory object for the {@link SqlSession}.
  */
  public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
  if (sqlSessionTemplate == null) {
  this.sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory, ExecutorType.BATCH);
  }
  }
   
  /**
  * Public setter for the {@link SqlSessionTemplate}.
  *
  * @param sqlSessionTemplate
  * a template object for use the {@link SqlSession} on the Spring managed transaction
  */
  public void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {
  this.sqlSessionTemplate = sqlSessionTemplate;
  }
   
  /**
  * Public setter for the statement id identifying the statement in the SqlMap configuration file.
  *
  * @param statementId
  * the id for the statement
  */
  public void setStatementId(String statementId) {
  this.statementId = statementId;
  }
   
  /**
  * Public setter for a converter that converting item to parameter object.
  * <p>
  * By default implementation, an item does not convert.
  *
  * @param itemToParameterConverter
  * a converter that converting item to parameter object
  * @since 2.0.0
  */
  public void setItemToParameterConverter(Converter<T, ?> itemToParameterConverter) {
  this.itemToParameterConverter = itemToParameterConverter;
  }
   
  /**
  * Check mandatory properties - there must be an SqlSession and a statementId.
  */
  @Override
  public void afterPropertiesSet() {
  notNull(sqlSessionTemplate, "A SqlSessionFactory or a SqlSessionTemplate is required.");
  isTrue(ExecutorType.BATCH == sqlSessionTemplate.getExecutorType(),
  "SqlSessionTemplate's executor type must be BATCH");
  notNull(statementId, "A statementId is required.");
  notNull(itemToParameterConverter, "A itemToParameterConverter is required.");
  }
   
  /**
  * {@inheritDoc}
  */
  @Override
  public void write(final List<? extends T> items) {
   
  if (!items.isEmpty()) {
  LOGGER.debug(() -> "Executing batch with " + items.size() + " items.");
   
  for (T item : items) {
  sqlSessionTemplate.update(statementId, itemToParameterConverter.convert(item));
  }
   
  List<BatchResult> results = sqlSessionTemplate.flushStatements();
   
  if (assertUpdates) {
  if (results.size() != 1) {
  throw new InvalidDataAccessResourceUsageException("Batch execution returned invalid results. "
  + "Expected 1 but number of BatchResult objects returned was " + results.size());
  }
   
  int[] updateCounts = results.get(0).getUpdateCounts();
   
  for (int i = 0; i < updateCounts.length; i++) {
  int value = updateCounts[i];
  if (value == 0) {
  throw new EmptyResultDataAccessException(
  "Item " + i + " of " + updateCounts.length + " did not update any rows: [" + items.get(i) + "]", 1);
  }
  }
  }
  }
  }
   
  private static class PassThroughConverter<T> implements Converter<T, T> {
   
  @Override
  public T convert(T source) {
  return source;
  }
   
  }
   
  }

 

경축! 아무것도 안하여 에스천사게임즈가 새로운 모습으로 재오픈 하였습니다.
어린이용이며, 설치가 필요없는 브라우저 게임입니다.
https://s1004games.com

 

 

본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
번호 제목 글쓴이 날짜 조회 수
57 [java, spring] Spring에서 request와 response를 JSON format 으로 한번에 로깅하기 file 졸리운_곰 2021.06.18 178
56 [Spring Boot] 2) Springboot OncePerRequestFilter 와 GenericFilterBean의 차이 file 졸리운_곰 2021.06.18 21
55 [Spring boot] [Spring boot] Spring Boot servlet filter 사용하기 졸리운_곰 2021.06.18 16
54 [SpringBoot] Filter(필터) OncePerRequestFilter간단히 사용하기 file 졸리운_곰 2021.06.18 65
53 [Spring boot] Spring boot 에서 Filter 사용하기 졸리운_곰 2021.06.18 18
52 [Spring Boot] 스프링 부트에 필터를 '조심해서' 사용하는 두 가지 방법 졸리운_곰 2021.06.18 140
51 [스프링 배치] java Spring Batch 졸리운_곰 2020.12.16 75
50 MyBatisPagingItemReader.java 졸리운_곰 2020.11.07 82
49 [JPA] 스프링 데이터 JPA 소개 file 졸리운_곰 2020.11.07 23
48 Spring Batch Example 3 - 청크 지향 프로세싱 file 졸리운_곰 2020.10.24 51
47 Spring Batch Example 2 - 간단한 Job만들기 file 졸리운_곰 2020.10.24 15
46 Spring Batch Example 1 - Spring Batch란? file 졸리운_곰 2020.10.24 54
45 [spring batch] Spring batch Job 설정과 실행하기 file 졸리운_곰 2020.10.24 24
44 public class MyBatisPagingItemReader<T> extends AbstractPagingItemReader<T> { 졸리운_곰 2020.10.23 97
» public class MyBatisBatchItemWriter<T> implements ItemWriter<T>, InitializingBean { 졸리운_곰 2020.10.23 119
42 MyBatisPagingItemReader, MyBatisPagingItemWriter 졸리운_곰 2020.10.23 208
41 [spring batch] 처음 해보는 Spring batch, Tasklet 작성하기 file 졸리운_곰 2020.10.18 15
40 Spring Boot - Properties 사용법 정리 졸리운_곰 2020.10.15 94
39 spring 설정 xml과 소스코드에서 properties 사용하기 졸리운_곰 2020.10.15 14
38 Spring Batch 간단 정리 Sprong Batch 기초를 알아보자 file 졸리운_곰 2020.10.13 47
대표 김성준 주소 : 경기 용인 분당수지 U타워 등록번호 : 142-07-27414
통신판매업 신고 : 제2012-용인수지-0185호 출판업 신고 : 수지구청 제 123호 개인정보보호최고책임자 : 김성준 sjkim70@stechstar.com
대표전화 : 010-4589-2193 [fax] 02-6280-1294 COPYRIGHT(C) stechstar.com ALL RIGHTS RESERVED