Saltar a contenido

mysql_connect

app.contrib.sqlalchemy.mysql_connect

Módulo de Python para gestionar la conexión a MySQL(pymysql)

Para más información, te recomendamos leer la documentación del Proyecto.

mysql_get_connect()

Obtiene de variables de entorno, los valores para definir una conexión hacia una Base de Datos MySQL.

Raises:

Type Description
DefaultException

excepciones para el manejo de errores personalizados

None

en caso de un error

Returns:

Type Description
Optional[dict[str, Any]]

un diccionario con información de la cadena de conexión, el nombre de la Base de Datos y el prefijo para las colecciones, ó None en caso de error

Examples:

1
2
3
4
from app.contrib.sqlalchemy.mysql_connect import mysql_get_connect
...

mysql_conn = mysql_get_connect()

mysql_connect(ping=False, pool_recycle_time=1800, use_echo=False)

Establece la conexión a MySQL.

Parameters:

Name Type Description Default
ping bool

permite hacer un ping a la Base de Datos, para comprobar el estado de la conexión, por defecto False

False
pool_recycle_time int

este parámetro hace que el pool recicle las conexiones después de que haya pasado el número de segundos dado. Por defecto es de 1800, ó 15 minutos

1800
use_echo bool

MySQL registrará todas las sentencias así como un repr(), la salida por defecto es sys.stdout

False

Raises:

Type Description
DefaultException

excepciones para el manejo de errores personalizados

Exception

fallo al conectarse a la Base de Datos

None

en caso de un error

Returns:

Type Description
Optional[dict[str, Any]]

un diccionario con información del cliente(session), la instancia de la Base de Datos, una instancia de declarative_base y el prefijo para las colecciones, ó None en caso de error

Examples:

1
2
3
4
5
from app.contrib.sqlalchemy.mysql_connect import mysql_connect
...

db = mysql_connect(True)
fastapi.mysql_db = db

mysql_close(conn=None)

Cierra la conexión a una Base de Datos MySQL.

Parameters:

Name Type Description Default
conn Any

la instancia de conexión

None

Examples:

1
2
3
4
5
from app.contrib.sqlalchemy.mysql_connect import mysql_close
...

conn = getattr(fastapp, "mysql_db", None)
mysql_close(conn)