add some comments.

databendlabs · Apr 17, 2024 · 5aeb081 · 5aeb081
1 parent 141e98b
commit 5aeb081
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendConnection.java
@@ -555,6 +555,7 @@ public void PingDatabendClientV1() throws SQLException {
             statement.execute("select 1");
             ResultSet r = statement.getResultSet();
             while (r.next()) {
+                //System.out.println(r.getInt(1));
             }
         } catch (SQLException e) {
             throw new DatabendFailedToPingException(String.format("failed to ping databend server: %s", e.getMessage()));

diff --git a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendResultSet.java b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendResultSet.java
@@ -216,6 +216,7 @@ private ResultsPageIterator(DatabendClient client)
             this.client = client;
         }
 
+        // AsyncIterator will call this and put rows to queue with MAX_QUEUED_ROWS=5000
         @Override
         protected Iterable<List<Object>> computeNext()
         {