Ver Fonte

close holo connect

liqian há 3 anos atrás
pai
commit
881ca6c315
1 ficheiros alterados com 30 adições e 30 exclusões
  1. 30 30
      db_helper.py

+ 30 - 30
db_helper.py

@@ -259,36 +259,36 @@ class RedisHelper(object):
 # connectPool = pgpool.SimpleConnectionPool(1, 30, **config_.HOLOGRES_INFO)
 
 
-class HologresHelper(object):
-    def __init__(self):
-        """初始化hologres连接信息"""
-        #self.hologres_info = config_.HOLOGRES_INFO
-
-    def get_data(self, sql):
-        #global conn
-        # 连接Hologres
-        #conn = psycopg2.connect(**self.hologres_info)
-        conn = connectPool.getconn()
-        # 创建游标
-        cur = conn.cursor()
-        try:
-            # 查询数据
-            cur.execute(sql)
-            data = cur.fetchall()
-            cur.close()
-            connectPool.putconn(conn, close=False)
-            # 提交事务
-            #conn.commit()
-            # 释放资源
-            #cur.close()
-            #conn.close()
-        except Exception as e:
-            log_.error('hologress error...')
-            log_.error(traceback.format_exc())
-            cur.close()
-            connectPool.putconn(conn, close=False)
-            return []
-        return data
+# class HologresHelper(object):
+#     def __init__(self):
+#         """初始化hologres连接信息"""
+#         #self.hologres_info = config_.HOLOGRES_INFO
+#
+#     def get_data(self, sql):
+#         #global conn
+#         # 连接Hologres
+#         #conn = psycopg2.connect(**self.hologres_info)
+#         conn = connectPool.getconn()
+#         # 创建游标
+#         cur = conn.cursor()
+#         try:
+#             # 查询数据
+#             cur.execute(sql)
+#             data = cur.fetchall()
+#             cur.close()
+#             connectPool.putconn(conn, close=False)
+#             # 提交事务
+#             #conn.commit()
+#             # 释放资源
+#             #cur.close()
+#             #conn.close()
+#         except Exception as e:
+#             log_.error('hologress error...')
+#             log_.error(traceback.format_exc())
+#             cur.close()
+#             connectPool.putconn(conn, close=False)
+#             return []
+#         return data
 
 
 class MysqlHelper(object):