import mysql.connector

# Conectar ao banco de dados
conn = mysql.connector.connect(
    host="74.63.254.202",
    user="hcpgestao_user",
    password="8;;*N^]}w+OW",
    database="hcpgestao_processo_seletivo"
)

# Cursor para executar comandos SQL
cursor = conn.cursor()

# Aumentar o limite do GROUP_CONCAT
cursor.execute("SET SESSION group_concat_max_len = 1000000;")

# Construir a consulta dinâmica para definir @sql
cursor.execute("""
    SELECT GROUP_CONCAT(
        'SELECT
            id,
            "', table_name, '" AS nome_tabela,
            vaga, nome, cpf,
            data_inscricao,
            status_avaliacao,
            data_avaliacao,
            status_entrevista,
            data_entrevista,
            status_resultado
        FROM ', table_name
        SEPARATOR ' UNION ALL '
    )
    FROM information_schema.tables
    WHERE table_schema = DATABASE()
    AND table_name LIKE 'processo_seletivo_%'
    AND table_name NOT IN ('processo_seletivo', 'processo_seletivo_info', 'processo_seletivo_nome')
""")
sql_result = cursor.fetchone()
final_query = sql_result[0] if sql_result else None

# Verificar se a consulta foi construída
if final_query:
    final_query += ' ORDER BY data_inscricao DESC;'
    
    # Verificar se a view já existe
    cursor.execute("SHOW TABLES LIKE 'vw_processo_seletivo_conteudo'")
    view_exists = cursor.fetchone()
    
    if view_exists:
        # Atualizar a view se já existir
        create_view_query = "CREATE OR REPLACE VIEW vw_processo_seletivo_conteudo AS " + final_query
        cursor.execute(create_view_query)
        conn.commit()
        print("View 'vw_processo_seletivo_conteudo' foi atualizada com sucesso.")
    else:
        # Criar a view se não existir
        create_view_query = "CREATE VIEW vw_processo_seletivo_conteudo AS " + final_query
        cursor.execute(create_view_query)
        conn.commit()
        print("View 'vw_processo_seletivo_conteudo' foi criada com sucesso.")
else:
    print("Não foi possível construir a consulta para a view.")

# Fechar cursor e conexão
cursor.close()
conn.close()