D-Net

package eu.dnetlib.enabling.is.dao;

import java.io.Serializable;

import java.util.List;

import javax.persistence.Table;

import org.hibernate.Query;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.Transaction;

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

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

	private SessionFactory sessionFactory;

	private Class<T> clazz;

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

		this.clazz = clazz;

		this.sessionFactory = sessionFactory;

	}

	@Override

	public void save(final T hib) {

		final Session session = sessionFactory.openSession();

		final Transaction tx = session.beginTransaction();

		hib.save(session);

		tx.commit();

		session.close();

	}

	@Override

	public List<T> list() {

		final String table = clazz.getAnnotation(Table.class).name();

		final Session session = sessionFactory.openSession();

		@SuppressWarnings("unchecked")

		final List<T> list = session.createQuery("from " + table).list();

		session.close();

		return list;

	}

	@Override

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

		final String table = clazz.getAnnotation(Table.class).name();

		final Session session = sessionFactory.openSession();

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

		// query.setParameter("value", value);

		@SuppressWarnings("unchecked")

		final List<T> list = query.list();

		session.close();

		return list;

	}

	@Override

	public T find(final Serializable id) {

		final Session session = sessionFactory.openSession();

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

		session.close();

		return hib;

	}

	@Override

	public void delete(final String id) {

		final Session session = sessionFactory.openSession();

		final Transaction tx = session.beginTransaction();

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

		hib.delete(session);

		tx.commit();

		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;

	}

}