(iotdb) branch master updated: Fix bug change the hasnext impl of session data set

[jackietien]

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

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 44b263e2a93 Fix bug change the hasnext impl of session data set
44b263e2a93 is described below

commit 44b263e2a93e38b955ccdd5fe2201f08ffd0f77b
Author: linxt20 <lxt135...@163.com>
AuthorDate: Sun Apr 14 14:10:16 2024 +0800

    Fix bug change the hasnext impl of session data set
---
 .../test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java | 1 +
 .../src/main/java/org/apache/iotdb/isession/SessionDataSet.java     | 6 +++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
index bb52fffda5d..040cda701ae 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
@@ -407,6 +407,7 @@ public class IoTDBSessionSimpleIT {
       SessionDataSet dataSet = session.executeQueryStatement("select * from 
root.存储组1.*");
       int count = 0;
       while (dataSet.hasNext()) {
+        dataSet.next();
         count++;
       }
       assertEquals(10, count);
diff --git 
a/iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java
 
b/iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java
index b0de2a331bb..f927f6d5467 100644
--- 
a/iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java
+++ 
b/iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java
@@ -155,7 +155,11 @@ public class SessionDataSet implements ISessionDataSet {
 
   @Override
   public boolean hasNext() throws StatementExecutionException, 
IoTDBConnectionException {
-    return ioTDBRpcDataSet.next();
+    if (ioTDBRpcDataSet.hasCachedRecord) {
+      return true;
+    } else {
+      return ioTDBRpcDataSet.next();
+    }
   }
 
   private RowRecord constructRowRecordFromValueArray() throws 
StatementExecutionException {