figure out Unclosed client session warning and fix it

Author: sn0wfree

ClickSQL/clickhouse/ClickHouse.py

@@ -107,7 +107,7 @@ def __init__(self, **db_settings):
         self.http_settings = self._merge_settings(None, updated_settings=self._default_settings)
         self.http_settings.update({'user': self._para.user, 'password': self._para.password})
 
-        self._session = ClientSession()
+        # self._session = ClientSession()
         self.max_async_query_once = 5
         self.is_closed = False
 
@@ -270,7 +270,6 @@ def execute(self, *sql, convert_to: str = 'dataframe', loop=None, ):
         :param loop:
         :return:
         """
-        ## TODO warning: Unclosed client session
 
         insert_process = list(map(lambda x: x.lower().startswith(available_queries_insert), sql))
         select_process = list(map(lambda x: x.lower().startswith(available_queries_select), sql))

ClickSQL/clickhouse/ClickHouseExt.py

@@ -1,7 +1,7 @@
 # coding=utf-8
 import pandas as pd
 import numpy as np
-
+import re
 
 class ClickHouseTableNodeExt(object):
     @classmethod
@@ -191,7 +191,7 @@ def _create_table_from_df(cls, db: str, table: str, df: pd.DataFrame, key_cols:
         dtypes_dict = {k: v for k, v in dtypes_dict.items() if k in cols}
         base = cls._create_table_from_sql(db, table, dtypes_dict, key_cols, engine_type=engine_type,
                                           extra_format_dict=extra_format_dict, partitions_expr=partitions_expr)
-        exist_status = cls._check_table_exists(obj, db, table)
+        # exist_status = cls._check_table_exists(obj, db, table)
 
         query_func(base)
         return exist_status

README.md

@@ -19,5 +19,16 @@ more information for ClickHouse can be found at [here](http://clickhouse.tech)
 
 ## Usage
 
+```python
+from ClickSQL import ClickHouseTableNode
+
+conn_str = "clickhouse://default:test121231@99.99.9.9:8123/system"
+ClickHouseTableNode(conn_str)
+
+>>> connection test:  Ok.
+
+``` 
+
+
 
 

test/testing.py

@@ -3,6 +3,7 @@
 from ClickSQL import ClickHouseTableNode
 
 if __name__ == '__main__':
-    print(ClickHouseTableNode)
+    conn_str = "clickhouse://default:Imsn0wfree@47.104.186.157:8123/system"
+    cf = ClickHouseTableNode(conn_str)
 
     pass