Z-Archive » Maybank Projects » M2U UPASS Project

 			<groupId>org.hibernate</groupId>

 			<artifactId>hibernate-core</artifactId>

 			<version>3.3.1.GA</version>

 			<type>jar</type>

 			<scope>compile</scope>

 		</dependency>

/**

 * Copyright (M) 2009 Penril Datability (M) Sdn Bhd All rights reserved.

 *

 * This software is copyrighted. Under the copyright laws, this software

 * may not be copied, in whole or in part, without prior written consent

 * of Penril Datability (M) Sdn Bhd or its assignees. This software is

 * provided under the terms of a license between Penril Datability (M)

 * Sdn Bhd and the recipient, and its use is subject to the terms of that

 * license.

 */

package net.penril.generic.hibernate;

import java.io.Serializable;

import java.util.List;

/**

 * PROGRAMMER: Danniell

 * CHANGE-NO:

 * TASK-NO:

 * DATE CREATED: Oct 27, 2010

 * TAG AS:

 * REASON(S):

 * MODIFICATION:

 */

/**

 * Represents Base Data Access Object

 */

public interface GenericDAO

{

	Object findById(Serializable id, boolean lock) throws Exception;

	List findAll()throws Exception;

	List findByExample(Object exampleInstance, String[] excludeProperty)throws Exception;

	Object makePersistent(Object entity)throws Exception;

	void makeTransient(Object entity)throws Exception;

	void flush()throws Exception;

	void clear()throws Exception;

	long getNextSequenceNumber(String sequenceName) throws Exception;

	long getCurrentSequenceNumber(String sequenceName) throws Exception;

}

/**

 * Copyright (M) 2009 Penril Datability (M) Sdn Bhd All rights reserved.

 *

 * This software is copyrighted. Under the copyright laws, this software

 * may not be copied, in whole or in part, without prior written consent

 * of Penril Datability (M) Sdn Bhd or its assignees. This software is

 * provided under the terms of a license between Penril Datability (M)

 * Sdn Bhd and the recipient, and its use is subject to the terms of that

 * license.

 */

package net.penril.generic.hibernate;

import java.io.Serializable;

import java.lang.reflect.ParameterizedType;

import java.math.BigDecimal;

import java.sql.CallableStatement;

import java.sql.Connection;

import java.sql.DatabaseMetaData;

import java.sql.SQLException;

import java.util.List;

import org.hibernate.Criteria;

import org.hibernate.LockMode;

import org.hibernate.Session;

import org.hibernate.Transaction;

import org.hibernate.criterion.Criterion;

import org.hibernate.criterion.Example;

public abstract class GenericDAOHibernate implements GenericDAO 

{

	private Class persistentClass;

	private Session session;

	public GenericDAOHibernate() 

