#!/usr/bin/env python3
import sys
import mysql.connector
from config import DB_HOST, DB_USERNAME, DB_PASSWORD, DB_DATABASE

def excluir_duplicados():
    try:
        conn = mysql.connector.connect(
            host=DB_HOST,
            user=DB_USERNAME,
            password=DB_PASSWORD,
            database=DB_DATABASE
        )
    except mysql.connector.Error as err:
        sys.exit("Erro ao conectar ao banco de dados: " + str(err))
    
    cursor = conn.cursor()

    # Essa query exclui registros duplicados com base no campo "email",
    # mantendo apenas o registro com o menor ID.
    delete_query = """
    DELETE t1 FROM consolidado t1
    INNER JOIN consolidado t2
      ON t1.email = t2.email AND t1.id > t2.id;
    """

    try:
        cursor.execute(delete_query)
        conn.commit()
        print(f"Total de duplicados excluídos: {cursor.rowcount}")
    except mysql.connector.Error as err:
        print("Erro ao excluir duplicados:", err)
    finally:
        cursor.close()
        conn.close()

if __name__ == '__main__':
    excluir_duplicados()