[Py-client] Print Dataset is closed error msg if user continues to fetch from it (#14396)

Author: HTHou

iotdb-client/client-py/iotdb/Session.py

@@ -516,7 +516,7 @@ def insert_str_record(self, device_id, timestamp, measurements, string_values):
             )
             measurements = list(filtered_measurements)
             values = list(filtered_values)
-            if len(measurements) is 0 or len(values) is 0:
+            if len(measurements) == 0 or len(values) == 0:
                 logger.info("All inserting values are none!")
                 return
         request = self.gen_insert_str_record_req(
@@ -556,7 +556,7 @@ def insert_aligned_str_record(
             )
             measurements = list(filtered_measurements)
             values = list(filtered_values)
-            if len(measurements) is 0 or len(values) is 0:
+            if len(measurements) == 0 or len(values) == 0:
                 logger.info("All inserting values are none!")
                 return
         request = self.gen_insert_str_record_req(
@@ -605,7 +605,7 @@ def insert_record(self, device_id, timestamp, measurements, data_types, values):
             measurements = list(filtered_measurements)
             data_types = list(filtered_data_types)
             values = list(filtered_values)
-            if len(measurements) is 0 or len(data_types) is 0 or len(values) is 0:
+            if len(measurements) == 0 or len(data_types) == 0 or len(values) == 0:
                 logger.info("All inserting values are none!")
                 return
         request = self.gen_insert_record_req(
@@ -651,7 +651,7 @@ def insert_records(
             ) = self.__filter_lists_by_values(
                 device_ids, times, measurements_lst, types_lst, values_lst
             )
-            if len(device_ids) is 0:
+            if len(device_ids) == 0:
                 logger.info("All inserting values are none!")
                 return
         if self.__enable_redirection:
@@ -734,7 +734,7 @@ def insert_aligned_record(
             measurements = list(filtered_measurements)
             data_types = list(filtered_data_types)
             values = list(filtered_values)
-            if len(measurements) is 0 or len(data_types) is 0 or len(values) is 0:
+            if len(measurements) == 0 or len(data_types) == 0 or len(values) == 0:
                 logger.info("All inserting values are none!")
                 return
         request = self.gen_insert_record_req(
@@ -780,7 +780,7 @@ def insert_aligned_records(
             ) = self.__filter_lists_by_values(
                 device_ids, times, measurements_lst, types_lst, values_lst
             )
-            if len(device_ids) is 0:
+            if len(device_ids) == 0:
                 logger.info("All inserting values are none!")
                 return
         if self.__enable_redirection:

iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py

@@ -25,6 +25,7 @@
 from thrift.transport import TTransport
 from iotdb.thrift.rpc.IClientRPCService import TSFetchResultsReq, TSCloseOperationReq
 from iotdb.tsfile.utils.DateUtils import parse_int_to_date
+from iotdb.utils.IoTDBConnectionException import IoTDBConnectionException
 from iotdb.utils.IoTDBConstants import TSDataType
 
 logger = logging.getLogger("IoTDB")
@@ -417,6 +418,8 @@ def result_set_to_pandas(self):
         return df
 
     def fetch_results(self):
+        if self.__is_closed:
+            raise IoTDBConnectionException("This DataSet is already closed")
         self.__rows_index = 0
         request = TSFetchResultsReq(
             self.__session_id,