[Java知识库]Spring Batch之读数据库——JdbcCursorItemReader（三十二）

一、JdbcCursorItemReader结构及关键属性

????????JdbcCursorItemReader将数据库记录转换为Java对象时主要有两步工作：首先根据PreparedStatement从数据库中获取结果集ResultSet；然后使用RowMapper将结果集ResultSet转换为Java对象。

二、关键接口、类和关键属性

1.JdbcCursorItemReader关键接口、类

2.JdbcCursorItemReader关键属性

三、配置JdbcCursorItemReader

????????使用JdbcCursorItemReader至少需要配置dataSource、sql、rowMapper三个属性：dataSource指定访问的数据源，sql用于指定查询的SQL语句，rowMapper用于将结果集ResultSet转换为Java业务。

<!-- 读取db -->
<bean id="jdbcItemReader" scope="step" class="org.springframework.batch.item.database.JdbcCursorItemReader" >
    <!--指定访问的数据源-->
    <property name="dataSource" ref="dataSource"/>
    <!--指定查询的SQL语句-->
    <property name="sql" value="select ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS from t_credit where id between 1 and 5 "/>
    <!--用于将指定结果集ResultSet转换为Java业务对象，即CreditBill-->
    <property name="rowMapper">
        <bean class="org.springframework.jdbc.core.BeanPropertyRowMapper">
            <property name="mappedClass" value="com.xj.demo26.CreditBill"/>
        </bean>
    </property>
</bean>

配置数据源：

<!--数据源-->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName">
        <value>${datasource.driver}</value>
    </property>
    <property name="url">
        <value>${datasource.url}</value>
    </property>
    <property name="username" value="${datasource.username}"></property>
    <property name="password" value="${datasource.password}"></property>
</bean>

数据库参数：

四、RowMapper

1.框架提供的BeanPropertyRowMapper

<!-- 读取db -->
<bean id="jdbcItemReader" scope="step" class="org.springframework.batch.item.database.JdbcCursorItemReader" >
    <!--指定访问的数据源-->
    <property name="dataSource" ref="dataSource"/>
    <!--指定查询的SQL语句-->
    <property name="sql" value="select ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS from t_credit where id between 1 and 5 "/>
    <!--用于将指定结果集ResultSet转换为Java业务对象，即CreditBill-->
    <property name="rowMapper">
        <bean class="org.springframework.jdbc.core.BeanPropertyRowMapper">
            <property name="mappedClass" value="com.xj.demo26.CreditBill"/>
        </bean>
    </property>
</bean>

????????使用Spring Batch提供的BeanPropertyRowMapper完成将结果集ResultSet转换为CreditBill对象，通过设置属性mappedClass，自动将结果集ResultSet和CreditBill对象映射(即将表中的字段名称映射到CreditBill对象的属性中)。

2.自定义RowMapper

????????通过实现接口org.springframework.jdbc.core.RowMapper<T>，可以自定义RowMapper的实现类。RowMapper接口为：

public interface RowMapper<T> {
    T mapRow(ResultSet var1, int var2) throws SQLException;
}

• mapRow():核心转换法，参数为结果集和当前游标所在的位置。

实现类CreditBillRowMapper.java:

package com.xj.demo27;

import org.springframework.jdbc.core.RowMapper;
import java.sql.ResultSet;
import java.sql.SQLException;

public class CreditBillRowMapper implements RowMapper<CreditBill> {

	public CreditBill mapRow(ResultSet rs, int rowNum) throws SQLException {
		CreditBill bill = new CreditBill();
		bill.setAccountID(rs.getString("ACCOUNTID"));
		bill.setAddress(rs.getString("ADDRESS"));
		bill.setAmount(rs.getDouble("AMOUNT"));
		bill.setDate(rs.getString("DATE"));
		bill.setName(rs.getString("NAME"));
		return bill;
	}
}

配置方法：

<!-- 参数化读取db -->
<bean id="jdbcParameterItemReader" scope="step"
           class="org.springframework.batch.item.database.JdbcCursorItemReader" >
    <property name="dataSource" ref="dataSource"/>
    <property name="sql" value="select ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS from t_credit where id between 1 and ? "/>
    <property name="rowMapper" ref="custCreditRowMapper" />
    <property name="preparedStatementSetter" ref="paramStatementSetter"/>
</bean>

<bean id="paramStatementSetter" scope="step"
           class="org.springframework.batch.core.resource.ListPreparedStatementSetter">
    <property name="parameters">
        <list>
            <value>#{jobParameters['id']}</value>
        </list>
    </property>
</bean>

<!--自定义RowMapper-->
<bean id="custCreditRowMapper" class="com.xj.demo27.CreditBillRowMapper"/>

五、preparedStatementSetter

1.框架提供的ListPreparedStatementSetter

????????Spring Batch框架提供了自带的ListPreparedStatementSetter，用来设置SQL语句需要的参数。配置详情见上“配置方法”。

2.自定义preparedStatementSetter

????????开发者可以根据自己业务需要实现自定义的PreparedStatementSetter来进行参数设置。PreparedStatementSetter接口定义如下：

public interface PreparedStatementSetter {
    void setValues(PreparedStatement var1) throws SQLException;
}

• setValues：核心方法，为参数PreparedStatement设置SQL需要的参数

自定义CreditBillPreparedStatementSetter.java:

package com.xj.demo28;

import org.springframework.jdbc.core.PreparedStatementSetter;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class CreditBillPreparedStatementSetter implements
        PreparedStatementSetter {

	public void setValues(PreparedStatement ps) throws SQLException {
		ps.setString(1, "5");
	}

}

配置方法：

<!-- 参数化读取db -->
<bean id="jdbcParameterItemReader" scope="step"
           class="org.springframework.batch.item.database.JdbcCursorItemReader" >
    <property name="dataSource" ref="dataSource"/>
    <property name="sql" value="select ID,ACCOUNTID,NAME,AMOUNT,DATE,ADDRESS from t_credit where id between 1 and ? "/>
    <property name="rowMapper" ref="custCreditRowMapper" />
    <property name="preparedStatementSetter" ref="custPreparedStatementSetter"/>
</bean>

<!--自定义PreparedStatementSetter-->
<bean id="custPreparedStatementSetter"        ??????????????????????????????class="com.xj.demo28.CreditBillPreparedStatementSetter"/>

<!--自定义RowMapper-->
<bean id="custCreditRowMapper" class="com.xj.demo28.CreditBillRowMapper"/>