|
@@ -23,7 +23,7 @@ from util.singleton import Singleton
|
|
|
sys.path.append(os.path.dirname(os.path.abspath(__file__)))
|
|
sys.path.append(os.path.dirname(os.path.abspath(__file__)))
|
|
|
|
|
|
|
|
|
|
|
|
|
-class DbClient(object):
|
|
|
|
|
|
|
+class DbClient(metaclass=Singleton):
|
|
|
"""
|
|
"""
|
|
|
DbClient DB工厂类 提供get/put/update/pop/delete/exists/getAll/clean/getCount/changeTable方法
|
|
DbClient DB工厂类 提供get/put/update/pop/delete/exists/getAll/clean/getCount/changeTable方法
|
|
|
|
|
|
|
@@ -48,8 +48,6 @@ class DbClient(object):
|
|
|
|
|
|
|
|
"""
|
|
"""
|
|
|
|
|
|
|
|
- __metaclass__ = Singleton
|
|
|
|
|
-
|
|
|
|
|
def __init__(self, db_conn):
|
|
def __init__(self, db_conn):
|
|
|
"""
|
|
"""
|
|
|
init
|
|
init
|
|
@@ -57,6 +55,7 @@ class DbClient(object):
|
|
|
"""
|
|
"""
|
|
|
self.db_conn = db_conn
|
|
self.db_conn = db_conn
|
|
|
self.parseDbConn(db_conn)
|
|
self.parseDbConn(db_conn)
|
|
|
|
|
+ self.__printConfig()
|
|
|
self.__initDbClient()
|
|
self.__initDbClient()
|
|
|
|
|
|
|
|
@classmethod
|
|
@classmethod
|
|
@@ -91,6 +90,15 @@ class DbClient(object):
|
|
|
password=self.db_pwd,
|
|
password=self.db_pwd,
|
|
|
db=self.db_name)
|
|
db=self.db_name)
|
|
|
|
|
|
|
|
|
|
+ def __printConfig(self):
|
|
|
|
|
+ print("============ DATABASE CONFIGURE =========================")
|
|
|
|
|
+ print("DB_TYPE: %s" % self.db_type)
|
|
|
|
|
+ print("DB_HOST: %s" % self.db_host)
|
|
|
|
|
+ print("DB_PORT: %s" % self.db_port)
|
|
|
|
|
+ print("DB_NAME: %s" % self.db_name)
|
|
|
|
|
+ print("DB_USER: %s" % self.db_user)
|
|
|
|
|
+ print("=========================================================")
|
|
|
|
|
+
|
|
|
def get(self, **kwargs):
|
|
def get(self, **kwargs):
|
|
|
return self.client.get(**kwargs)
|
|
return self.client.get(**kwargs)
|
|
|
|
|
|