Conectar con un transactor

Doobie es una capa JDBC funcional pura para Scala. Un Transactor[F] conecta los programas puros de Doobie con una conexión real a la base de datos.

Un Transactor sabe cómo adquirir una Connection JDBC, ejecutar su programa dentro de una transacción y liberar los recursos de forma segura.

Está parametrizado por un tipo de efecto F[_], como cats.effect.IO.

Las consultas de Doobie son valores de tipo ConnectionIO[A]. Describen un cálculo que necesita una conexión JDBC, pero todavía no se ejecutan.

Puede construir estos programas de forma pura y, después, entregárselos a un Transactor para ejecutarlos. La base de datos no se toca hasta que se ejecuta el programa.

El Transactor más sencillo es Transactor.fromDriverManager. Abre una conexión completamente nueva para cada transacción mediante el DriverManager de JDBC.

Necesita el nombre de la clase del driver, la URL JDBC, el nombre de usuario y la contraseña. Es adecuado para pruebas y scripts, pero no dispone de un pool de conexiones.

Para ejecutar un ConnectionIO, llame a .transact(xa). Esto produce un F[A], en este caso un IO[A].

El Transactor envuelve el programa en una transacción: confirma los cambios si tiene éxito y revierte la transacción si falla, liberando la conexión en ambos casos.

En producción necesitará un pool de conexiones. Doobie incluye HikariTransactor, respaldado por HikariCP.

Se crea como un Resource para que el pool se cierre correctamente. También debe proporcionar un contexto de ejecución para las operaciones JDBC bloqueantes.

Un Transactor con pool posee estado de larga duración: conexiones abiertas e hilos en segundo plano. Resource[F, A] garantiza que la adquisición y la liberación estén emparejadas incluso si se producen errores o cancelaciones.

Normalmente se construye el Transactor una vez al iniciar la aplicación y se reutiliza durante toda su vida útil.

HikariCP necesita un ExecutionContext para esperar conexiones del pool. Doobie proporciona ExecutionContexts.fixedThreadPool para este fin, que también es un Resource.

Mantenerlo separado del pool de cómputo evita que la adquisición bloqueante de conexiones deje sin recursos al trabajo limitado por la CPU.

Si ya dispone de un javax.sql.DataSource configurado (por ejemplo, una instancia de Hikari ajustada), envuélvalo directamente con Transactor.fromDataSource.

Esto es habitual cuando un framework administra el pool y solo desea que Doobie lo utilice.

Una comprobación de estado sencilla consiste en ejecutar select 1 mediante el Transactor. Si devuelve un resultado, el driver, la URL y las credenciales funcionan correctamente.

Es un buen primer paso antes de conectar consultas reales.

Un Transactor se construye a partir de intérpretes y una Strategy. La Strategy controla lo que ocurre alrededor de cada transacción: before, after, oops (en caso de error) y always.

La estrategia predeterminada desactiva el commit automático, confirma los cambios tras el éxito, revierte la transacción si hay un error y cierra siempre la conexión.

Doobie puede registrar cada sentencia, sus argumentos y sus tiempos. Las versiones modernas asocian un LogHandler[F] a cada consulta en lugar de a cada Transactor.

Esto resulta esencial para detectar consultas lentas y verificar la vinculación de parámetros en producción.

Compruebe su comprensión de los Transactors.

Un Transactor[F] conecta programas puros ConnectionIO con una base de datos real. fromDriverManager es adecuado para pruebas; HikariTransactor y fromDataSource son apropiados para producción mediante pooling.

Construya los Transactors con pool como un Resource, ejecute los programas con .transact(xa) y deje que la Strategy predeterminada gestione la confirmación, la reversión y la limpieza.