Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def read_mysql_database(table, column):
- log.debug( f'read_mysql_database() called with ({table}, {column})')
- try:
- connection = mysql.connector.connect(user=system_info.mysql_username,
- password=system_info.mysql_password,
- host=system_info.mysql_servername,
- database=system_info.mysql_database)
- cursor = connection.cursor(buffered=True)
- cursor.execute(("SELECT %s FROM %s") % (column, table))
- for data in cursor:
- database_value = (data[0])
- return database_value
- cursor.close()
- connection.close()
- except Error as error :
- log.warning("Failed to read record from database: {}".format(error))
- exit()
Add Comment
Please, Sign In to add comment