Skip to content
This repository
Search
Pull requests
Issues
Marketplace
Gist
 @mieru
 Sign out
 Watch 0
  Star 0
  Fork 0 mieru/smbapp
 Code  Issues 0  Pull requests 0  Projects 0  Wiki  Settings Insights
Branch: master Find file Copy pathsmbapp/smbcustsrv/src/main/java/dbmenager/abstr/AbstractDAO.java
5a9359f  on 30 Dec 2016
@mieru mieru Mocna Refaktoryzacja
1 contributor
RawBlameHistory
96 lines (81 sloc)  3.07 KB
package dbmenager.abstr;

import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
import java.math.BigInteger;
import java.sql.Date;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;

public abstract class AbstractDAO<T> {
	@PersistenceContext(unitName = "smbcustsrv")
	protected EntityManager entityManager;


	public T update(T value) {
		try {
			entityManager.merge(value);
			return value;
		} catch (Exception e) {
			System.out.println(e.getMessage()); // FIXME log to file
			return null;
		}
	}

	public T insert(T value) {
		try {
			entityManager.persist(value);
			return value;
		} catch (Exception e) {
			System.out.println(e.getMessage());// FIXME log to file
			return null;
		}
	}

	public boolean delete(T value) {
		try {
			T toBeRemoved = entityManager.merge(value);
			entityManager.remove(toBeRemoved);
			return true;
		} catch (Exception e) {
			System.out.println(e.getMessage());// FIXME log to file
			return false;
		}
	}

	protected Class<T> dbEntity;

	public List<T> findEntity(T value) {
		try {
			StringBuilder queryString = new StringBuilder();
			queryString.append("SELECT " + value.getClass().getSimpleName() + " FROM "
					+ value.getClass().getSimpleName() + " " + value.getClass().getSimpleName() + " WHERE 1=1");
			for (Field field : value.getClass().getDeclaredFields()) {
				field.setAccessible(true);
				if (field.get(value) != null && !Modifier.isStatic(field.getModifiers())
						&& !Modifier.isStatic(field.getModifiers()) && !Modifier.isFinal(field.getModifiers())) {
					if (field.getType().isAssignableFrom(String.class) || field.getType().isAssignableFrom(Date.class)
							|| field.getType().isAssignableFrom(BigInteger.class)) {
						queryString.append(" AND " + value.getClass().getSimpleName() + "." + field.getName() + " = '"
								+ field.get(value) + "'");
					} else {
						queryString.append(" AND " + value.getClass().getSimpleName() + "." + field.getName() + " = "
								+ field.get(value));
					}
				}
			}
			System.out.println(queryString.toString());
			List<T> queryResult = entityManager.createQuery(queryString.toString()).getResultList();
			return queryResult;
		} catch (Exception e) {
			System.out.println("factory.abstr.AbstractFactory.findEntity() - Blad w generowaniu zapytania");
			return null;
		}
	}

	public T findEntityByID(Integer primaryKey) {
		String sql = "SELECT " + dbEntity.getSimpleName() + " FROM " + dbEntity.getSimpleName() + " "
				+ dbEntity.getSimpleName() + " WHERE " + dbEntity.getSimpleName() + "."
				+ dbEntity.getDeclaredFields()[1].getName() + " = " + primaryKey;
		System.out.println("LOG[sql findEntityByID]: " + sql);
		T queryResault = (T) entityManager.createQuery(sql).getSingleResult();
		return queryResault;
	}

	public List<T> findAll() {
		TypedQuery<T> queryResault = entityManager.createNamedQuery(dbEntity.getSimpleName() + ".findAll", dbEntity);
		return queryResault.getResultList();
	}



}
Contact GitHub API Training Shop Blog About
© 2017 GitHub, Inc. Terms Privacy Security Status Help