當我嘗試讀取我的 csv 文件時，我遇到了 Spring batch 的這個問題。我必須閱讀具有如下結構的CSV ：valueHeader;valueHeader;valueHeader;valueHeader;valueHeader;valueHeaderconventValue;conventValue;conventValue;conventValue;conventValueconventValue;conventValue;conventValue;conventValue;conventValueconventValue;conventValue;conventValue;conventValue;conventValuevalueFooter;valueFooter;valueFooter;valueFooter;valueFooter;valueFooter我有一個MultiResourceItemReader，它委托一個String 類型的FlatFileItemReader，以便輕松地將此行映射到我在之后執行的自定義項處理器中的自定義 DTO。在我的 Tasklet 中，我像這樣注入了我的 MultiResourceItemReader bean：@Autowired private MultiResourceItemReader<String> resourceItemReader;然后我這樣稱呼它（設置資源和上下文）： resourceItemReader.setStrict(Boolean.FALSE); resourceItemReader.setResources(resources); resourceItemReader.open(context.getStepContext().getStepExecution().getExecutionContext()); String currentContent = resourceItemReader.read(); while(currentContent != null) { linesReaded.add(currentContent); currentContent = resourceItemReader.read(); }But I am getting a **NullPointerException** in the first Line and I don't know why:20190705 19:53:30.041 INFO com.mycomp.mycustomp.tasklet.MyCustomTasklet [[ # ]] - [MyCustomTasklet:EXECUTE]20190705 19:53:41.560 ERROR org.springframework.batch.core.step.AbstractStep [[ # ]] - Encountered an error executing step processRebateASLIStep in job MyProyectJob
1 回答
繁星點點滴滴
TA貢獻1803條經驗 獲得超3個贊
您沒有在您的LineMapper. 這是添加一個的方法：
reader.setLineMapper(new DefaultLineMapper<String>() {
{
//Setea los valores en la clase indicada
setFieldSetMapper(new FieldSetMapper<String>() {
@Override
public String mapFieldSet(FieldSet fieldSet) throws BindException {
String[] values = fieldSet.getValues();
return String.join(";", values);
}
});
setLineTokenizer(new DelimitedLineTokenizer(";"));
}
});
FlatFileItemReaderBuilder由于其流暢的 API，我建議使用 which更直觀。這是一個例子：
@Bean
public FlatFileItemReader<Pojo> flatFileItemReader() {
return new FlatFileItemReaderBuilder<Pojo>()
.name("itemReader")
.resource(new FileSystemResource("/path/to/flat/file"))
.targetType(Pojo.class)
.delimited()
.delimiter(";")
.names("column1", "column2")
.build();
}
添加回答
舉報
0/150
提交
取消