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)