從Spring批處理數據庫中讀取記錄

Question

我試圖從循環中讀取數據庫中的一些記錄，然後對記錄進行一些計算（更新一個稱爲總計的字段）。

但我是新的春季批次，所以請任何人都可以提供一些提示。

Answer 1

這聽起來像塊圖案會解決的問題。您可以使用現有的Spring Batch組件來重新讀取數據庫，編寫自己的處理器，然後傳回給Spring Batch組件進行存儲。

說用例是這樣的; - 讀取記錄 - record.setTotalColumn（record.getColumn2（）+ record.getColumn3（）） - 更新

這種配置可能是這樣

<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"/> 

這意味着你唯一必須從頭開始寫「計算器處理器」，它可能是這樣的;

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; 
    } 

}