DataSource en Jakarta EE

Para que nuestra aplicación Jakarta EE tenga conexión a la base de datos, debemos configurar un DataSource. No debemos usar la clase java.sql.DriverManager, es decir, la conexión nativa a JDBC, sino, debemos usar lo que ofrece el servidor Jakarta EE. Aquí mostraremos dos maneras: configurando el DataSource en la misma aplicación, y configurando en el Servidor Jakarta EE.

Configurando en la Aplicación

Existen dos maneras de configurar el DataSource desde la aplicación. Si usas una aplicación web, usas el web.xml y sino puedes usas crear una clase con la notación @DataSourceDefinition

Usando `web.xml`

La notación en el archivo web.xml es así:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="https://jakarta.ee/xml/ns/jakartaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="https://jakarta.ee/xml/ns/jakartaee https://jakarta.ee/xml/ns/jakartaee/web-app_5_0.xsd"
         version="5.0">
    <data-source>
        <name>java:app/jdbc/sakila</name>
        <class-name>com.mysql.cj.jdbc.MysqlDataSource</class-name>
        <url>jdbc:mysql://localhost:23306/sakila
        <</url>
        <user>sakila</user>
        <password>sakila</password>
        <property>
            <name>allowPublicKeyRetrieval</name>
            <value>true</value>
        </property>
        <property>
            <name>serverTimezone</name>
            <value>America/Lima</value>
        </property>
        <property>
            <name>useSSL</name>
            <value>false</value>
        </property>
    </data-source>
</web-app>

Asumiendo que se usa MySQL 8, se deben agregar ciertas propiedades como los que están al final

Usando `@DataSourceDefinition`

En esta manera se debe crear una clase y definir la anotación como sigue:

import jakarta.annotation.sql.DataSourceDefinition;
import jakarta.enterprise.context.ApplicationScoped;

@DataSourceDefinition(
        name = "java:app/jdbc/sakila",
        className = "com.mysql.cj.jdbc.MysqlDataSource",
        databaseName = "sakila",
        user = "sakila",
        password = "sakila",
        portNumber = 23306,
        properties = {
                "allowPublicKeyRetrieval=true",
                "serverTimezone=America/Lima",
                "useSSL=false"
        }

)
@ApplicationScoped
public class DataSourceProvider {
//..
}

En ambos casos se está creando un DataSource con nombre java:app/jdbc/sakila y se puede consumir de la siguiente manera:

@ApplicationScoped
public class DataSourceProvider {

    @jakarta.enterprise.inject.Produces
    @Resource(lookup = "java:app/jdbc/sakila")
    private DataSource dataSource;
}

Y en adelante, solo lo podríamos reutilizar con un @Inject, por ejemplo:

@ApplicationScoped
public class CityService {
    @Inject
    private DataSource dataSource;

    public List<CityDTO> getCitiesList() {
        List<CityDTO> citiesList = new ArrayList<>();
        try (Connection conn = dataSource.getConnection()) {
            try (Statement stmt = conn.createStatement()) {
                try (ResultSet rs = stmt.executeQuery("select  * from city")) {
                    while (rs.next()) {
                        citiesList.add(new CityDTO(rs.getInt("city_id"), rs.getString("city")));

                    }
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return citiesList;
    }
}

Configurando en el servidor Jakarta EE

Para este ejemplo usaríamos Payara Server o GlassFish

Consola Web admin

El paso más largo es hacer visualmente siguiendo los pasos para crear tanto el Pool, como el Recurso. En el vídeo se puede ver mejor.

Comandos `create-jdbc-connection-pool` y `create-jdbc-resource`

Estos comandos pueden ser un script que se pueden ejecutar desde el asadmin. Tienen todos los parámetros que van para crear tanto el pool como el recurso:

create-jdbc-connection-pool --ping=true --pooling=true --restype=javax.sql.DataSource --datasourceclassname=com.mysql.cj.jdbc.MysqlDataSource --property user=sakila:password=sakila:serverName=localhost:port=23306:databaseName=sakila:allowPublicKeyRetrieval=true:serverTimezone=America/Lima:useSSL=false SakilaPool

create-jdbc-resource --connectionpoolid SakilaPool jdbc/sakila

XML de recursos + comando `add-resources`

Otra manera es crear un archivo .xml con la configuración de todos los parámetros del Pool y del Recurso y ejecutarlo desde el asadmin con el comando add-resources. Este es un ejemplo del archivo resources.xml:

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<resources>
    <jdbc-resource jndi-name="jdbc/sakila" pool-name="SakilaPool"/>
    <jdbc-connection-pool datasource-classname="com.mysql.cj.jdbc.MysqlDataSource" name="SakilaPool" resType="javax.sql.DataSource">
        <property name="url" value="jdbc:mysql://localhost:23306/sakila"/>
        <property name="user" value="sakila"/>
        <property name="password" value="sakila"/>
        <property name="allowPublicKeyRetrieval" value="true"/>
        <property name="serverTimezone" value="America/Lima"/>
        <property name="useSSL" value="false"/>
    </jdbc-connection-pool>
</resources>

En ambos casos, se está creando el recurso con el nombre jdbc/sakila y la manera de consumirlo es:

@ApplicationScoped
public class DataSourceProvider {

    @jakarta.enterprise.inject.Produces
    @Resource(lookup = "jdbc/sakila")
    private DataSource dataSource;
}

Y todo sigue igual

Vídeo

El vídeo con más detalle se encuentra aquí.

بحث هذه المدونة الإلكترونية

Apuntes de Java