Questions tagged [camel-sql]

82 questions
9
votes
1 answer

Apache Camel SQL Batch insertion taking long time

I am using Apache Camel SQL batch insertion process. My application is reading tickets from the Active MQ which contains around 2000 tickets. I have updated the batch as 100. The query which i am firing is as follows: sql.subs.insertCdr= insert…
KayV
  • 12,987
  • 11
  • 98
  • 148
4
votes
0 answers

Camel-SQL Why using StreamList seems to load all ResultSet?

Hi, What am I trying to do ? I am currently working on an ESB project (apache-camel + spring boot 2) where i read a MySQL table with more than 100 000 000 rows. I empty this table 1 row at a time, transform the row and send it to another…
4
votes
1 answer

Unable to map postgresql timestamp with timezone in camel jdbc

I have following route which get data from postgresql but date object is coming null. it's unable to map that value My route if following
user1047873
  • 230
  • 3
  • 8
  • 28
4
votes
1 answer

Apache Camel How do I access the Header values from an sql component

I am trying to print the number of rows selected by an sql component using the property header.CamelSqlRowCount. However the value is coming empty. I added trace as mentioned in another post to check the header values and only breadcrumbId is…
Sarun
  • 161
  • 1
  • 8
2
votes
0 answers

Apache Camel JdbcAggregationRepository demands unproportionate TABLESPACE in Oracle 12C

I have a simple camel route. It polls a directory, reads a text file and splits the content of file line by line. Then it transforms each line (now having lesser no. of characters than original line) and aggregates the transformed lines (messages)…
Sanjeev Saha
  • 2,632
  • 1
  • 12
  • 19
2
votes
1 answer

SimpleParserException: Unknown function: property.fileName

I'm using Apache Camel 3.0 and I'm getting this error when parsing the file: from("file:" + filePath) .routeId("create-ticket") .unmarshal(ticketCsv) .to("jpa:Ticket") .log("Created new ticket with…
uzx79024
  • 21
  • 1
  • 2
2
votes
1 answer

Apache Camel - JPAEndpoint - Catch exception on commit e.g. PersistenceException

I have a route which basically transfers the data from one database table to the other. Producer and consumers are JPA endpoints. Simplified: from(producer) .process(new StagingEventTransformer()) .to(consumer); What I'm currently want to catch is…
user984200
  • 273
  • 1
  • 6
  • 17
2
votes
1 answer

Accessing OUT parameters with Apache Camel SQL Stored Procedure Component

I'm calling an Oracle Stored Procedure using Apache Camel's SQL Stored Procedure Component. The Stored Procedure that I'm calling has several OUT parameters which are all returned in the BODY as a String, for example: {param1=0, param2=-,…
Unai
  • 181
  • 1
  • 11
2
votes
2 answers

Camel-Spring Boot: Route doesn't stop after execution

I am using Spring Boot + Camel with below config. Main Class @SpringBootApplication public class Application extends RouteBuilder { public static void main(String[] args) { SpringApplication.run(Application.class, args); } …
user1637487
  • 241
  • 1
  • 9
  • 17
2
votes
1 answer

Camel SQL - Put DataSource to SimpleRegistry in Spring Boot

I am using Spring Boot to initiate a camel route that uses Camel-sql to query MySQL DB and call a REST…
user1637487
  • 241
  • 1
  • 9
  • 17
1
vote
0 answers

SQL Component internally resets CamelSqlUpdateCount to zero

Oddly enough, the SQL component reset the CamelSqlUpdateCount header value to zero when there is a 'SET FOREIGN_KEY_CHECKS' before a 'REPLACE SELECT'. I ran in debug mode with a watcher on the header map. Yes the value is correct at first but it is…
1
vote
1 answer

Why does camel move file with only partial data?

Below is my code: from("quartz2:report?cron=" + cronExpression) .routeId("jms:queue:test") .setHeader("CURRENT_TIME", simple("${date:now:MM-dd-yyyy HH:mm:ss.S}")) //Writing column names for report to the file .setBody() …
1
vote
1 answer

camel csv display column name

I have two questions. The first question: i use camel sql and camel csv to export database in csv. I would like to display column names however the options of camel csv doesn't work for me while i am on camel 2.16.5 version. ex)
Katy
  • 39
  • 6
1
vote
1 answer

Apache Camel: How to transform hierarchical data from database into pojo

I am new to stackoverflow and also to Apache Camel. I try to write a understandable description of my problems. My goal is to read hierarchical data from database (mysql) which is composed by 1 entry in a parent table and several rows in a child…
1
vote
1 answer

Apache Camel Idempotent Consumer for file

I have one physical server where two Apache Camel instances a running on. Both contain the same integration artifacts. The task is to integrate files from the server's file system with Apache Camel's file component triggered by a cron job. The file…
ian_eve
  • 97
  • 2
  • 8
1
2 3 4 5 6