python mysql批量巡检

import mysql.connector
from mysql.connector import Error

def check_database_connection(host, database, user, password):
    try:
        connection = mysql.connector.connect(host=host,
                                             database=database,
                                             user=user,
                                             password=password)
        if connection.is_connected():
            print("Database is connected!")
        return connection
    except Error as e:
        print(f"Error while connecting to MySQL: {e}")
        return None

def check_table_integrity(connection, table_name):
    cursor = connection.cursor()
    try:
        cursor.execute(f"CHECK TABLE {table_name} FAST")
        result = cursor.fetchone()
        if result[3] == 'OK':
            print(f"Table {table_name} is intact.")
        else:
            print(f"Table {table_name} has issues: {result[3]}")
    except Error as e:
        print(f"Error checking table integrity: {e}")
    finally:
        cursor.close()

def main():
    host = 'localhost'
    database = 'testdb'
    user = 'root'
    password = 'password'

    connection = check_database_connection(host, database, user, password)
    if connection:
        tables = ['table1', 'table2', 'table3']
        for table in tables:
            check_table_integrity(connection, table)
        connection.close()

if __name__ == "__main__":
    main()