	{

		this.persistentClass = (Class)((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];

	}

	public void setSession(Session s) 

	{

		this.session = s;

	}

	/**

	 * 

	 * Will override the current session

	 *

	 * @param hibernateCfgPath The Hibernate configuration file path

	 */

	public void setSession(String hibernateCfgPath) 

	{

		HibernateUtils.overrideSession (hibernateCfgPath);

		this.session = HibernateUtils.currentSession ();

	}

	protected Session getSession() throws Exception 

	{

		if (session == null || session.isOpen () == false)

		{

			try

			{

				session = HibernateUtils.currentSession();

			}

			catch(Exception e)

			{

				throw e;

			}

		}

		return session;

	}

	public Class getPersistentClass() 

	{

		return persistentClass;

	}

	public void clear() throws Exception 

	{

		getSession ().clear ();

	}

	public List findAll() throws Exception 

	{

		return findByCriteria(null);

	}

	protected List findByCriteria (Criterion[] criterion) throws Exception

	{

		Criteria crit = getSession().createCriteria(getPersistentClass());

		if(criterion != null)

		{

			for(int i=0; i<criterion.length; i++){

				crit.add(criterion[0]);

			}

		}

		return crit.list();

	}

	public List findByExample(Object exampleInstance, String[] excludeProperty) throws Exception 

	{

		Criteria crit = getSession().createCriteria(getPersistentClass());

		Example example = Example.create(exampleInstance);

		for(int i=0; i<excludeProperty.length; i++){

			example.excludeProperty(excludeProperty[0]);

		}

		crit.add(example);

		return crit.list();

	}

	public Object findById(Serializable id, boolean lock) throws  Exception 

	{

		Object entity;

		if (lock)

		{

			entity = getSession().get(getPersistentClass(), id, LockMode.UPGRADE);

		}

		else

		{

			entity = getSession().get(getPersistentClass(), id);

		}

		return entity;

	}

	public void flush() throws  Exception 

	{

		getSession ().flush ();

	}

	public Object makePersistent(Object entity) throws  Exception 

	{

		getSession().saveOrUpdate(entity);

		return entity;

	}

	public void makeTransient(Object entity) throws  Exception 

	{

		getSession().delete(entity);

	}

	public long getNextSequenceNumber(String sequenceName) throws Exception {

		BigDecimal nextValue = new BigDecimal(0);

		// TODO: Don't forget to remove the following line!

		System.out.println("########## Retrieving next value for"

				+ " sequence: " + sequenceName);

		Session hSession = getSession();

		Transaction tx = null;

		try {

			Connection conn = hSession.connection();

			DatabaseMetaData metaData = conn.getMetaData();

			String jdbcUrl = metaData.getURL();

			if (jdbcUrl.startsWith("jdbc:oracle")) {

				nextValue = (BigDecimal) hSession.createSQLQuery(

						"select " + sequenceName + ".nextval from dual")

						.uniqueResult();

			} else if (jdbcUrl.startsWith("jdbc:sqlserver")) {

				// TODO: Don't forget to remove the following line!

				System.out

						.println("########## Simulating sequences in SQL Server.");

				tx = hSession.beginTransaction();

				CallableStatement cstmt = conn.prepareCall(//

						"{call nextval_" + sequenceName + "(?)}");

				cstmt.registerOutParameter(1, java.sql.Types.BIGINT);

				cstmt.execute();

				nextValue = cstmt.getBigDecimal(1);

				tx.commit();

			} else

				throw new RuntimeException(

						"The jdbc driver is not in supported.");

		} catch (SQLException e) {

			if (tx != null && tx.isActive())

				tx.rollback();

			throw new RuntimeException(e);

		} finally {

			hSession.close();

		}

		long longValue = nextValue.longValue();

		// TODO: Don't forget to remove the following line!

		System.out.println("########## Last sequence value: " + longValue);

		return longValue;

	}

	public long getCurrentSequenceNumber(String sequenceName) throws Exception {

		BigDecimal currentValue = new BigDecimal(0);

		// TODO: Don't forget to remove the following line!

		System.out.println("########## Retrieving current value for"

				+ " sequence: " + sequenceName);

		try {

			Connection conn = getSession().connection();

			DatabaseMetaData metaData = conn.getMetaData();

			String jdbcUrl = metaData.getURL();

			if (jdbcUrl.startsWith("jdbc:oracle")) {

				currentValue = (BigDecimal) getSession().createSQLQuery(

						"select " + sequenceName + ".currval from dual")

						.uniqueResult();

			} else if (jdbcUrl.startsWith("jdbc:sqlserver")) {

				currentValue = (BigDecimal) getSession().createSQLQuery(

						"select seq_value from " + sequenceName).uniqueResult();

			} else

				throw new RuntimeException(

						"The jdbc driver is not in supported.");

		} catch (SQLException e) {

			throw new RuntimeException(e);

		} finally {

			getSession().close();

		}

		long longValue = currentValue.longValue();

		// TODO: Don't forget to remove the following line!

		System.out.println("########## Current sequence value: " + longValue);

		return longValue;

	}

}

/**

 * Copyright (c) 2009 Penril Datability (SEA) Sdn Bhd All rights reserved.

 *

 * This software is copyrighted. Under the copyright laws, this software

 * may not be copied, in whole or in part, without prior written consent

 * of Penril Datability (SEA) Sdn Bhd or its assignees. This software is

 * provided under the terms of a license between Penril Datability (SEA)

 * Sdn Bhd and the recipient, and its use is subject to the terms of that

 * license.

 */

package net.penril.generic.hibernate;

import org.hibernate.HibernateException;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.cfg.Configuration;

/**

 * Configures and provides access to Hibernate sessions, tied to the current

 * thread of execution. Follows the Thread Local Session pattern, see {@link http://hibernate.org/42.html}.

 * 

 * <pre>

 *  For this project, all the hibernate configuration file must be at the "/com/ib/ibss/hibernate/configuration/hibernate.cfg.xml".

 *  It is hard coded. Just make sure out the hibernate configuration file at the mentioned path.

 * </pre>

 */

public class HibernateUtils {

