采购及仓库信息管理系统

package com.mmc.common.dao; import java.io.Serializable; import java.lang.reflect.ParameterizedType; import java.util.List; import java.util.Map; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; public class BaseDaoImpl<T,PK extends Serializable> implements IBaseDao<T,PK>{ private Class<T> persistentClass; public Class<T> getPersistentClass() { return persistentClass; } public void setPersistentClass(Class<T> persistentClass) { this.persistentClass = persistentClass; } @SuppressWarnings("unchecked") public BaseDaoImpl() { this.persistentClass=(Class<T>) ((ParameterizedType)getClass().getGenericSuperclass()).getActualTypeArguments()[0]; } private SessionFactory sessionFactory; public SessionFactory getSessionFactory() { return sessionFactory; } public void setSessionFactory(SessionFactory sessionFactory) { this.sessionFactory = sessionFactory; } @Override public void save(T entity) { this.getSessionFactory().getCurrentSession().save(entity); } /*======================inser========================*/ @Override public void insert(String hql){ this.getSessionFactory().openSession().createSQLQuery(hql).executeUpdate(); } /*======================inser========================*/ @Override public void saveOrUpdate(T entity) { this.getSessionFactory().getCurrentSession().saveOrUpdate(entity); } @Override public void delete(PK id) { this.getSessionFactory().getCurrentSession().delete(this.getById(id)); } @Override public void delete(T entity) { this.getSessionFactory().getCurrentSession().delete(entity); } @Override public void deleteByProperty(String propertyName, Object value) { String queryString="delete from " + this.getPersistentClass().getName() + " as model where model." + propertyName + "=?"; Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); query.setParameter(0, value); query.executeUpdate(); } @Override public void update(T entity) { this.getSessionFactory().getCurrentSession().update(entity); } /*======================修改=================================*/ @Override public void up(String hql){ this.getSessionFactory().openSession().createSQLQuery(hql).executeUpdate(); //Transaction tx = this.getSessionFactory().openSession().beginTransaction(). } /*======================修改==================================*/ @Override public T getById(PK id) { return (T) this.getSessionFactory().getCurrentSession().get(getPersistentClass(), id); } @Override public int countAll() { String queryString="select count(*) from " + this.getPersistentClass().getName(); Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); List<T> list=query.list(); Long result=(Long) list.get(0); return result.intValue(); } @Override public int countByProperty(String propertyName, Object value) { String[] propertyNames = new String[]{propertyName}; Object[] values = new Object[]{value}; return this.countByProperties(propertyNames, values); } @Override public int countByProperties(String[] propertyNames, Object[] values) { StringBuffer strBuffer = new StringBuffer(); strBuffer.append("select count(*) from " + getPersistentClass().getName()); strBuffer.append(" as model where "); for (int i = 0; i < propertyNames.length; i++) { if (i != 0) strBuffer.append(" and"); strBuffer.append(" model."); strBuffer.append(propertyNames[i]); strBuffer.append("="); strBuffer.append("? "); } String queryString = strBuffer.toString(); Query query = this.getSessionFactory().getCurrentSession().createQuery(queryString); for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } List list = query.list(); Long result = (Long) list.get(0); return result.intValue(); } public T get(String hql) { Query q= this.sessionFactory.getCurrentSession().createQuery(hql); List<T> l=q.list(); if(l!=null && l.size()>0){ return l.get(0); } return null; } public T get(String hql, Object[] params) { Query q= this.sessionFactory.openSession().createQuery(hql); if(params!=null && params.length>0){ for(int i=0;i<params.length;i++){ q.setParameter(i, params[i]); } } List<T> l=q.list(); if(l!=null && l.size()>0){ return l.get(0); } return null; } public T get(String hql, Map<String, Object> params) { Query q= this.sessionFactory.openSession().createQuery(hql); if(params != null && !params.isEmpty()){ for(String key:params.keySet()){ q.setParameter(key, params.get(key)); } } List<T> l=q.list(); if(l!=null && l.size()>0){ return l.get(0); } return null; } @SuppressWarnings("unchecked") @Override public List<T> getAll() { String queryString="from " + this.getPersistentClass().getName(); Query query = this.getSessionFactory().getCurrentSession().createQuery(queryString); return query.list(); } @Override public List<T> getAll(int page, int pageSize) { String queryString="from " + getPersistentClass().getName(); Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); int firstResult=(page-1) * pageSize; query.setFirstResult(firstResult); query.setMaxResults(pageSize); return query.list(); } @Override public List<T> getAllSequence(int page, int pageSize,boolean isSequence) { String queryString="from " + getPersistentClass().getName()+" order by id"; //select * from user ORDER BY uid desc; if(isSequence){ queryString+=" asc"; }else{ queryString+=" desc"; } Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); int firstResult=(page-1) * pageSize; query.setFirstResult(firstResult); query.setMaxResults(pageSize); return query.list(); } /*//查询用户表里的采购员 @Override public List<T> getAllBuyer() { String queryString="from User u where u.role.roleId=4"; Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); return query.list(); } */ @Override public List<T> findByProperty(String propertyName, Object value) { String queryString="from " + getPersistentClass().getName()+" as model where model." + propertyName + "=?"; Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); query.setParameter(0, value); return query.list(); } @Override public T getByProperty(String propertyName, Object value) { String queryString="from " + getPersistentClass().getName()+" as model where model." + propertyName + "=?"; Query query=this.getSessionFactory().getCurrentSession().createQuery(queryString); query.setParameter(0, value); List<T> list=query.list(); if(list.size()>0) return list.get(0); else return null; } @Override public List<T> getByProperty(String propertyName, Object value, int page, int pageSize) { return this.getByProperties(new String[] { propertyName }, new Object[] { value }, page, pageSize); } @Override public List<T> getByPropertyOrder(String propertyName, Object value,int page, int pageSize, String propertyOrder, boolean isSequence) { //String queryString="from " + getPersistentClass().getName()+" as model where model." + propertyName + "=? order by model."+propertyOrder; String queryString="from " + getPersistentClass