(iotdb) branch master updated: Release query resources in the Python sessionPool example (#17013)

[haonan]

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

haonan 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 09db0d6b6de Release query resources in the Python sessionPool example 
(#17013)
09db0d6b6de is described below

commit 09db0d6b6de109552d3d4305a865068afacca804
Author: Z-By <shuai.z...@timecho.com>
AuthorDate: Mon Jan 12 16:50:28 2026 +0800

    Release query resources in the Python sessionPool example (#17013)
---
 iotdb-client/client-py/session_pool_example.py     | 18 ++++++++--------
 .../client-py/table_model_session_pool_example.py  | 24 +++++++++++-----------
 2 files changed, 21 insertions(+), 21 deletions(-)

diff --git a/iotdb-client/client-py/session_pool_example.py 
b/iotdb-client/client-py/session_pool_example.py
index 64a754087fa..dfbc7a44705 100644
--- a/iotdb-client/client-py/session_pool_example.py
+++ b/iotdb-client/client-py/session_pool_example.py
@@ -89,14 +89,14 @@ def query_data():
     session = session_pool.get_session()
 
     print("get data from root.test.d0")
-    res = session.execute_query_statement("select * from root.test.d0")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("select * from root.test.d0") as res:
+        while res.has_next():
+            print(res.next())
 
     print("get data from root.test.d1")
-    res = session.execute_query_statement("select * from root.test.d1")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("select * from root.test.d1") as res:
+        while res.has_next():
+            print(res.next())
 
     session_pool.put_back(session)
 
@@ -105,9 +105,9 @@ def delete_data():
     session = session_pool.get_session()
     session.delete_storage_group(STORAGE_GROUP_NAME)
     print("data has been deleted. now the devices are:")
-    res = session.execute_statement("show devices root.test.**")
-    while res.has_next():
-        print(res.next())
+    with session.execute_statement("show devices root.test.**") as res:
+        while res.has_next():
+            print(res.next())
     session_pool.put_back(session)
 
 
diff --git a/iotdb-client/client-py/table_model_session_pool_example.py 
b/iotdb-client/client-py/table_model_session_pool_example.py
index bd190a8b473..ed910b843e9 100644
--- a/iotdb-client/client-py/table_model_session_pool_example.py
+++ b/iotdb-client/client-py/table_model_session_pool_example.py
@@ -44,9 +44,9 @@ def prepare_data():
 
     print("now the tables are:")
     # show result
-    res = session.execute_query_statement("SHOW TABLES")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("SHOW TABLES") as res:
+        while res.has_next():
+            print(res.next())
 
     session.close()
 
@@ -101,14 +101,14 @@ def query_data():
     session = session_pool.get_session()
 
     print("get data from table0")
-    res = session.execute_query_statement("select * from table0")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("select * from table0") as res:
+        while res.has_next():
+            print(res.next())
 
     print("get data from table1")
-    res = session.execute_query_statement("select * from table0")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("select * from table0") as res:
+        while res.has_next():
+            print(res.next())
 
     session.close()
 
@@ -117,9 +117,9 @@ def delete_data():
     session = session_pool.get_session()
     session.execute_non_query_statement("drop database db1")
     print("data has been deleted. now the databases are:")
-    res = session.execute_query_statement("show databases")
-    while res.has_next():
-        print(res.next())
+    with session.execute_query_statement("show databases") as res:
+        while res.has_next():
+            print(res.next())
     session.close()