ItemReaderについて説明します。
csvファイルはSpring Batchアプリケーションを実行するサーバに配置してください。
例1はcsvファイルの内容を直接渡す場合の例です。例2はcsvファイルの内容を指定して読み込む場合の例です。ItemReaderの設定とは別にPOJOクラスとFieldSetMapperクラスが必要です。指定した形式とは異なるデータが含まれていた場合、エラーを返します。例3は複数のCSVファイルを使用する場合の例です。
例
例1 csvファイルの内容を直接後プロセスに渡す場合
Job定義ファイル(job.xml):
<!-- ItemReader定義 --> <bean id="flatFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader"> <property name="resource" value="file:/csv/input.csv" /> <!-- lineMapperを行わないための設定 --> <property name="lineMapper"> <bean class="org.springframework.batch.item.file.mapping.PassThroughLineMapper" /> </property> </bean> |
例2 csvファイルの内容を指定して読み込む場合
POJOクラス(UserModel.java):
public class UserModel {private int id; private String name; public int getId() {return id; } public void setId(int id) {this.id = id; } public String getName() {return name; } public void setName(String name) {this.name = name; } } |
FieldSetMapperクラス(UserFieldSetMapper.java):
… public class UserFieldSetMapper implements FieldSetMapper<UserModel> { public UserModel mapFieldSet(FieldSet fieldSet) {UserModel userModel = new UserModel(); userModel.setId(fieldSet.readInt("id")); userModel.setName(fieldSet.readString("name"));return userModel; } } |
Job定義ファイル(job.xml):
<!-- ItemReader定義 --> <bean id="flatFileItemReader " class="org.springframework.batch.item.file.FlatFileItemReader"> <property name="resource" value="file:/csv/input.csv" /> <!-- lineMapperの設定 --> <property name="lineMapper"> <bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper"> <!-- 想定するトークンを指定 --> <property name="lineTokenizer"> <bean class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer"> <property name="names" value="id, name" /> </bean> </property> <!-- FieldSetMapperの指定 --> <property name="fieldSetMapper"> <bean class="example.UserFieldSetMapper" /> </property> </bean> </property> </bean> |
例3 複数のCSVファイルを使用する場合
Job定義ファイル(job.xml):
<!-- MultiResourceItemReader定義 --> <bean id="multiResourceItemReader" class="org.springframework.batch.item.file.MultiResourceItemReader"> <!-- 正規表現を使用して複数ファイルを取得 --> <property name="resources" value="file:/csv/input*.csv" /> <!-- デリゲートするFileItemReaderの指定 --> <property name="delegate" ref="flatFileItemReader" /> </bean> <!-- ItemReader定義 --> <bean id="flatFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader"> <!-- MultiResourceItemReaderにてresource定義を行うため、resource定義は不要 --> <property name="lineMapper"> <bean class="org.springframework.batch.item.file.mapping.PassThroughLineMapper" /> </property> </bean> |
JDBCを使用したデータベース入力についての設定を以下に示します。
例
Job定義ファイル(job.xml):
<!-- ItemReader定義 --> <bean id="jdbcPagingItemReader" class="org.springframework.batch.item.database.JdbcPagingItemReader"> <!-- 入力データが格納されているデータソースを設定 --> <property name="dataSource" ref="jdbcDataSource" /> <!-- 各種DB用のクエリ生成機能設定 --> <property name="queryProvider"> <bean class="org.springframework.batch.item.database.support.OraclePagingQueryProvider"> <property name="selectClause" value="select *" /> <property name="fromClause" value=" USERTABLE" /> <property name="sortKeys"> <map> <entry key="id" value="ASCENDING" /> </map> </property> </bean> </property> <!-- Mapper用クラスを設定 --> <property name="rowMapper"> <bean class="org.springframework.jdbc.core.BeanPropertyRowMapper"> <property name="mappedClass" value="example.model.UserModel" /> </bean> </property> </bean> |
ポイント
Hibernateの設定方法については、“オープンJavaフレームワークユーザーズガイド Java EE 7編”の“3.3.3.4 O/Rマッピング連携(Hibernate)”を参照してください。
Hibernateを使用したデータベース入力についての設定を示します。
例
Job定義ファイル(job.xml):
<!-- ItemReader定義 --> <bean id=" hibernatePagingItemReader" class="org.springframework.batch.item.database.HibernatePagingItemReader"> <!-- 入力データが格納されているデータソースを設定 --> <property name="dataSource" ref="hibernateDataSource" /> <!-- セッションファクトリを設定 --> <property name="sessionFactory" ref="sessionFactory" /> <!-- Hibernate Query Language(HQL)のfrom句にてエンティティクラスを指定 --> <property name="queryString" value="from example.model.UserModel" /> </bean> |
ポイント
JPAの設定方法については、“オープンJavaフレームワークユーザーズガイド Java EE 7編”の“3.3.3.5 O/Rマッピング連携(JPA)”を参照してください。
JPAを使用したデータベース入力についての設定を示します。
例
Job定義ファイル(job.xml):
<!-- ItemReader定義 --> <bean id="jpaPagingItemReader" class="org.springframework.batch.item.database.JpaPagingItemReader"> <!-- 入力データが格納されているデータソースを設定 --> <property name="dataSource" ref="jpaDataSource" /> <!-- エンティティマネージャファクトリを指定 --> <property name="entityManagerFactory" ref="entityManagerFactory" /> <!-- Java Persistence Query Language(JPQL)のfrom句にてエンティティクラスを指定 --> <property name="queryString" value="from example.model.UserModel" /> </bean> |
ポイント
MyBatisの設定方法については、“オープンJavaフレームワークユーザーズガイド Java EE 7編”の“3.3.3.6 O/Rマッピング連携(MyBatis)”を参照してください。
MyBatisを使用したデータベース入力についての設定を示します。
例
Job定義ファイル(job.xml):
<!-- Mapperインターフェースを指定 --> <mybatis-spring:scan base-package="example.mapper" /> <!-- ItemReader定義 --> <bean id="mybatisPagingItemReader" class="org.mybatis.spring.batch.MyBatisPagingItemReader"> <!-- 入力データが格納されているデータソースを設定 --> <property name="dataSource" ref="mybatisDataSource" /> <!-- セッションファクトリを設定 --> <property name="sqlSessionFactory" ref="sqlSessionFactory" /> <!-- 入力用メソッドを指定 --> <property name="queryId" value="example.mapper.SQLMapper.getUser" /> </bean> |
MyBatisPagingItemReaderを使用する場合は、読み込んだページ番号をわたす必要があります。読み込んだページ番号をわたすSQL文はデータベースによって異なります。以下に例を示します。
例
Symfoware Server (Postgres)の場合(SQLMapper.java):
… // Mapperインターフェース public interface SQLMapper {// Symfoware Server (Postgres)用のSQL文 @Select("SELECT id, name FROM TESTTABLE ORDER BY id ASC LIMIT #{_pagesize} OFFSET #{_skiprows}")UserModel getUser(); } |
Oracleの場合(SQLMapper.java):
… // Mapperインターフェース public interface SQLMapper {// Oracle用のSQL文 @Select("select * from (select * from (SELECT id, name, ROWNUM ROWNUM_ FROM TESTTABLE T ORDER BY id) WHERE ROWNUM_ > ( #{_page} * #{_pagesize} )) WHERE ROWNUM <= #{_pagesize}")UserModel getUser(); } |
