Como manejar dos bases de datos distintas con Hibernate
Índice de contenidos
1. Introducción
2. Entorno
3. Hibernate con más de una base de datos
4. Probando la clase de ayuda
5. Conclusiones
1. Introducción
En ciertas ocasiones nos vemos obligados a manejar en una aplicación más de una base de datos diferente.
En este tutorial vamos a exponer una clase de ayuda para poder gestionar esta situación con Hibernate.
2. Entorno
El tutorial está escrito usando el siguiente entorno:
- Hardware: Portátil Ahtex Signal X-9500M (Centrino 1.6 GHz, 1024 MB RAM, 60 GB HD).
- Sistema Operativo: GNU / Linux, Debian Sid (unstable), Kernel 2.6.11, KDE 3.4
- Máquina Virtual Java: JDK 1.5.0_03 de Sun Microsystems
- Hibernate 3.0 (http://www.hibernate.org)
3. Hibernate con más de una base de datos
En principio no hay ningún problema para poder gestionar mas de una base de datos con Hibernate.
En Hibernate podemos tener mas de un fichero de configuración, siendo el fichero de configuración por defecto “hibernate.cfg.xml”. Cada fichero de configuración puede representar una conexión a una base de datos distinta, y por supuesto cada fichero de configuración hará referencia a los ficheros de mapeo correspondientes para las tablas de cada base de datos.
La clase que vamos a presentar a continuación pretende facilitar la gestión de está situación, consiguiendo de forma sencilla sesiones de Hibernate a cada una de las bases de datos.
Además la clase se encarga de asegurar que la sesión de Hibernate es única por Thread. Esto puede resultar muy conveniente en aplicaciones multithread o en aplicaciones Web donde múltiples clientes acceden de forma simultánea.
El código de la clase es el siguiente:
|
1 |
package com.autentia.tool;</code> <code>import java.util.HashMap;</code> <code>import java.util.Map;</code> <code>import org.hibernate.HibernateException;</code> <code>import org.hibernate.Session;</code> <code>import org.hibernate.SessionFactory;</code> <code>import org.hibernate.cfg.Configuration;</code> <code>/**</code> <code> * Clase de utilidad para conseguir la sesión de Hibernate.</code> <code> * La sesión es única por thread.</code> <code> * Pueden existir varios ficheros de configuración.</code> <code> * Al menos siempre existirá la configuración por defecto sacada del fichero "hibernate.cfg.xml".</code> <code> * </code> <code> * @author Autentia</code> <code> */</code> <code>public class HibernateMultipleConfig {</code> <code> /** Clave para acceder a la sesión por defecto, esta sesión se obtiene a partir del fichero de configuración "hibernate.cfg.xml". */</code> <code> public static final String DEFAULT = "default";</code> <code> /** Mapa donde se guardan los SessionFactory para cada uno de los ficheros de configuración. */</code> <code> private static final Map<String, SessionFactory> sessionFactorys = new HashMap();</code> <code> /** Atributo único por threat donde se guardan las sesiones para cada uno de los ficheros de configuración. */</code> <code> private static final ThreadLocal<Map<String, Session>> sessions = new ThreadLocal>();</code> <code> static {</code> <code> try {</code> <code> // Create the DEFAULT SessionFactory from hibernate.cfg.xml</code> <code> SessionFactory sessionFactory = new Configuration().configure().buildSessionFactory();</code> <code> sessionFactorys.put(DEFAULT, sessionFactory);</code> <code> } catch (Throwable e) {</code> <code> // Make sure you log the exception, as it might be swallowed</code> <code> System.err.println("Initial SessionFactory creation failed." + e);</code> <code> throw new ExceptionInInitializerError(e);</code> <code> }</code> <code> // Creamos el mapa donde se guardará la sesión para cada una de las configuraciones.</code> <code> // Este mapa lo guardamos en el atributo sessions, que nos asegura que el mapa es único por thread.</code> <code> sessions.set(new HashMap<String, Session>());</code> <code> }</code> <code> /**</code> <code> * Añade un nuevo fichero de configuración, creando el SessionFactory correspondiente.</code> <code> * Para encontrar el fichero de configuración, este debe encontrarse en el classpath,</code> <code> * junto al fichero de configuración por defecto de hibernate "hibernate.cfg.xml". </code> <code> * </code> <code> * @param fileName nombre del fichero de configuración que se quiere añadir.</code> <code> * @param key clave con la que se hará referencia a esta configuración en las siguientes llamadas.</code> <code> * @throws HibernateException si no se puede crear el SessionFactory basado en el fichero que se pasa como</code> <code> * argumento.</code> <code> */</code> <code> public static void addConfigFile(String fileName, String key) throws HibernateException {</code> <code> SessionFactory sessionFactory = new Configuration().configure(fileName).buildSessionFactory();</code> <code> sessionFactorys.put(key, sessionFactory);</code> <code> }</code> <code> /**</code> <code> * Devuelve la sesión, para el thread que hace la llamada. Es decir cada thread tiene su propia sesión.</code> <code> * </code> <code> * @param key clave que identifica la sesión a la que se quiere acceder.</code> <code> * @return sesión por defecto, para el thread que hace la llamada.</code> <code> * @throws HibernateException</code> <code> */</code> <code> public static Session currentSession(String key) throws HibernateException {</code> <code> Map<String, Session> ss = sessions.get();</code> <code> Session s = ss.get(key);</code> <code> // Abre una nueva sesión si este thread todavía no tiene ninguna</code> <code> if (s == null) {</code> <code> s = sessionFactorys.get(key).openSession();</code> <code> ss.put(key, s);</code> <code> }</code> <code> return s;</code> <code> }</code> <code> /**</code> <code> * Cierra la sesión, para el thread que hace la llamada.</code> <code> * </code> <code> * @param key clave que identifica la sesión que se quiere cerrar.</code> <code> * @throws HibernateException</code> <code> */</code> <code> public static void closeSession(String key) throws HibernateException {</code> <code> Map<String, Session> ss = sessions.get();</code> <code> Session s = ss.get(key);</code> <code> if (s != null) {</code> <code> s.close();</code> <code> ss.put(key, null);</code> <code> }</code> <code> }</code> <code> /**</code> <code> * Devuelve la sesión por defecto, para el thread que hace la llamada.</code> <code> * Es decir cada thread tiene su propia sesión.</code> <code> * </code> <code> * @return sesión por defecto, para el thread que hace la llamada.</code> <code> * @throws HibernateException</code> <code> */</code> <code> public static Session currentSession() throws HibernateException {</code> <code> return currentSession(DEFAULT);</code> <code> }</code> <code> /**</code> <code> * Cierra la sesión por defecto, para el thread que hace la llamada.</code> <code> * </code> <code> * @throws HibernateException</code> <code> */</code> <code> public static void closeSession() throws HibernateException {</code> <code> closeSession(DEFAULT);</code> <code> }</code> <code>} |
Este código está basado en la clase de ayuda propuesta por la documentación de Hibernate en:
http://www.hibernate.org/hib_docs/v3/reference/en/html/tutorial.html#tutorial-firstapp-helpers
4. Probando la clase de ayuda
Aquí proponemos un pequeño ejemplo para probar la clase de ayuda:
|
1 |
import org.hibernate.Session;</code> <code>import com.autentia.tool.HibernateMultipleConfig;</code> <code>public class TestHibernateMultipleConfig {</code> <code> public static void main(String[] args) {</code> <code> // Añadimos un nuevo fichero de configuración,</code> <code> // a parte de la configuración por defecto obtenida del fichero "hibernate.cfg.xml".</code> <code> // Primero indico el nombre del fichero de configuración,</code> <code> // y luego la clave por la que haré referencia a esa configuración.</code> <code> // Esto sólo habría que hacerlo una vez, en una fase de inicialización de la aplicación.</code> <code> HibernateMultipleConfig.addConfigFile("miOtraConfiguracion.hibernate.cfg.xml", "otraConfiguracion");</code> <code> </code> <code> </code> <code> </code> <code> // Trabajamos con la sesión por defecto de hibernate.</code> <code> // La sesión por defecto se obtiene del fichero "hibernate.cfg.xml".</code> <code> Session defaultSession = HibernateMultipleConfig.currentSession();</code> <code> // ...</code> <code> </code> <code> HibernateMultipleConfig.closeSession();</code> <code> </code> <code> </code> <code> </code> <code> </code> <code> // Trabajamos con una sesión concreta de hibernate.</code> <code> // La sesión se obtendrá a partir de la clave que se pasa como parámetro.</code> <code> Session aSession = HibernateMultipleConfig.currentSession("otraConfiguracion");</code> <code> </code> <code> // ...</code> <code> </code> <code> HibernateMultipleConfig.closeSession("otraConfiguracion");</code> <code> }</code> <code>} |
5. Conclusiones
Esta clase no pretende ser perfecta ni la solución definitiva (si encontráis algún bug decírmelo ;), pero si pretende ser un buen punto de partida para la gestión de múltiples bases de datos con Hibernate.
Seguramente un buen punto a mejorar es como se cierran las sesiones. Habría que intentar facilitar un poco más la vida al desarrollador, de forma que pudiera hacer algo como “aSession.close()” y ya se realizara toda la gestión (os lo dejo como deberes). En cualquier caso no os olvidéis nunca de cerrar las sesiones (y en general de cerrar cualquier recurso: conexiones, streams, …).
Espero que os sirva de ayuda, y nos vemos en el próximo tutorial.
