+++ /dev/null
-/*
- * $Id: HibernateSessionManager.java,v 1.1 2004/11/06 16:20:48 idfx Exp $
- *
- * Copyright (C) 2001, 2002, 2003, 2004 The Mir-coders group
- *
- * This file is part of Mir.
- *
- * Mir is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * Mir is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with Mir; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
- *
- * In addition, as a special exception, The Mir-coders gives permission to link
- * the code of this program with any library licensed under the Apache Software License,
- * The Sun (tm) Java Advanced Imaging library (JAI), The Sun JIMI library
- * (or with modified versions of the above that use the same license as the above),
- * and distribute linked combinations including the two. You must obey the
- * GNU General Public License in all respects for all of the code used other than
- * the above mentioned libraries. If you modify this file, you may extend this
- * exception to your version of the file, but you are not obligated to do so.
- * If you do not wish to do so, delete this exception statement from your version.
- */
-package org.codecoop.mir.core.dao.hibernate;
-
-import net.sf.hibernate.HibernateException;
-import net.sf.hibernate.Interceptor;
-import net.sf.hibernate.Session;
-import net.sf.hibernate.SessionFactory;
-import net.sf.hibernate.cfg.Configuration;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.codecoop.mir.core.dao.DatabaseFailure;
-
-/**
- * HibernateUtil
- *
- * @author idefix
- * @version $Revision: 1.1 $
- */
-class HibernateSessionManager {
-
- private static Log log = LogFactory.getLog(HibernateSessionManager.class);
-
- private static Configuration configuration;
- private static SessionFactory sessionFactory;
- private static final ThreadLocal threadSession = new ThreadLocal();
- private static final ThreadLocal threadInterceptor = new ThreadLocal();
-
- // Create the initial SessionFactory from the default configuration files
- static {
- try {
- configuration = new Configuration();
- sessionFactory = configuration.configure().buildSessionFactory();
- log.debug("SessionFactory built.");
- } catch (Throwable ex) {
- log.error("Building SessionFactory failed.", ex);
- throw new ExceptionInInitializerError(ex);
- }
- }
-
- /**
- * Returns the SessionFactory used for this static class.
- *
- * @return SessionFactory
- */
- static SessionFactory getSessionFactory() {
- return sessionFactory;
- }
-
- /**
- * Returns the original Hibernate configuration.
- *
- * @return Configuration
- */
- static Configuration getConfiguration() {
- return configuration;
- }
-
- /**
- * Rebuild the SessionFactory with the static Configuration.
- *
- */
- static void rebuildSessionFactory() throws DatabaseFailure {
- synchronized (sessionFactory) {
- try {
- sessionFactory = getConfiguration().buildSessionFactory();
- } catch (Exception ex) {
- throw new DatabaseFailure(ex);
- }
- }
- }
-
- /**
- * Rebuild the SessionFactory with the given Hibernate Configuration.
- *
- * @param cfg
- */
- static void rebuildSessionFactory(Configuration cfg) throws DatabaseFailure {
- synchronized (sessionFactory) {
- try {
- sessionFactory = cfg.buildSessionFactory();
- configuration = cfg;
- } catch (Exception ex) {
- throw new DatabaseFailure(ex);
- }
- }
- }
-
- /**
- * Retrieves the current Session local to the thread. <p/>If no Session is
- * open, opens a new Session for the running thread.
- *
- * @return Session
- */
- static Session getSession() throws DatabaseFailure {
- Session s = (Session) threadSession.get();
- try {
- if (s == null) {
- log.debug("Opening new Session for this thread.");
- if (getInterceptor() != null) {
- log.debug("Using interceptor: " + getInterceptor().getClass());
- s = getSessionFactory().openSession(getInterceptor());
- } else {
- s = getSessionFactory().openSession();
- }
- threadSession.set(s);
- }
- } catch (HibernateException ex) {
- throw new DatabaseFailure(ex);
- }
- return s;
- }
-
- /**
- * Closes the Session local to the thread.
- */
- static void closeSession() throws DatabaseFailure {
- try {
- Session s = (Session) threadSession.get();
- threadSession.set(null);
- if (s != null && s.isOpen()) {
- log.debug("Closing Session of this thread.");
- s.close();
- }
- } catch (HibernateException ex) {
- throw new DatabaseFailure(ex);
- }
- }
-
- /**
- * Reconnects a Hibernate Session to the current Thread.
- *
- * @param session
- * The Hibernate Session to be reconnected.
- */
- static void reconnect(Session session) throws DatabaseFailure {
- try {
- session.reconnect();
- threadSession.set(session);
- } catch (HibernateException ex) {
- throw new DatabaseFailure(ex);
- }
- }
-
- /**
- * Disconnect and return Session from current Thread.
- *
- * @return Session the disconnected Session
- */
- static Session disconnectSession() throws DatabaseFailure {
-
- Session session = getSession();
- try {
- threadSession.set(null);
- if (session.isConnected() && session.isOpen())
- session.disconnect();
- } catch (HibernateException ex) {
- throw new DatabaseFailure(ex);
- }
- return session;
- }
-
- /**
- * Register a Hibernate interceptor with the current thread.
- * <p>
- * Every Session opened is opened with this interceptor after registration.
- * Has no effect if the current Session of the thread is already open,
- * effective on next close()/getSession().
- */
- static void registerInterceptor(Interceptor interceptor) {
- threadInterceptor.set(interceptor);
- }
-
- private static Interceptor getInterceptor() {
- Interceptor interceptor = (Interceptor) threadInterceptor.get();
- return interceptor;
- }
-
-}
-
projects / mir.git / blobdiff