1

model/util/ClickHouseUtils.py

@@ -1,51 +0,0 @@
-from clickhouse_driver.client import Client
-from model.common.log import logger
-log=logger()
-
-class CkUtils:
-
-    def __init__(self):
-        self.client = Client(host='cc-bp1h3yc7o3g3o7k64o.ads.aliyuncs.com',
-                           user='qucheng_ck',
-                           password='Qc123456',
-                           port='3306',
-                           send_receive_timeout=5)
-
-    def execute(self, sql):
-        self.client.execute(sql)
-
-
-    def insertMany(self,table,col,data):
-        """
-        :param table: 表名 srt
-        :param col:   字段名 srt   eg: ”a,b,c“
-        :param data:  tuple
-        :return:
-        """
-        max=200
-        sql="insert into {} ({}) values ".format(table,col)
-
-        if len(data) == 0:
-            log.debug("data.len==0")
-            return
-        if len(data) <= max:
-            sql = sql+str(data)[1:-1]
-            # log.info(sql)
-            # log.info("insert {} rows".format(len(data)))
-            self.execute(sql)
-            return
-        else:
-
-            sql2=sql+str(data[:max])[1:-1]
-            # log.info(sql2)
-            self.execute(sql2)
-            # log.info("insert {} rows".format(max))
-            self.insertMany(table,col,data[max:])
-
-
-
-if __name__ == '__main__':
-    ck= CkUtils()
-    a =ck.execute("desc order")
-    print(a)
-