import mysql.connector
from mysql.connector import Error


# Print iterations progress
def printProgressBar (iteration, total, prefix = '', suffix = '', decimals = 1, length = 100, fill = '█', printEnd = "\r"):
    """
    Call in a loop to create terminal progress bar
    @params:
        iteration   - Required  : current iteration (Int)
        total       - Required  : total iterations (Int)
        prefix      - Optional  : prefix string (Str)
        suffix      - Optional  : suffix string (Str)
        decimals    - Optional  : positive number of decimals in percent complete (Int)
        length      - Optional  : character length of bar (Int)
        fill        - Optional  : bar fill character (Str)
        printEnd    - Optional  : end character (e.g. "\r", "\r\n") (Str)
    """
    percent = ("{0:." + str(decimals) + "f}").format(100 * (iteration / float(total)))
    filledLength = int(length * iteration // total)
    bar = fill * filledLength + '-' * (length - filledLength)
    print(f'\r{prefix} |{bar}| {percent}% {suffix}', end = printEnd)
    # Print New Line on Complete
    if iteration == total: 
        print()


# 📌 Étape 1 : Lire le fichier SQL
file_path = "src/Command/car_specs.sql" #"/Users/petrusedgar/Documents/projets/autoconso/base de données/car_db/car_specs.sql"
with open(file_path, 'r') as file:

    try:
        connection = mysql.connector.connect(
            host="localhost",
            port="3306",
            user="naje4034_autoconso_admin",
            password="Francisco$*1401",
            database="naje4034_autoconso_api"
            #host="localhost",
            #port="8889",
            #database="autoconso-api",
            #user="root",
            #password="root"
        )

        printProgressBar(0, 3465974, prefix = 'Progress:', suffix = 'Complete', length = 3465974)
        i = 0
        l = 3465974
        if connection.is_connected():

            printProgressBar(i + 1, l, prefix = 'Progress:', suffix = 'Complete', length = 50)
            cursor = connection.cursor()

            # 📌 Étape 3 : Mettre à jour la BDD
            sql_script = file.read()
            # Exécuter le script SQL
            for statement in sql_script.split(';'):
                if statement.strip():
                    cursor.execute("INSERT INTO `car_spec` (`id`, `car_engine_id`, `car_spec_type_id`, `value`, `unit`, `date_create`, `date_update`, `car_type_id`) VALUES " + statement.strip())
                    print(f"✅ Exécuté : {statement.strip()}")
            # ✅ Commit après toutes les mises à jour
            connection.commit()
            print("✅ Toutes les mises à jour ont été effectuées avec succès.")
    except Error as e:
        print("❌ Erreur lors de la connexion à MySQL : ", e)
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("✅ Connexion MySQL fermée.")
        else:
            print("❌ La connexion MySQL n'est pas ouverte.")
            print("❌ Erreur lors de la connexion à MySQL : ", e)