1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="//www.springframework.org/schema/beans"
 3     xmlns:xsi="//www.w3.org/2001/XMLSchema-instance" xmlns:p="//www.springframework.org/schema/p"
 4     xmlns:tx="//www.springframework.org/schema/tx" xmlns:aop="//www.springframework.org/schema/aop"
 5     xmlns:context="//www.springframework.org/schema/context"
 6     xsi:schemaLocation="//www.springframework.org/schema/beans  
 7 //www.springframework.org/schema/beans/spring-beans-3.0.xsd  
 8 //www.springframework.org/schema/tx  
 9 //www.springframework.org/schema/tx/spring-tx-3.0.xsd  
10 //www.springframework.org/schema/aop  
11 //www.springframework.org/schema/aop/spring-aop-3.0.xsd  
12 //www.springframework.org/schema/context  
13 //www.springframework.org/schema/context/spring-context-2.5.xsd"
14     default-autowire="byName">
15 
16     <!-- auto scan path -->
17     <context:component-scan base-package="com.wanggc.springbatch.sample.xml" />
18 
19     <bean id="jobLauncher"
20         class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
21         <property name="jobRepository" ref="jobRepository" />
22     </bean>
23 
24     <bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean" />
25 
26     <bean id="transactionManager"
27         class="org.springframework.batch.support.transaction.ResourcelessTransactionManager">
28     </bean>
29 </beans>

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <bean:beans xmlns="//www.springframework.org/schema/batch"
 3     xmlns:bean="//www.springframework.org/schema/beans" xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
 4     xmlns:p="//www.springframework.org/schema/p" xmlns:tx="//www.springframework.org/schema/tx"
 5     xmlns:aop="//www.springframework.org/schema/aop" xmlns:context="//www.springframework.org/schema/context"
 6     xmlns:util="//www.springframework.org/schema/util"
 7     xsi:schemaLocation="//www.springframework.org/schema/beans 
 8 //www.springframework.org/schema/beans/spring-beans-3.0.xsd  
 9 //www.springframework.org/schema/tx 
10 //www.springframework.org/schema/tx/spring-tx-3.0.xsd  
11 //www.springframework.org/schema/aop 
12 //www.springframework.org/schema/aop/spring-aop-3.0.xsd  
13 //www.springframework.org/schema/context 
14 //www.springframework.org/schema/context/spring-context-2.5.xsd
15 //www.springframework.org/schema/batch 
16 //www.springframework.org/schema/batch/spring-batch-2.1.xsd 
17 //www.springframework.org/schema/util //www.springframework.org/schema/util/spring-util.xsd">
18 
19     <bean:import resource="applicationContext.xml" />
20 
21     <job id="xmlFileReadAndWriterJob">
22         <step id="xmlFileReadAndWriterStep">
23             <tasklet>
24                 <chunk reader="xmlReader" writer="xmlWriter" processor="xmlProcessor"
25                     commit-interval="10">
26                 </chunk>
27             </tasklet>
28         </step>
29     </job>
30 
31     <!-- XML文(wen)件讀取 -->
32     <bean:bean id="xmlReader"
33         class="org.springframework.batch.item.xml.StaxEventItemReader" scope="step">
34         <bean:property name="fragmentRootElementName" value="goods" />
35         <bean:property name="unmarshaller" ref="tradeMarshaller" />
36         <bean:property name="resource"
37             value="file:#{jobParameters['inputFilePath']}"></bean:property>
38     </bean:bean>
39 
40     <!-- XML文件寫入 -->
41     <bean:bean id="xmlWriter"
42         class="org.springframework.batch.item.xml.StaxEventItemWriter" scope="step">
43         <bean:property name="rootTagName" value="wanggc" />
44         <bean:property name="marshaller" ref="tradeMarshaller" />
45         <bean:property name="resource"
46             value="file:#{jobParameters['outputFilePath']}" />
47     </bean:bean>
48 
49     <bean:bean id="tradeMarshaller"
50         class="org.springframework.oxm.xstream.XStreamMarshaller">
51         <bean:property name="aliases">
52             <util:map id="aliases">
53                 <bean:entry key="goods"
54                     value="com.wanggc.springbatch.sample.xml.pojo.Goods" />
55                 <bean:entry key="buyDay" value="java.util.Date"></bean:entry>
56             </util:map>
57         </bean:property>
58     </bean:bean>
59 </bean:beans>

package com.wanggc.springbatch.sample.xml;

import java.util.Date;

import org.springframework.batch.item.ItemProcessor;
import org.springframework.stereotype.Component;

import com.wanggc.springbatch.sample.xml.pojo.Goods;

/**
 * XML文件處理類。
 */
@Component("xmlProcessor")
public class XMLProcessor implements ItemProcessor<Goods, Goods> {

    /**
     * XML文件內容處理。
     * 
     */
    @Override
    public Goods process(Goods goods) throws Exception {
        // 購入日期(qi)變更
        goods.setBuyDay(new Date());
        // 顧客信息(xi)變更
        goods.setCustomer(goods.getCustomer() + "顧客!");
        // ISIN變(bian)更
        goods.setIsin(goods.getIsin() + "IsIn");
        // 價格變更(geng)
        goods.setPrice(goods.getPrice() + 1000.112);
        // 數量變更
        goods.setQuantity(goods.getQuantity() + 100);
        // 處(chu)理后的數據返(fan)回
        return goods;
    }
}

package com.wanggc.springbatch.sample.xml;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class XMLLaunch {

    /**
     * @param args
     */
    public static void main(String[] args1) {

        ApplicationContext context = new ClassPathXmlApplicationContext(
                "batch.xml");
        JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");
        Job job = (Job) context.getBean("xmlFileReadAndWriterJob");

        try {
            // JOB實行
            JobExecution result = launcher.run(job, new JobParametersBuilder()
                    .addString("inputFilePath", "C:\\input.xml")
                    .addString("outputFilePath", "C:\\output.xml")
                    .toJobParameters());
            // 運(yun)行結果(guo)輸出
            System.out.println(result.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

package com.wanggc.springbatch.sample.xml.pojo;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 商品信息類.
 */
public class Goods {
    /** isin號 */
    private String isin;
    /** 數量 */
    private int quantity;
    /** 價(jia)格(ge) */
    private double price;
    /** 客戶 */
    private String customer;
    /** 購入日(ri)期(qi) */
    private Date buyDay;

    /* getter he setter已經刪(shan)除 */
}