You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/01/08 17:41:01 UTC
[06/10] camel git commit: CAMEL-9491 : statement.maxRows not working
as expected camel jdbc
CAMEL-9491 : statement.maxRows not working as expected camel jdbc
add maxrows test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6c54fdcd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6c54fdcd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6c54fdcd
Branch: refs/heads/camel-2.16.x
Commit: 6c54fdcd6e5525c208b3c018d37f47cf6d8affc4
Parents: 1c66c30
Author: gautric <ga...@redhat.com>
Authored: Fri Jan 8 16:49:43 2016 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Jan 8 17:40:11 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/component/jdbc/JdbcFix9491Test.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/6c54fdcd/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/JdbcFix9491Test.java
----------------------------------------------------------------------
diff --git a/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/JdbcFix9491Test.java b/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/JdbcFix9491Test.java
index 32928bf..dc80d42 100644
--- a/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/JdbcFix9491Test.java
+++ b/components/camel-jdbc/src/test/java/org/apache/camel/component/jdbc/JdbcFix9491Test.java
@@ -45,7 +45,7 @@ public class JdbcFix9491Test extends AbstractJdbcTestSupport {
direct.sendBody("select * from customer");
assertMockEndpointsSatisfied();
- Assert.assertEquals(3,mock.getReceivedExchanges().get(1).getIn().getBody(List.class).size());
+ Assert.assertEquals(2,mock.getReceivedExchanges().get(1).getIn().getBody(List.class).size());
}
@@ -54,7 +54,7 @@ public class JdbcFix9491Test extends AbstractJdbcTestSupport {
return new RouteBuilder() {
public void configure() throws Exception {
from("direct:start").
- to("jdbc:testdb").to("mock:result");
+ to("jdbc:testdb?statement.maxRows=2").to("mock:result");
}
};
}