1.接口
package net.shopxx.dao;
import java.io.Serializable;
import java.util.List;
import net.shopxx.bean.Pager;
import org.hibernate.criterion.DetachedCriteria;
/**
* Dao接口 - Dao基接口
* ============================================================================
* 版权所有 2008-2010 长沙鼎诚软件有限公司,并保留所有权利。
* ----------------------------------------------------------------------------
* 提示:在未取得SHOP++商业授权之前,您不能将本软件应用于商业用途,否则SHOP++将保留追究的权力。
* ----------------------------------------------------------------------------
* 官方网站:http://www.shopxx.net
* ----------------------------------------------------------------------------
* KEY: SHOPXX0FF87D88DFDA50E4762E39A4625B158C
* ============================================================================
*/
public interface BaseDao<T, PK extends Serializable> {
/**
* 根据ID获取实体对象.
*
* @param id
* 记录ID
* @return 实体对象
*/
public T get(PK id);
/**
* 根据ID获取实体对象.
*
* @param id
* 记录ID
* @return 实体对象
*/
public T load(PK id);
/**
* 根据ID数组获取实体对象集合.
*
* @param ids
* ID对象数组
*
* @return 实体对象集合
*/
public List<T> get(PK[] ids);
/**
* 根据属性名和属性值获取实体对象.
*
* @param propertyName
* 属性名称
* @param value
* 属性值
* @return 实体对象
*/
public T get(String propertyName, Object value);
/**
* 根据属性名和属性值获取实体对象集合.
*
* @param propertyName
* 属性名称
* @param value
* 属性值
* @return 实体对象集合
*/
public List<T> getList(String propertyName, Object value);
/**
* 获取所有实体对象集合.
*
* @return 实体对象集合
*/
public List<T> getAll();
/**
* 获取所有实体对象总数.
*
* @return 实体对象总数
*/
public Long getTotalCount();
/**
* 根据属性名、修改前后属性值判断在数据库中是否唯一(若新修改的值与原来值相等则直接返回true).
*
* @param propertyName
* 属性名称
* @param oldValue
* 修改前的属性值
* @param oldValue
* 修改后的属性值
* @return boolean
*/
public boolean isUnique(String propertyName, Object oldValue, Object newValue);
/**
* 根据属性名判断数据是否已存在.
*
* @param propertyName
* 属性名称
* @param value
* 值
* @return boolean
*/
public boolean isExist(String propertyName, Object value);
/**
* 保存实体对象.
*
* @param entity
* 对象
* @return ID
*/
public PK save(T entity);
/**
* 更新实体对象.
*
* @param entity
* 对象
*/
public void update(T entity);
/**
* 删除实体对象.
*
* @param entity
* 对象
* @return
*/
public void delete(T entity);
/**
* 根据ID删除实体对象.
*
* @param id
* 记录ID
*/
public void delete(PK id);
/**
* 根据ID数组删除实体对象.
*
* @param ids
* ID数组
*/
public void delete(PK[] ids);
/**
* 刷新session.
*
*/
public void flush();
/**
* 清除Session.
*
*/
public void clear();
/**
* 清除某一对象.
*
* @param object
* 需要清除的对象
*/
public void evict(Object object);
/**
* 根据Pager对象进行查询(提供分页、查找、排序功能).
*
* @param pager
* Pager对象
* @return Pager对象
*/
public Pager findByPager(Pager pager);
/**
* 根据Pager和DetachedCriteria对象进行查询(提供分页、查找、排序功能).
*
* @param pager
* Pager对象
* @return Pager对象
*/
public Pager findByPager(Pager pager, DetachedCriteria detachedCriteria);
}
2,实现:
package net.shopxx.dao.impl;
import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.List;
import javax.annotation.Resource;
import net.shopxx.bean.Pager;
import net.shopxx.bean.Pager.OrderType;
import net.shopxx.dao.BaseDao;
import org.apache.commons.lang.StringUtils;
import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.criterion.CriteriaSpecification;
import org.hibernate.criterion.DetachedCriteria;
import org.hibernate.criterion.Order;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.springframework.stereotype.Repository;
import org.springframework.util.Assert;
/**
* Dao实现类 - Dao实现类基类
* ============================================================================
* 版权所有 2008-2010 长沙鼎诚软件有限公司,并保留所有权利。
* ----------------------------------------------------------------------------
* 提示:在未取得SHOP++商业授权之前,您不能将本软件应用于商业用途,否则SHOP++将保留追究的权力。
* ----------------------------------------------------------------------------
* 官方网站:http://www.shopxx.net
* ----------------------------------------------------------------------------
* KEY: SHOPXXCED32589174C8D5905B5D0A02A2F33DF
* ============================================================================
*/
@Repository
public class BaseDaoImpl<T, PK extends Serializable> implements BaseDao<T, PK> {
private Class<T> entityClass;
protected SessionFactory sessionFactory;
@SuppressWarnings("unchecked")
public BaseDaoImpl() {
this.entityClass = null;
Class c = getClass();
Type type = c.getGenericSuperclass();
if (type instanceof ParameterizedType) {
Type[] parameterizedType = ((ParameterizedType) type).getActualTypeArguments();
this.entityClass = (Class<T>) parameterizedType[0];
}
}
@Resource
public void setSessionFactory(SessionFactory sessionFactory) {
this.sessionFactory = sessionFactory;
}
protected Session getSession() {
return sessionFactory.getCurrentSession();
}
@SuppressWarnings("unchecked")
public T get(PK id) {
Assert.notNull(id, "id is required");
return (T) getSession().get(entityClass, id);
}
@SuppressWarnings("unchecked")
public T load(PK id) {
Assert.notNull(id, "id is required");
return (T) getSession().load(entityClass, id);
}
@SuppressWarnings("unchecked")
public List<T> get(PK[] ids) {
Assert.notEmpty(ids, "ids must not be empty");
String hql = "from " + entityClass.getName() + " as model where model.id in(:ids)";
return getSession().createQuery(hql).setParameterList("ids", ids).list();
}
@SuppressWarnings("unchecked")
public T get(String propertyName, Object value) {
Assert.hasText(propertyName, "propertyName must not be empty");
Assert.notNull(value, "value is required");
String hql = "from " + entityClass.getName() + " as model where model." + propertyName + " = ?";
return (T) getSession().createQuery(hql).setParameter(0, value).uniqueResult();
}
@SuppressWarnings("unchecked")
public List<T> getList(String propertyName, Object value) {
Assert.hasText(propertyName, "propertyName must not be empty");
Assert.notNull(value, "value is required");
String hql = "from " + entityClass.getName() + " as model where model." + propertyName + " = ?";
return getSession().createQuery(hql).setParameter(0, value).list();
}
@SuppressWarnings("unchecked")
public List<T> getAll() {
String hql = "from " + entityClass.getName();
return getSession().createQuery(hql).list();
}
public Long getTotalCount() {
String hql = "select count(*) from " + entityClass.getName();
return (Long) getSession().createQuery(hql).uniqueResult();
}
public boolean isUnique(String propertyName, Object oldValue, Object newValue) {
Assert.hasText(propertyName, "propertyName must not be empty");
Assert.notNull(newValue, "newValue is required");
if (newValue == oldValue || newValue.equals(oldValue)) {
return true;
}
if (newValue instanceof String) {
if (oldValue != null && StringUtils.equalsIgnoreCase((String) oldValue, (String) newValue)) {
return true;
}
}
T object = get(propertyName, newValue);
return (object == null);
}
public boolean isExist(String propertyName, Object value) {
Assert.hasText(propertyName, "propertyName must not be empty");
Assert.notNull(value, "value is required");
T object = get(propertyName, value);
return (object != null);
}
@SuppressWarnings("unchecked")
public PK save(T entity) {
Assert.notNull(entity, "entity is required");
return (PK) getSession().save(entity);
}
public void update(T entity) {
Assert.notNull(entity, "entity is required");
getSession().update(entity);
}
public void delete(T entity) {
Assert.notNull(entity, "entity is required");
getSession().delete(entity);
}
public void delete(PK id) {
Assert.notNull(id, "id is required");
T entity = load(id);
getSession().delete(entity);
}
public void delete(PK[] ids) {
Assert.notEmpty(ids, "ids must not be empty");
for (PK id : ids) {
T entity = load(id);
getSession().delete(entity);
}
}
public void flush() {
getSession().flush();
}
public void clear() {
getSession().clear();
}
public void evict(Object object) {
Assert.notNull(object, "object is required");
getSession().evict(object);
}
public Pager findByPager(Pager pager) {
if (pager == null) {
pager = new Pager();
}
DetachedCriteria detachedCriteria = DetachedCriteria.forClass(entityClass);
return findByPager(pager, detachedCriteria);
}
public Pager findByPager(Pager pager, DetachedCriteria detachedCriteria) {
if (pager == null) {
pager = new Pager();
}
Integer pageNumber = pager.getPageNumber();
Integer pageSize = pager.getPageSize();
String property = pager.getProperty();
String keyword = pager.getKeyword();
String orderBy = pager.getOrderBy();
OrderType orderType = pager.getOrderType();
Criteria criteria = detachedCriteria.getExecutableCriteria(getSession());
if (StringUtils.isNotEmpty(property) && StringUtils.isNotEmpty(keyword)) {
String propertyString = "";
if (property.contains(".")) {
String propertyPrefix = StringUtils.substringBefore(property, ".");
String propertySuffix = StringUtils.substringAfter(property, ".");
criteria.createAlias(propertyPrefix, "model");
propertyString = "model." + propertySuffix;
} else {
propertyString = property;
}
criteria.add(Restrictions.like(propertyString, "%" + keyword + "%"));
}
Integer totalCount = (Integer) criteria.setProjection(Projections.rowCount()).uniqueResult();
criteria.setProjection(null);
criteria.setResultTransformer(CriteriaSpecification.ROOT_ENTITY);
criteria.setFirstResult((pageNumber - 1) * pageSize);
criteria.setMaxResults(pageSize);
if (StringUtils.isNotEmpty(orderBy) && orderType != null) {
if (orderType == OrderType.asc) {
criteria.addOrder(Order.asc(orderBy));
} else {
criteria.addOrder(Order.desc(orderBy));
}
}
pager.setTotalCount(totalCount);
pager.setList(criteria.list());
return pager;
}
}
3.继承
public class AdminDaoImpl extends BaseDaoImpl<Admin, int>{}
分享到:
相关推荐
dao接口 : PersonDAO extends GenericDao, Integer> 可以不写代码,方法已经在父类泛型dao里了,这里为了说明:可扩展添加 findByNameExact()方法 子类的附加方法。 泛型daoimpl :GenericDaoImpl, ID extends ...
泛型单例父类(带锁线程可释放),很好用的一个泛型单例父类,想将一个类变成单例类的时候,只有继承这个class就可以了;而且带线程锁,不怕多线程的时候出现错误了,而且还能手动释放;完全成品.cs文件,直接扔项目里就能用;...
而泛型DAO是一个类型安全的,代码精简的设计模式(相对于传统DAO),尤其在DAO组件数量庞大的时候,代码量的减少更加明显。 泛型DAO的核心是定义一个GenericDao接口,声明基本的CRUD操作: 用hibernate作为持久化...
基于hibernate5 泛型Dao实例,下载后改一下数据库 配置直接可以用
S2SH整合例子 注解配置 JSON 泛型Dao
使用了泛型的dao,在ssh里的应用,非常的简便好用
ssh通用泛型DAO 共包含3个类:BaseHibernateDAO,Page,QueryParameter
泛型DAO 完善的dao代码及criteria查询底层代码
dao接口 : PersonDAO extends GenericDao, Integer> 可以不写代码,方法已经在父类泛型dao里了,这里为了说明:可扩展添加 findByNameExact()方法 子类的附加方法。 泛型daoimpl :GenericDaoImpl, ID extends ...
654.652.JAVA基础教程_反射-获取运行时类的父类及父类的泛型(654).rar
泛型dao 即:不写重复的dao 。这个技术 能让 dao层 和 service层 不写一行代码。外国都用这个泛型DAO了 中国还是一个类一个dao的写,我生气就写了这个文章了。 在本文中,我将为您展示如何避免再三地重复 DAO 代码
目的,研究泛型DAO模式在java Web程序运用中的应用及其作用。方法,通过研究泛型DAO模式的设计理念及工作过程,与已经存在的DAO模式进行对比,分析其在java Web程序运用中的作用。结果:在编辑了泛型DAO模式之后的java ...
NULL 博文链接:https://287854442.iteye.com/blog/746718
NULL 博文链接:https://rooi.iteye.com/blog/1032620
NULL 博文链接:https://zhaoshijie.iteye.com/blog/982232
T21.13_泛型DAO模式与OSIV java 经典教程 经典教材
Hibernate泛型DAO及使用方法.
再次打造SSH1整合下的通用泛型DAO+分页,基于HibernateTemplate,欢迎大家指正 - DAO - Java - JavaEye论坛_files
3、此底层包含泛型DAO、Proxool连接池、国际化语言、DateUtil工具、ExcelUtil报表工具、自定义封装的弹框、批量删除、分页、上传等。 4、包含常用的工具:jquery、easy-ui、日期控件、highcharts图表控件、图片放大...