如何使用spring batch从db中的多个表读取数据

Question

我尝试使用spring batch从一个表中读取数据并写入其他表，但现在我的要求是从多个表中读取数据并写入一个文件，所以我们可以通过定义多个作业来实现这一点，但我想使用单个作业来实现，即单个读取器、单个写入器和单个处理器。

请为我提供一些关于这个场景的参考资料。

Answer 1

spring批处理提供的类不可能，但您可以让它成为我们的一种方式。
在块处理之前添加一个步骤，创建一个定制的tasklet，在其中分配不同的sql和不同的输出文件，并使它们在循环中运行，只要有sql要执行。
听起来可能很难，但我也处理过同样的情况，这里有一些您可以做到的想法-

   <flow id="databaseReadWriteJob">
            <step id="step1_setReaderWriter">
                <tasklet ref="setReaderWriter" />
                <next on="FAILED" to="" />
                <next on="*" to="dataExtractionStep" />
            </step>
            <step id="dataExtractionStep">
                <tasklet>
                    <chunk reader="dbReader" writer="flatFileWriter" commit-interval="${commit-interval}" />
</tasklet>
                <next on="FAILED" to="" />
                <next on="*" to="step3_removeProcessedSql" />
            </step>
            <step id="step3_removeProcessedSql">
                <tasklet ref="removeProcessedSql" />
                <next on="NOOP" to="step1_setReaderWriter" />
                <next on="*" to="step4_validateNumOfSuccessfulSteps" />
            </step>
    </flow>

下面是setReaderWriter的bean

<beans:bean id="setReaderWriter" class="SetReaderWriter">
        <beans:property name="reader" ref="dbReader" />
        <beans:property name="flatFileWriter" ref="flatFileWriter" />
        <beans:property name="fileSqlMap" ref="jobSqlFileMap" />
        <beans:property name="fileNameBuilder" ref="localFileNameBuilder" />
        <beans:property name="sourceFolder" value="${dataDir}" />
        <beans:property name="dateDiff" value="${dateDiff}" />

任何需要在Reader或Writer中动态添加的内容。上面的sqlMap是sql作为键和输出文件作为值的映射。
希望能有所帮助。