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:04 UTC
[09/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/c080086b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c080086b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c080086b
Branch: refs/heads/camel-2.15.x
Commit: c080086be0f74ec17e0d6a2063c457c94bc25f87
Parents: 6603feb
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:41 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/c080086b/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");
}
};
}