spring batch getting a SQLParameterSource from a BeanWrapper

Question

我正在使用BeanWrapperFieldSetMapper将CSV文件的内容映射到自定义Bean。是否有一个 spring 批处理实用程序类可以将此 bean 转换为实现 SQLParameterSource 接口的对象。我正在寻找一个使用反射来填充 MapSqlParameterSource 类的类，使用自定义 bean 字段名称和关联的值以及键/值对。

这是我当前的作业配置

<bean id="abcFileReaderDBLoaderJob" parent="simpleJob">
    <property name="steps">
        <list>
            <bean parent="simpleStep">
                <property name="itemReader">
                    <bean class="org.springframework.batch.item.file.FlatFileItemReader">
                        <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="strict" value="false"/>
                                        <property name="names" value="a,b,c" />
                                    </bean>
                                </property>
                                <property name="fieldSetMapper">
                                    <bean class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper">
                                        <property name="prototypeBeanName" value="abcBean"/>
                                    </bean>
                                </property>
                            </bean>
                        </property>
                        <property name="resource">
                            <bean class="org.springframework.core.io.FileSystemResource">
                                <constructor-arg value="${abc.file}" />
                            </bean>
                        </property>
                    </bean>
                </property>
                <property name="itemWriter" ref="abcTableWriter"/>
            </bean>
        </list>
    </property>
</bean>

我的通用表编写器有这个接口

/**
 * Takes a list of SqlParameterSource and writes to the DB.
 */
public class TableWriter implements ItemWriter<SqlParameterSource> {
    ....
}

Answer 1

你的意思是BeanPropertySqlParameterSource吗？

从以下位置获取参数值的 SqlParameterSource 实现 给定 JavaBean 对象的 Bean 属性。豆子的名字 属性必须与参数名称匹配。

使用Spring BeanWrapper在下面访问Bean属性。