MyBatisPagingItemReader.java

---------------------------------

 

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

/**
  * 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.notNull;
  import static org.springframework.util.ClassUtils.getShortName;
   
  import java.util.HashMap;
  import java.util.Map;
  import java.util.concurrent.CopyOnWriteArrayList;
   
  import org.apache.ibatis.session.ExecutorType;
  import org.apache.ibatis.session.SqlSession;
  import org.apache.ibatis.session.SqlSessionFactory;
  import org.mybatis.spring.SqlSessionTemplate;
  import org.springframework.batch.item.database.AbstractPagingItemReader;
   
  /**
  * {@code org.springframework.batch.item.ItemReader} for reading database records using MyBatis in a paging fashion.
  * <p>
  * Provided to facilitate the migration from Spring-Batch iBATIS 2 page item readers to MyBatis 3.
  *
  * @author Eduardo Macarron
  *
  * @since 1.1.0
  */
  public class MyBatisPagingItemReader<T> extends AbstractPagingItemReader<T> {
   
  private String queryId;
   
  private SqlSessionFactory sqlSessionFactory;
   
  private SqlSessionTemplate sqlSessionTemplate;
   
  private Map<String, Object> parameterValues;
   
  public MyBatisPagingItemReader() {
  setName(getShortName(MyBatisPagingItemReader.class));
  }
   
  /**
  * Public setter for {@link SqlSessionFactory} for injection purposes.
  *
  * @param sqlSessionFactory
  * a factory object for the {@link SqlSession}.
  */
  public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
  this.sqlSessionFactory = sqlSessionFactory;
  }
   
  /**
  * Public setter for the statement id identifying the statement in the SqlMap configuration file.
  *
  * @param queryId
  * the id for the statement
  */
  public void setQueryId(String queryId) {
  this.queryId = queryId;
  }
   
  /**
  * The parameter values to be used for the query execution.
  *
  * @param parameterValues
  * the values keyed by the parameter named used in the query string.
  */
  public void setParameterValues(Map<String, Object> parameterValues) {
  this.parameterValues = parameterValues;
  }
   
  /**
  * Check mandatory properties.
  *
  * @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
  */
  @Override
  public void afterPropertiesSet() throws Exception {
  super.afterPropertiesSet();
  notNull(sqlSessionFactory, "A SqlSessionFactory is required.");
  notNull(queryId, "A queryId is required.");
  }
   
  @Override
  protected void doReadPage() {
  if (sqlSessionTemplate == null) {
  sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory, ExecutorType.BATCH);
  }
  Map<String, Object> parameters = new HashMap<>();
  if (parameterValues != null) {
  parameters.putAll(parameterValues);
  }
  parameters.put("_page", getPage());
  parameters.put("_pagesize", getPageSize());
  parameters.put("_skiprows", getPage() * getPageSize());
  if (results == null) {
  results = new CopyOnWriteArrayList<>();
  } else {
  results.clear();
  }
  results.addAll(sqlSessionTemplate.selectList(queryId, parameters));
  }
   
  @Override
  protected void doJumpToPage(int itemIndex) {
  // Not Implemented
  }
   
  }

 

 

본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
번호 제목 글쓴이 날짜 조회 수
404 자바 인코딩 관련 문제 종합 정리 file 졸리운_곰 2021.01.29 40
403 JAVA) 예외처리(throw , throws) file 졸리운_곰 2021.01.24 21
402 [Java 디자인패턴] [JAVA 디자인 패턴] static을 응용한 싱글톤 패턴(Singleton Pattern) 구현 졸리운_곰 2021.01.22 20
401 예외처리 (throwable, exception, error, throws) file 졸리운_곰 2021.01.21 39
400 Eclipse -`항상 실행 백그라운드에서 실행 '창을 다시 표시하는 방법 file 졸리운_곰 2021.01.14 434
399 Prometheus + Grafana로 Java 애플리케이션 모니터링하기 file 졸리운_곰 2020.12.17 79
398 [스프링 배치] java Spring Batch 졸리운_곰 2020.12.16 75
397 [java] [MyBatis] #{} 와 ${} 개념과 차이점 졸리운_곰 2020.12.11 47
396 [java, mybatis] MyBatis에서 샾(#{})과 달러(${})의 차이는 무엇일까? 졸리운_곰 2020.12.11 66
395 [Java] 자바 extends, implements 차이 file 졸리운_곰 2020.12.10 48
394 [JAVA] String to int, int to String 형변환 컴퓨터/코딩 졸리운_곰 2020.12.10 35
393 [Java] 현재날짜 구하기 졸리운_곰 2020.12.10 15
392 [Java] [Java] Jackson으로 Json <-> Object 변환(Transformation)하기 졸리운_곰 2020.12.09 18
391 [java] jackson custom serializer, deserializer 만들기 file 졸리운_곰 2020.12.09 60
390 [Java] Deserialize MongoDB date fields to Java POJO Using Jackson 졸리운_곰 2020.12.09 132
389 [Java] Jackson ObjectMapper upper/lower case issues 졸리운_곰 2020.12.09 471
388 Java의 날짜와 시간 API file 졸리운_곰 2020.12.03 41
387 Java로 현재 날짜 / 시간을 얻는 방법 file 졸리운_곰 2020.11.30 451
386 [java, jackson] [jackson] json serialize 만 ignore 하고 싶다면? 졸리운_곰 2020.11.07 16
385 Java MongoDB : Query document 졸리운_곰 2020.11.07 30
대표 김성준 주소 : 경기 용인 분당수지 U타워 등록번호 : 142-07-27414
통신판매업 신고 : 제2012-용인수지-0185호 출판업 신고 : 수지구청 제 123호 개인정보보호최고책임자 : 김성준 sjkim70@stechstar.com
대표전화 : 010-4589-2193 [fax] 02-6280-1294 COPYRIGHT(C) stechstar.com ALL RIGHTS RESERVED