Lesen von Datensätzen Aus einer Datenbank in Spring Batch

diese klingt wie etwas, was die chunk-Muster-Adresse. Sie können die Wiederverwendung bestehender Spring Batch Komponenten aus der Datenbank gelesen, Komponieren Sie Ihren eigenen Prozessor, dann pass zurück zu a Spring Batch-Komponente zu speichern.

sagen, der Anwendungsfall ist wie folgt;
- Lesen eines Datensatzes
- Rekord.setTotalColumn(Rekord.getColumn2() + Datensatz.getColumn3())
- update

diese Konfiguration könnte wie folgt Aussehen

<batch:job id="recordProcessor">
  <batch:step id="recordProcessor.step1">
    <batch:tasklet>
      <batch:chunk reader="jdbcReader" processor="calculator" writer="jdbcWriter" commit-interval="10"/>
      </batch:tasklet>
  </batch:step>
</batch:job>

<bean id="jdbcReader" class="org.springframework.batch.item.database.JdbcCursorItemReader">
  <property name="dataSource" ref="dataSource"/>
  <property name="sql" value="select idColumn,column1,column2,totalColumn from my_table"/>
  <property name="rowMapper" ref="myRowMapper"/>
</bean>

<bean id="jdbcWriter" class="org.springframework.batch.item.database.JdbcBatchItemWriter">
  <property name="dataSource" ref="dataSource"/>
  <property name="sql" value="update my_table set totalColumn = :value where idColumn = :id"/>
</bean>

<bean id="calculator" class="de.incompleteco.spring.batch.step.item.CalculationProcessor"/>

dies bedeutet, dass die einzige Sache, die Sie haben zu 'schreiben' von Grund auf neu würde der Rechner Prozessor könnte e so etwas wie dieses;

package de.incompleteco.spring.batch.step.item;

import org.springframework.batch.item.ItemProcessor;

public class CalculationProcessor implements ItemProcessor<MyObject, MyObject> {

    @Override
    public MyObject process(MyObject item) throws Exception {
        //do the math
        item.setTotalColumn(item.getColumn1() + item.getColumn2());
        //return
        return item;
    }

}

InformationsquelleAutor incomplete-co.de