	private static final Object CONFIG_LOCK = new Object();

	/**

	 * <pre>

	 * Location of hibernate.cfg.xml file. NOTICE: Location should be on the

	 * classpath as Hibernate uses #resourceAsStream style lookup for its

	 * configuration file. That is place the config file in a Java package - the

	 * default location is the default Java package.

	 * 

	 * Examples:

	 * <code>CONFIG_FILE_LOCATION = "/hibernate.conf.xml". 

	 * CONFIG_FILE_LOCATION = "/com/foo/bar/myhiberstuff.conf.xml".</code>

	 * 

	 * For this project, all the hibernate configuration file must be at the "/com/ib/ibss/hibernate/configuration/hibernate.cfg.xml".

	 * It is hard coded. Just make sure out the hibernate configuration file at the mentioned path.

	 * </pre>

	 */

	private static String CONFIG_FILE_LOCATION = "/com/ib/hibernate/configuration/hibernate.cfg.xml";

	private static Configuration cfg = null;

	private static SessionFactory sessionFactory = null;

	private static ThreadLocal session = null;

	/**

	 * To create a new session

	 */

	private static void init() {

		synchronized (CONFIG_LOCK) {

			if (session == null) {

				/** The single instance of hibernate configuration */

				cfg = new Configuration();

				/** The single instance of hibernate SessionFactory */

				sessionFactory = cfg.configure(CONFIG_FILE_LOCATION).buildSessionFactory();

				/** Holds a single instance of Session */

				session = new ThreadLocal();

			}

		}

	}

	/**

	 * 

	 * Override the current session if already exist. If not, create a new session.

	 * 

	 * @param p

	 */

	public static void overrideSession(String p) {

		synchronized (CONFIG_LOCK) {

			/** The single instance of hibernate configuration */

			cfg = new Configuration();

			/** The single instance of hibernate SessionFactory */

			sessionFactory = cfg.configure(p).buildSessionFactory();

			/** Holds a single instance of Session */

			session = new ThreadLocal();

		}

	}

	/**

	 * Returns the ThreadLocal Session instance. Lazy initialize the <code>SessionFactory</code> if needed.

	 * Will instantiate the hibernate session if not exist.

	 * 

	 * @return Session The hirbernate session.

	 * @throws HibernateException

	 */

	public static Session currentSession() throws HibernateException {

		init();

		Session m_oSession = (Session) session.get();

		// Open a new Session, if this Thread has none yet

		if (m_oSession == null || (m_oSession != null && !m_oSession.isConnected())) {

			try {

				m_oSession = sessionFactory.openSession();

				session.set(m_oSession);

			} catch (Throwable ex) {

				// Make sure you log the exception, as it might be swallowed

				throw new ExceptionInInitializerError(ex);

			}

		}

		return m_oSession;

	}

	/**

	 * Close the single hibernate session instance.

	 * 

	 * @throws HibernateException

	 */

	public static void closeSession() throws HibernateException {

		Session m_oSession = (Session) session.get();

		session.set(null);

		if (m_oSession != null) {

			m_oSession.close();

		}

	}

}