mysql:
for _ in range(10):
try:
conn = pymysql.connect(**self.base_info)
# 返回字典格式的数据
cursor = conn.cursor(pymysql.cursors.DictCursor)
return conn, cursor
except Exception as err:
logger.exception("数据库连接失败, %s" % err)
return None, None
pgsql:
def connectPostgreSQL(self):
"""
PG库连接
"""
for _ in range(10):
try:
conn = psycopg2.connect(**PG_SQL_LOCAL)
cursor = conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
return conn, cursor
except Exception as err:
logger.exception("数据库连接失败, %s" % err)
return None, None