我正在使用univocity-PARSERS将csv文件行转换为java对象.
在处理文件时,如果它遇到行中任何列的任何问题,那么它解析在该行中停止并抛出异常.但我需要一些东西,只要跳过有错误的行,就会一直持续到文件结尾.但我没有api中的任何实用程序类.
我的豆类
public class ItemcodeBean {
@Trim
@NullString(nulls = { " ","" })
@Parsed(field = "ItemCode")
private String itemCode;
@Trim
@NullString(nulls = { " ","" })
@Parsed(field = "PartNumber")
private String partNumber;
@Trim
@NullString(nulls = { " ","" })
@Parsed(field = "ModelNumber")
private String modelNumber;
}
我的主要课程
公共类TestClass {
private BeanListProcessorstem.out.println(itemcodeBean.toString());
}
}catch (Throwable ex){
System.out.println(ex.getLocalizedMessage());
}
}
private BeanListProcessornoreLeadingWhitespaces(true);
//skip trailing whitespaces
parserSettings.setIgnoreTrailingWhitespaces(true);
//skip empty lines
parserSettings.setSkipEmptyLines(true);
File file = new File("C:\\Users\\abhishyam.c\\Downloads\\Itemcode_Template.csv");
this.parser = new CsvParser(parserSettings);
//parser.parse(file);
parser.beginParsing(file);
return rowProcessor;
}
private ItemcodeBean getRowData() throws Throwable {
String[] row;
try {
while ((row = parser.parseNext()) != null){
return rowProcessor.createBean(row,parser.getContext());
}
}catch (DataProcessingException e){
throw new DataProcessingException(e.getColumnName(),e);
}
// parser.stopParsing();
return null;
}
}
最佳答案
只需使用错误处理程序,除非您自己抛出异常,否则它将继续运行:
//Let's set a RowProcessorErrorHandler to log the error. The parser will keep running.
settings.setProcessorErrorHandler(new RowProcessorErrorHandler() {
@Override
public void handleError(DataProcessingException error,Object[] inputRow,ParsingContext context) {
println(out,"Error processing row: " + Arrays.toString(inputRow));
println(out,"Error details: column '" + error.getColumnName() + "' (index " + error.getColumnIndex() + ") has value '" + inputRow[error.getColumnIndex()] + "'");
}
});
更新:您可以使用RetryableErrorHandler来防止丢弃该行.这是添加到版本2.3.0的特殊实现,允许用户调用方法setDefaultValue()为有问题的列分配值,并使用keepRecord来防止记录被丢弃.
例:
settings.setProcessorErrorHandler(new RetryableErrorHandlerirst column,assign 50 and proceed with the record.
if(error.getColumnIndex() == 0){
setDefaultValue(50);
} else { //else keep the record anyway. Null will be used instead.
keepRecord();
}
}
});
请注意,如果error.getColumnIndex()返回-1,则无法保存记录,无论如何都会跳过它.您可以使用它来记录错误详细信息.