Arquitectura del PDO Pool
Este articulo describe el diseno interno del PDO Pool. Si busca una guia de uso, consulte PDO Pool: Pool de Conexiones.
Arquitectura de Dos Niveles
El PDO Pool consta de dos capas:
1. Nucleo PDO (pdo_pool.c) -- logica para vincular conexiones a corrutinas, gestion de transacciones, conteo de referencias de sentencias.
2. Async Pool (zend_async_pool_t) -- el pool universal de recursos de la extension asincrona. Gestiona la cola de conexiones libres, limites y healthchecks. No sabe nada sobre PDO -- trabaja con valores zval abstractos.
Esta separacion permite usar el mismo mecanismo de pooling para cualquier recurso, no solo bases de datos.
Diagrama de Componentes
Conexion Plantilla
Al crear un PDO con pool, el nucleo no abre una conexion TCP real. En su lugar, se crea una plantilla -- un objeto pdo_dbh_t que almacena el DSN, nombre de usuario, contrasena y una referencia al driver. Todas las conexiones reales se crean despues, bajo demanda, basandose en esta plantilla.
Para la plantilla, se llama a db_handle_init_methods() en lugar de db_handle_factory(). Este metodo establece la tabla de metodos del driver (dbh->methods) pero no crea una conexion TCP ni asigna driver_data.
Ciclo de Vida de la Conexion
Creacion de una Conexion desde el Pool (Secuencia)
API Interno
pdo_pool.c -- Funciones Publicas
| Funcion | Proposito |
|---|---|
pdo_pool_create() | Crea un pool para pdo_dbh_t basado en atributos del constructor |
pdo_pool_destroy() | Libera todas las conexiones, cierra el pool, limpia la tabla hash |
pdo_pool_acquire_conn() | Devuelve una conexion para la corrutina actual (reutilizacion o adquisicion) |
pdo_pool_peek_conn() | Devuelve la conexion vinculada sin acquire (NULL si no hay ninguna) |
pdo_pool_maybe_release() | Devuelve la conexion al pool si no hay transaccion ni sentencias |
pdo_pool_get_wrapper() | Devuelve el objeto PHP Async\Pool para el metodo getPool() |
pdo_pool.c -- Callbacks Internos
| Callback | Cuando se Llama |
|---|---|
pdo_pool_factory() | El pool necesita una nueva conexion (acquire cuando el pool esta vacio) |
pdo_pool_destructor() | El pool destruye una conexion (al cerrar o desalojar) |
pdo_pool_healthcheck() | Verificacion periodica -- la conexion sigue viva? |
pdo_pool_before_release() | Antes de devolver al pool -- rollback de transacciones no confirmadas |
pdo_pool_free_conn() | Cierra la conexion del driver, libera memoria |
Vinculacion a una Corrutina
Las conexiones se vinculan a corrutinas mediante una tabla hash pool_connections, donde la clave es el identificador de la corrutina y el valor es un puntero a pdo_dbh_t.
El identificador de la corrutina se calcula mediante la funcion pdo_pool_coro_key():
- Si la corrutina es un objeto PHP -- se usa
zend_object.handle(uint32_t secuencial) - Para corrutinas internas -- la direccion del puntero desplazada por
ZEND_MM_ALIGNMENT_LOG2
Limpieza al Finalizar la Corrutina
Cuando una conexion se vincula a una corrutina, se registra un pdo_pool_cleanup_callback a traves de coro->event.add_callback(). Cuando la corrutina finaliza (normalmente o con error), el callback devuelve automaticamente la conexion al pool. Esto garantiza que no haya fugas de conexiones incluso con excepciones no manejadas.
Fijacion: Bloqueo de Conexion
Una conexion se fija a una corrutina y no volvera al pool si se cumple al menos una condicion:
conn->in_txn == true-- una transaccion activaconn->pool_slot_refcount > 0-- hay sentencias activas (PDOStatement) usando esta conexion
El refcount se incrementa cuando se crea una sentencia y se decrementa cuando se destruye. Cuando ambas condiciones se despejaron, pdo_pool_maybe_release() devuelve la conexion al pool.
Gestion de Credenciales en la Factoria
Al crear una nueva conexion, pdo_pool_factory() copia las cadenas de DSN, nombre de usuario y contrasena desde la plantilla via estrdup(). Esto es necesario porque los drivers pueden mutar estos campos durante db_handle_factory():
- PostgreSQL -- reemplaza
;con espacios endata_source - MySQL -- asigna
username/passworddesde el DSN si no fueron proporcionados - ODBC -- reconstruye completamente
data_source, incrustando credenciales
Despues de una llamada exitosa a db_handle_factory(), las copias se liberan via efree(). En caso de error, la liberacion ocurre a traves de pdo_pool_free_conn(), que tambien es utilizado por el destructor del pool.
Incompatibilidad con Conexiones Persistentes
Las conexiones persistentes (PDO::ATTR_PERSISTENT) son incompatibles con el pool. Una conexion persistente esta vinculada al proceso y sobrevive entre solicitudes, mientras que el pool crea conexiones a nivel de solicitud con gestion automatica del ciclo de vida. Intentar habilitar ambos atributos simultaneamente resultara en un error.
Que Sigue?
- PDO Pool: Pool de Conexiones -- guia de uso
- Corrutinas -- como funcionan las corrutinas
- Scope -- gestion de grupos de corrutinas