# ../config/cnxpdo.py
import mysql.connector
from mysql.connector import Error

# def get_connection():
#     try:
#         connection = mysql.connector.connect(
#             host="10.51.20.5",
#             user="usermas",
#             password="u2$p1Lg@XY#XUpY2kf",
#             database="data_catastro"
#         )
#         if connection.is_connected():
#             return connection
#     except Error as e:
#         print(f"Error de conexión: {e}")
#         return None

def get_connection():
    try:
        connection = mysql.connector.connect(
            host="catia-dbmysql02.mysql.database.azure.com",
            user="valormas",
            password="A3A9qXf1XEXNY8YG1yds",
            database="data_catastro"
        )
        if connection.is_connected():
            return connection
    except Error as e:
        print(f"Error de conexión: {e}")
        return None