From 27f71201df915b3d9c2dc046f91e0eaa9610bbbe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E5=B8=85?= Date: Mon, 12 Jan 2026 15:52:24 +0800 Subject: [PATCH 1/2] Update Python sessionPool example --- .../client-py/session_pool_example.py | 24 ++++++++------ .../table_model_session_pool_example.py | 32 ++++++++++++------- 2 files changed, 35 insertions(+), 21 deletions(-) diff --git a/iotdb-client/client-py/session_pool_example.py b/iotdb-client/client-py/session_pool_example.py index 64a754087fae..85ecc4b5ff8e 100644 --- a/iotdb-client/client-py/session_pool_example.py +++ b/iotdb-client/client-py/session_pool_example.py @@ -89,14 +89,18 @@ 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 +109,11 @@ 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 bd190a8b4732..5967b6dccc96 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,11 @@ 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 +103,18 @@ 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 +123,11 @@ 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() From cfe2765054f34eaae3311083e77f6205d13baf2f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E5=B8=85?= Date: Mon, 12 Jan 2026 16:41:11 +0800 Subject: [PATCH 2/2] black session_pool_example.py and table_model_session_pool_example.py --- iotdb-client/client-py/session_pool_example.py | 12 +++--------- .../table_model_session_pool_example.py | 16 ++++------------ 2 files changed, 7 insertions(+), 21 deletions(-) diff --git a/iotdb-client/client-py/session_pool_example.py b/iotdb-client/client-py/session_pool_example.py index 85ecc4b5ff8e..dfbc7a44705a 100644 --- a/iotdb-client/client-py/session_pool_example.py +++ b/iotdb-client/client-py/session_pool_example.py @@ -89,16 +89,12 @@ def query_data(): session = session_pool.get_session() print("get data from root.test.d0") - with session.execute_query_statement( - "select * from root.test.d0" - ) as res: + 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") - with session.execute_query_statement( - "select * from root.test.d1" - ) as res: + with session.execute_query_statement("select * from root.test.d1") as res: while res.has_next(): print(res.next()) @@ -109,9 +105,7 @@ def delete_data(): session = session_pool.get_session() session.delete_storage_group(STORAGE_GROUP_NAME) print("data has been deleted. now the devices are:") - with session.execute_statement( - "show devices root.test.**" - ) as res: + 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 5967b6dccc96..ed910b843e94 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,7 @@ def prepare_data(): print("now the tables are:") # show result - with session.execute_query_statement( - "SHOW TABLES" - ) as res: + with session.execute_query_statement("SHOW TABLES") as res: while res.has_next(): print(res.next()) @@ -103,16 +101,12 @@ def query_data(): session = session_pool.get_session() print("get data from table0") - with session.execute_query_statement( - "select * from table0" - ) as res: + with session.execute_query_statement("select * from table0") as res: while res.has_next(): print(res.next()) print("get data from table1") - with session.execute_query_statement( - "select * from table0" - ) as res: + with session.execute_query_statement("select * from table0") as res: while res.has_next(): print(res.next()) @@ -123,9 +117,7 @@ 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:") - with session.execute_query_statement( - "show databases" - ) as res: + with session.execute_query_statement("show databases") as res: while res.has_next(): print(res.next()) session.close()