import mysql.connector
from mysql.connector import Error
import json
import datetime
import re
import requests

def crear_conexion(host_name, user_name, user_password, port, db_name):
    try:
        conexion = mysql.connector.connect(
            host=host_name,
            user=user_name,
            passwd=user_password,
            port=port,
            database=db_name
        )
        return conexion
    except Error as e:
        raise Error(f"Error al conectar a MySQL: {e}")

def ejecutar_consulta(conexion, consulta, parametros=None):
    cursor = conexion.cursor()
    try:
        if parametros:
            cursor.execute(consulta, parametros)
        else:
            cursor.execute(consulta)
        if cursor.with_rows:
            return cursor.fetchall()
        else:
            conexion.commit()
    except Error as e:
        raise Error(f"Error al ejecutar la consulta: {e}")