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

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

commit a921366bbcf5916a329a2f4e28584e4329ae37cf
Author: JackieTien97 <[email protected]>
AuthorDate: Tue Sep 29 19:03:36 2020 +0800

    solve the statement twice call bug
---
 jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java 
b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
index 1b21c5c..c93bb33 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
@@ -224,12 +224,12 @@ public class IoTDBStatement implements Statement {
       if (execResp.queryDataSet == null) {
         this.resultSet = new IoTDBNonAlignJDBCResultSet(this, 
execResp.getColumns(),
             execResp.getDataTypeList(), execResp.columnNameIndexMap, 
execResp.ignoreTimeStamp, client, sql, queryId,
-            sessionId, execResp.nonAlignQueryDataSet);
+            sessionId, execResp.nonAlignQueryDataSet.deepCopy());
       }
       else {
         this.resultSet = new IoTDBJDBCResultSet(this, execResp.getColumns(),
             execResp.getDataTypeList(), execResp.columnNameIndexMap, 
execResp.ignoreTimeStamp, client, sql, queryId,
-            sessionId, execResp.queryDataSet);
+            sessionId, execResp.queryDataSet.deepCopy());
       }
       return true;
     }
@@ -320,12 +320,12 @@ public class IoTDBStatement implements Statement {
     if (execResp.queryDataSet == null) {
       this.resultSet = new IoTDBNonAlignJDBCResultSet(this, 
execResp.getColumns(),
           execResp.getDataTypeList(), execResp.columnNameIndexMap, 
execResp.ignoreTimeStamp, client, sql, queryId,
-          sessionId, execResp.nonAlignQueryDataSet);
+          sessionId, execResp.nonAlignQueryDataSet.deepCopy());
     }
     else {
       this.resultSet = new IoTDBJDBCResultSet(this, execResp.getColumns(),
           execResp.getDataTypeList(), execResp.columnNameIndexMap, 
execResp.ignoreTimeStamp, client, sql, queryId,
-          sessionId, execResp.queryDataSet);
+          sessionId, execResp.queryDataSet.deepCopy());
     }
     return resultSet;
   }

Reply via email to