java - 骆驼Bindy @csvRecord 生成页脚

Question

我已经使用@csvRecord 生成了带有camel Bindy 的CSV 文件，但无法为此csv 生成页脚以显示文件中的记录总数。我可以使用@FixedLenght 记录生成，但不能使用@csvRecord。请提供任何建议

标签： javacsvapache-camelfooterbindy

Answer 1

您不能以与使用 camel-bindy 的 FixedLength 类似的方式在 CSV 中生成页脚。

根据数据，您可能会添加一条包含有关总数等信息的附加记录。

编辑：

CSV 文件示例：

FIELD1;FIELD2
test1;4
test3;6

CSVFilePojo 类：

import org.apache.camel.dataformat.bindy.annotation.CsvRecord;
import org.apache.camel.dataformat.bindy.annotation.DataField;

@CsvRecord(separator = ";", skipFirstLine = true)
public class CsvFilePojo {

    @DataField(pos = 1)
    private String field1;

    @DataField(pos = 2)
    private Integer field2;

    public CsvFilePojo(String field1, Integer field2) {
        this.field1 = field1;
        this.field2 = field2;
    }

    public CsvFilePojo() {
    }

    public String getField1() {
        return field1;
    }

    public void setField1(String field1) {
        this.field1 = field1;
    }

    public Integer getField2() {
        return field2;
    }

    public void setField2(Integer field2) {
        this.field2 = field2;
    }

    @Override
    public String toString() {
        return String.format("field1: %s; field2: %s", field1, field2);
    }

}

CountTotalProcessor 类：

import java.util.List;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class CountTotalProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        List<CsvFilePojo> csvlist = exchange.getIn().getBody(List.class);

        // count total
        Integer total = 0;
        for (CsvFilePojo c : csvlist) {
            total += c.getField2();
        }

        // add total as last record in csv data
        csvlist.add(new CsvFilePojo("total", total));
        exchange.getIn().setBody(csvlist);
    }
}

MyRouteBuilder 类：

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat;

public class MyRouteBuilder extends RouteBuilder {

    public void configure() {
        //@formatter:off
        from("file:csvFiles")
            .log("gotFile ${file:name}")
            .to("direct:processFile")
            .to("file:processedCsvFiles");

        from("direct:processFile")
            .log("processing CSV file")
            .unmarshal(new BindyCsvDataFormat(CsvFilePojo.class))
            .process(new CountTotalProcessor())
            .split(simple("${body}"))
                .log("Body ${body}")
            .end()
            ;
    }

}

使用该示例 csv 文件，此路由将生成一个 CSV 文件，如下所示：

FIELD1;FIELD2
test1;4
test3;6
total;10