本文共 2579 字，大约阅读时间需要 8 分钟。

– Start

假设我们有如下分隔符文件(people_20170711.txt)

header1|zhangsan2|lisi3|wangwufooter

需要导入如下表中

CREATE TABLE PEOPLE(	ID    NUMBER(8,0), 	NAME  VARCHAR2(30));

来看看如何配置这个 job 吧

   
   		
    	
    	    
     	    
     	    
     	    
     	
    		
    	
    	    
     	
    		
    	
    	
    	
    	    
     	
    	
    	
    		
     			
      				
       			
      		
     	
    	
    	
    		
     	    
     		
     		
     			
      				
       
        header
       				
       
        footer
       			
      		
     		
     		
     	    
     		
     		
     	    
     	
    		
    		
     		
     	
    		
    		
     	
    		
    		
     		
     		
     	
    	
    	
    	
    	
    		
     		
     		
     	
    		
    		
     	
    		
    
   

package shangbo.springbatch.example2;public class People implements java.io.Serializable{	private static final long serialVersionUID = 8904705906008476310L;		private Integer id;	private String name;	public Integer getId() {		return id;	}	public void setId(Integer id) {		this.id = id;	}	public String getName() {		return name;	}	public void setName(String name) {		this.name = name;	}}

package shangbo.springbatch.example2;import java.util.HashMap;import java.util.Map;import org.springframework.batch.core.Job;import org.springframework.batch.core.JobParameter;import org.springframework.batch.core.JobParameters;import org.springframework.batch.core.JobParametersInvalidException;import org.springframework.batch.core.launch.JobLauncher;import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;import org.springframework.batch.core.repository.JobRestartException;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class App {	public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {		ApplicationContext context = new ClassPathXmlApplicationContext("shangbo/springbatch/example2/LoadFileJob.xml");		// job 和 job 参数		Map
   
     parameters = new HashMap<>();		parameters.put("business_date", new JobParameter("20170711"));		JobParameters jobParameters = new JobParameters(parameters);		Job job = context.getBean(Job.class);		// 运行 job		JobLauncher jobLauncher = context.getBean(JobLauncher.class);		jobLauncher.run(job, jobParameters);	}}
   

–