camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Müller <christian.muel...@gmail.com>
Subject Re: statement.maxRows not working as expected camel jdbc
Date Wed, 06 Jan 2016 22:21:22 GMT
Hi Felix,

I have a unit test which confirms your finding. Could you please open an
JIRA and post the ticket number here. I will have a closer look during the
next days.
As workaround, you could also set the limit in the SQL query. Something
like: select * from TBL_DATA_AC LIMIT 2

Best,

Christian
-----------------

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Jan 6, 2016 at 4:04 PM, Felix Thomas <felix.thomas@gmail.com> wrote:

> hello,
>
>       I have an issue (not sure if its a bug)  in camel. I have tested in
> multiple versio*n i.e. 2.15.1,2.16.0,2.16.1 *also but still the same
> result.
>
>       I have a route defined below in spring XML . When i start the camel
> instance it works fine at the first time i.e it fetches only 2 records as
> expected . But  when the timer kicks in after 1 minute again it fetchs all
> the rows in the table . I expect it to fetch only 2 again. Is there an
> issue in my route definition ??
>
>
> <route customId="true" id="ROUTE_TBL_DATA_AC" xmlns="
> http://camel.apache.org/schema/spring">
>     <from uri="timer://getDataROUTE_TBL_DATA_AC?period=1m"/>
>     <setBody id="setBody2">
>         <constant>select * from TBL_DATA_AC</constant>
>     </setBody>
>
>     <to
> uri="jdbc:DSROUTE_TBL_DATA_AC?*statement.maxRows=2&*amp;outputType=StreamList"
> id="to8"/>
>     <split parallelProcessing="true" streaming="true" id="split1">
>         <simple>${body}</simple>
>         <convertBodyTo type="java.lang.String" />
>         <multicast parallelProcessing="true"
> executorServiceRef="customThreadPoolProfile" id="multicast1">
>             <pipeline id="pipeline1">
>                 <to
>
> uri="rabbitmq://localhost/QUEUE?autoDelete=false&amp;autoAck=false&amp;queue=DEV&amp;username=guest&amp;password=guest&amp;routingKey=DEV&amp;durable=true"
> id="to9"/>
>             </pipeline>
>         </multicast>
>     </split>
> </route>
>
>
>
> regards,
> Felix
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message