D-Net

package eu.dnetlib.enabling.is.dao;

import java.io.Serializable;

import java.util.List;

import javax.persistence.Table;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.hibernate.Query;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.Transaction;

import eu.dnetlib.enabling.is.hib.objects.HibDnetObject;

import eu.dnetlib.rmi.soap.exceptions.InformationServiceException;

public class DnetSimpleDaoImpl<T extends HibDnetObject> implements DnetSimpleDao<T> {

	private SessionFactory sessionFactory;

	private Class<T> clazz;

	private String table;

	private static final Log log = LogFactory.getLog(DnetSimpleDaoImpl.class);

	public DnetSimpleDaoImpl(final Class<T> clazz, final SessionFactory sessionFactory) {

		this.clazz = clazz;

		this.sessionFactory = sessionFactory;

		this.table = clazz.getAnnotation(Table.class).name();

	}

	@Override

	public void save(final T hib) throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			final Transaction tx = session.beginTransaction();

			hib.save(session);

			tx.commit();

		} catch (Throwable e) {

			log.error("Error saving resource, class: " + clazz, e);

			throw new InformationServiceException("Error saving resource, class: " + clazz, e);

		} finally {

			session.close();

		}

	}

	@SuppressWarnings("unchecked")

	@Override

	public List<T> list() throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			return session.createQuery("from " + table).list();

		} catch (Throwable e) {

			log.error("Error listing resources, class: " + clazz, e);

			throw new InformationServiceException("Error listing resources, class: " + clazz, e);

		} finally {

			session.close();

		}

	}

	@SuppressWarnings("unchecked")

	@Override

	public List<T> list(final String col, final Object value) throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			final Query query = session.createQuery("from " + table + " where " + col + " = :value");

			query.setParameter("value", value);

			return query.list();

		} catch (Throwable e) {

			log.error("Error listing resources, class: " + clazz, e);

			throw new InformationServiceException("Error listing resources, class: " + clazz, e);

		} finally {

			session.close();

		}

	}

	@Override

	public T find(final Serializable id) throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			return clazz.cast(session.get(clazz, id));

		} catch (Throwable e) {

			log.error("Error obtaining resource, class: " + clazz + ", id: " + id, e);

			throw new InformationServiceException("Error obtaining resource, class: " + clazz + ", id: " + id, e);

		} finally {

			session.close();

		}

	}

	@Override

	public void delete(final String id) throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			final Transaction tx = session.beginTransaction();

			final T hib = clazz.cast(session.get(clazz, id));

			hib.delete(session);

			tx.commit();

		} catch (Throwable e) {

			log.error("Error deleting resource, class: " + clazz + ", id: " + id, e);

			throw new InformationServiceException("Error deleting resource, class: " + clazz + ", id: " + id, e);

		} finally {

			session.close();

		}

	}

	@Override

	public long count() throws InformationServiceException {

		final Session session = sessionFactory.openSession();

		try {

			return ((Number) session.createQuery("select count(*) from " + table).uniqueResult()).longValue();

		} catch (Throwable e) {

			log.error("Error listing resources, class: " + clazz, e);

			throw new InformationServiceException("Error listing resources, class: " + clazz, e);

		} finally {

			session.close();

		}

	}

	public SessionFactory getSessionFactory() {

		return sessionFactory;

	}

	public void setSessionFactory(final SessionFactory sessionFactory) {

		this.sessionFactory = sessionFactory;

	}

	public Class<T> getClazz() {

		return clazz;

	}

	public void setClazz(final Class<T> clazz) {

		this.clazz = clazz;

	}

}