0

我有以下骆驼路线：

from(inputDirectory)
  .unmarshal(jaxb)
  .process(jaxb2CSVDataProcessor)
  .split(body()) //because there is a list of CSVRecords
  .marshal(bindyCsvDataFormat)
  .to(outputDirectory); //appending to existing file using "?autoCreate=true&fileExist=Append"

对于我的 CSV 模型类，我正在使用注释：

@CsvRecord(separator = ",", generateHeaderColumns = true)
...

和属性

@DataField(pos = 0)
...

我的问题是每次附加新的 csv 记录时都会附加标题。

有没有一种不脏的方法来控制它？我在这里错过了什么吗？

4

3 回答 3

1

我做了一个工作非常好的工作，通过查询@DataField 注释的列名来创建标题。一旦第一次写入文件，就会发生这种情况。我在这里写下了整个解决方案：

如何使用 Camel Bindy 生成带有页眉和页脚的平面文件

于 2019-03-20T09:03:34.440 回答
0

我最终添加了一个处理器来检查 csv 文件是否存在于“to”子句之前。在那里我对字节数组进行操作并删除标题。

于 2016-12-16T15:18:16.487 回答
0

希望这对其他人有帮助。我需要做一些类似的事情，在我的第一个拆分消息之后，我想抑制标题输出。这是一个完整的类（'FieldUtils' 是 apache commons lib 的一部分）

package com.routes;

import java.io.OutputStream;

import org.apache.camel.Exchange;
import org.apache.camel.dataformat.bindy.BindyAbstractFactory;
import org.apache.camel.dataformat.bindy.BindyCsvFactory;
import org.apache.camel.dataformat.bindy.BindyFactory;
import org.apache.camel.dataformat.bindy.FormatFactory;
import org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat;
import org.apache.commons.lang3.reflect.FieldUtils;

public class StreamingBindyCsvDataFormat extends BindyCsvDataFormat {

    public StreamingBindyCsvDataFormat(Class<?> type) {
        super(type);
    }

    @Override
    public void marshal(Exchange exchange, Object body, OutputStream outputStream) throws Exception {
        final StreamingBindyModelFactory factory = (StreamingBindyModelFactory) super.getFactory();
        final int splitIndex = exchange.getProperty(Exchange.SPLIT_INDEX, -1, int.class);
        final boolean splitComplete = exchange.getProperty(Exchange.SPLIT_COMPLETE, false, boolean.class);

        super.marshal(exchange, body, outputStream);

        if (splitIndex == 0) {
        factory.setGenerateHeaderColumnNames(false); // turn off header generate after first exchange
        } else if(splitComplete) {
        factory.setGenerateHeaderColumnNames(true); // turn on header generate when split complete
        }
    }

    @Override
    protected BindyAbstractFactory createModelFactory(FormatFactory formatFactory) throws Exception {
        BindyCsvFactory bindyCsvFactory = new StreamingBindyModelFactory(getClassType());
        bindyCsvFactory.setFormatFactory(formatFactory);
        return bindyCsvFactory;
    }

    public class StreamingBindyModelFactory extends BindyCsvFactory implements BindyFactory {

        public StreamingBindyModelFactory(Class<?> type) throws Exception {
            super(type);
        }

        public void setGenerateHeaderColumnNames(boolean generateHeaderColumnNames) throws IllegalAccessException {
            FieldUtils.writeField(this, "generateHeaderColumnNames", generateHeaderColumnNames, true);
        }

    }

}
于 2021-05-27T09:08:09.500 回答