一旦发生错误，csv 到 bean 对象的 UNIVOCITY-PARSERS 就会停止

Question

我正在使用 UNIVOCITY-PARSERS 将 csv 文件行转换为 java 个对象。

在处理文件时，如果它在行中的任何列遇到任何问题，那么它会在该行停止解析并抛出异常。但我需要一些东西，只要跳过有错误的行，它就会一直持续到文件末尾。但是我在 api.

中没有任何实用程序 classes

我的豆子class

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;

}

我的主Class

public class TestClass {

    private  BeanListProcessor<ItemcodeBean>
            rowProcessor = null;
    private CsvParser parser = null;
    public static void main(String[] args) {
        TestClass testClass = new TestClass();
        testClass.init();
        try{
            ItemcodeBean itemcodeBean;
            while ((itemcodeBean = testClass.getRowData()) != null){
                System.out.println(itemcodeBean.toString());
            }
        }catch (Throwable ex){
            System.out.println(ex.getLocalizedMessage());
        }

    }

    private BeanListProcessor<ItemcodeBean> init() {
        // BeanListProcessor converts each parsed row to an instance of a given class, then stores each instance into a list.
              this.rowProcessor =
                new BeanListProcessor<ItemcodeBean>(ItemcodeBean.class);

        CsvParserSettings parserSettings = new CsvParserSettings();
        parserSettings.setProcessor(rowProcessor);
        parserSettings.setHeaderExtractionEnabled(true);
        // skip leading whitespaces
        parserSettings.setIgnoreLeadingWhitespaces(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;
    }
}

Answer 1

只需使用一个错误处理程序，它将继续运行，除非您自己抛出异常：

    //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 RetryableErrorHandler<ParsingContext>() {
    @Override
    public void handleError(DataProcessingException error, Object[] inputRow, ParsingContext context) {
        //if there's an error in the first 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() returns -1，则无法保存记录，无论如何都会跳过。您可以使用它来记录错误详细信息。

一旦发生错误，csv 到 bean 对象的 UNIVOCITY-PARSERS 就会停止

UNIVOCITY-PARSERS for csv to bean object stopping as soon as error has occured

java

csv

parsing

univocity