Ошибка компонента Camel SQL при вставке данных с помощью Postgres db

Я новичок на верблюде, и в настоящее время я создаю маршрут для вставки данных в БД. Рассматриваемая база данных - Postgres. Я пытаюсь использовать компонент верблюда-SQL версии 2.18.2 для вставки записей в базу данных. Однако я получаю синтаксические ошибки на простой запрос вставки при использовании его с компонентом SQL. я не уверен, поддерживает ли компонент camel-sql синтаксис Postgres или есть какие-либо проблемы с тем, как я настроил. Я много искал документацию SO и Camel, но не мог найти потенциальных клиентов. ниже приведен код, который я использую. Может кто-нибудь, пожалуйста, помогите с решением этой проблемы, которая я как-то застрял на некоторое время сейчас.

    from("seda:dailyInsert")
            .routeId("dailyInsert")
            .log(LoggingLevel.INFO,"inside dailyInsert")
            .process(dailyInsertProcessor) //**getting syntax errors in SQL line below **
            .to("sql:INSERT INTO tran."DailynInsert" ("DAILY_TRAN_SEQ_ID","SOURCE_CODE") VALUES 
     (nextval('tran."DAILY_TRAN_SEQ_ID"'), :#SOURCE_CODE)")
            .log(LoggingLevel.INFO,"records have been inserted 
      successfully")

Ниже процессор

@Override
public void process(Exchange exchange) throws Exception {
    // TODO Auto-generated method stub
    @SuppressWarnings("unchecked")
    DailyDetail dailyDetails =  (DailyDetail) exchange.getIn().getHeader("dailyRecords");

    logger.info("Starting setting the batch details in the exchange");
    // set all the details in the header.

    exchange.getIn().setHeader("SOURCE_CODE", dailyDetails.getSourceCode());

}

0 ответов

Другие вопросы по тегам