package nu.xss.jpa.dao;

import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class GenericJpaDao<E, K> implements Dao<E, K>, Serializable {

	private static final long serialVersionUID = 4998055731089977476L;
	protected final Logger logger = LoggerFactory.getLogger(this.getClass());

	@PersistenceContext
	protected EntityManager entityManager;

	protected Class<E> entity;

	@SuppressWarnings("unchecked")
	public GenericJpaDao() {
		ParameterizedType genericSuperclass = (ParameterizedType) getClass()
				.getGenericSuperclass();
		this.entity = (Class<E>) genericSuperclass.getActualTypeArguments()[0];
	}

	public void save(E entity) {
		logger.info("Persist Entity: {}.", entity.toString());
		entityManager.persist(entity);
		entityManager.flush();
		logger.info("Saved entity: {}.", entity.toString());
	}

	public void merge(E entity) {
		logger.info("Merge Entity: {}.", entity.toString());
		entityManager.merge(entity);
		entityManager.flush();
		logger.info("Saved entity: {}.", entity.toString());
	}

	public void delete(E entity) {
		entityManager.remove(entity);
		logger.info("Deleted entity: {}.", entity.toString());
	}

	public E findById(K id) {
		return entityManager.find(entity, id);
	}

	public List<E> findAll() {
		CriteriaBuilder cb = entityManager.getCriteriaBuilder();
		CriteriaQuery<E> c = cb.createQuery(this.entity);
		Root<E> root = c.from(this.entity);
		c.select(root);
		return entityManager.createQuery(c).getResultList();
	}

}