fix IT

Author: HTHou

…nt-py/SessionAlignedTimeseriesExample.py …py/session_aligned_timeseries_example.pyiotdb-client/client-py/SessionAlignedTimeseriesExample.py renamed to iotdb-client/client-py/session_aligned_timeseries_example.py iotdb-client/client-py/SessionAlignedTimeseriesExample.py renamed to iotdb-client/client-py/session_aligned_timeseries_example.py

@@ -37,39 +37,15 @@ def test_session_pool():
 def session_test(use_session_pool=False):
     with IoTDBContainer("iotdb:dev") as db:
         db: IoTDBContainer
-
+        config = {
+            "node_urls": [
+                f"{db.get_container_host_ip()}:{db.get_exposed_port(6667)}",
+            ]
+        }
         if use_session_pool:
-            # pool_config = PoolConfig(
-            #     db.get_container_host_ip(),
-            #     db.get_exposed_port(6667),
-            #     "root",
-            #     "root",
-            #     None,
-            #     1024,
-            #     "Asia/Shanghai",
-            #     3,
-            #     sql_dialect="table",
-            # )
-            # session_pool = create_session_pool(pool_config, 1, 3000)
-            # session = session_pool.get_session()
-
-            session_pool = TableSessionPool(
-                config={
-                    "node_urls": [
-                        f"{db.get_container_host_ip()}:{db.get_exposed_port(6667)}",
-                    ]
-                }
-            )
+            session_pool = TableSessionPool(**config)
         else:
-            host = db.get_container_host_ip()
-            port = db.get_exposed_port(6667)
-            session = TableSession(
-                config={
-                    "node_urls": [
-                        f"{host}:{port}",
-                    ]
-                }
-            )
+            session = TableSession(**config)
 
         session.execute_non_query_statement("CREATE DATABASE IF NOT EXISTS db1")
         session.execute_non_query_statement('USE "db1"')

iotdb-client/client-py/SessionExample.py iotdb-client/client-py/session_example.pyiotdb-client/client-py/SessionExample.py renamed to iotdb-client/client-py/session_example.py

@@ -30,15 +30,12 @@
 def test_insert_use_tablet():
     with IoTDBContainer("iotdb:dev") as db:
         db: IoTDBContainer
-        host = db.get_container_host_ip()
-        port = db.get_exposed_port(6667)
-        session = TableSession(
-            config={
-                "node_urls": [
-                    f"{host}:{port}",
-                ]
-            }
-        )
+        config = {
+            "node_urls": [
+                f"{db.get_container_host_ip()}:{db.get_exposed_port(6667)}",
+            ]
+        }
+        session = TableSession(**config)
 
         # Preparation before testing
         session.execute_non_query_statement(
@@ -625,15 +622,12 @@ def test_insert_use_tablet():
 def test_insert_relational_tablet_use_numpy_tablet():
     with IoTDBContainer("iotdb:dev") as db:
         db: IoTDBContainer
-        host = db.get_container_host_ip()
-        port = db.get_exposed_port(6667)
-        session = TableSession(
-            config={
-                "node_urls": [
-                    f"{host}:{port}",
-                ]
-            }
-        )
+        config = {
+            "node_urls": [
+                f"{db.get_container_host_ip()}:{db.get_exposed_port(6667)}",
+            ]
+        }
+        session = TableSession(**config)
 
         # Preparation before testing
         session.execute_non_query_statement(
@@ -1112,15 +1106,12 @@ def test_insert_relational_tablet_use_numpy_tablet():
 def test_insert_relational_tablet_auto_create():
     with IoTDBContainer("iotdb:dev") as db:
         db: IoTDBContainer
-        host = db.get_container_host_ip()
-        port = db.get_exposed_port(6667)
-        session = TableSession(
-            config={
-                "node_urls": [
-                    f"{host}:{port}",
-                ]
-            }
-        )
+        config = {
+            "node_urls": [
+                f"{db.get_container_host_ip()}:{db.get_exposed_port(6667)}",
+            ]
+        }
+        session = TableSession(**config)
 
         # Preparation before testing
         session.execute_non_query_statement(