[camel-kafka-connector] 11/14: Cleanup iteration over test result set

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit ffedadd2dc977c29ba2eaa281d16785784ea8d16
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Wed Jan 13 15:23:45 2021 +0100

    Cleanup iteration over test result set
---
 .../org/apache/camel/kafkaconnector/jdbc/client/DatabaseClient.java     | 2 +-
 .../java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/client/DatabaseClient.java
 
b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/client/DatabaseClient.java
index 855fcdc..72b9bfb 100644
--- 
a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/client/DatabaseClient.java
+++ 
b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/client/DatabaseClient.java
@@ -54,7 +54,7 @@ public class DatabaseClient {
         String query = String.format("select count(*) as count from %s", 
table);
 
         try (ResultSet rs = connection.prepareStatement(query).executeQuery()) 
{
-            while (rs.next()) {
+            if (rs.next()) {
                 return rs.getInt("count");
             }
         }
diff --git 
a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java
 
b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java
index f3e8c21..5dbd27f 100644
--- 
a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java
+++ 
b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/client/DatabaseClient.java
@@ -54,7 +54,7 @@ public class DatabaseClient {
         String query = String.format("select count(*) as count from %s", 
table);
 
         try (ResultSet rs = connection.prepareStatement(query).executeQuery()) 
{
-            while (rs.next()) {
+            if (rs.next()) {
                 return rs.getInt("count");
             }
         }