python连接数据库的方式
pyzenith.connect()函数就是连接数据库;
exception.ScriptException()这一句是自定义异常,可以不用我这个;
finally里面还有一个try finally是有必要的,防止关闭出现异常错误
@staticmethoddef connect_data(user_info, sql):"""连接数据库执行sql语句:param user_info: 数据库账户信息:param sql: sql语句:return: list<tuple> 类型的数据"""start = time.time()cursor = Noneconn = Nonetry:conn = pyzenith.connect(user_info.get('serverName'), user_info.get('user'),user_info.get('passwd'), str(user_info.get('port')))cursor = conn.cursor()cursor.execute(sql)row_data = cursor.fetchall()return row_dataexcept Exception as ex:raise exception.ScriptException(f'数据库操作执行失败:{ex}')finally:try:if cursor:cursor.close()finally:if conn:conn.close()LOG.info('数据库操作共使用%s秒', time.time() - start)