呵呵，第一次发帖，希望不要被群体鄙视。前段时间在公司做项目时负责几个小模块，功能很简单，实现动态参数查询分页就可以。因为本人刚进入工作，属于菜鸟级别，之前是针对每张表写一个DAO，现把它做成一个通用的DAO，采用Hibernate的QBC查询。DAO代码如下：
package com.aostarit.erp.dao;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.hibernate.Criteria;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Example;
import org.hibernate.criterion.Projections;
import org.hibernate.criterion.Restrictions;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import com.aostarit.erp.util.Pager;
public class ManagerDao extends HibernateDaoSupport
{
private Class entity;
public Class getEntity()
{
return entity;
}
public void setEntity(Class entity)
{
this.entity = entity;
}
/**
* @function 根据传递过来的hql语句，做相应的查询
* @return 返回记录数的集合
*/
public List getAllInfo(String hql)
{
List list = this.getHibernateTemplate().find(hql);
return list;
}
/**
* @function 根据传递过来的hql语句，做相应的查询
* @return 将查询结果封装成Bean返回
*/
public Object getBeanInfo(String hql)
{
List list = this.getHibernateTemplate().find(hql);
return list.get(0);
}
/**
* @function 查询抢修人员所以记录数
* @return 返回记录数的个数
*/
public int getTotalCount(String hql)
{
List list = this.getHibernateTemplate().find(hql);
Integer i = (Integer) list.get(0);
return i;
}
/**
* @function 分页显示符合所有的记录数，将查询结果封装为Pager
* @param pageNo
* 当前页数
* @param pageSize
* 每页显示的条数
* @return 查询结果Pager
*/
public Pager findPageAll(int pageNo, int pageSize)
{
Pager pager = null;
try
{
Criteria criteria = this.getSession().createCriteria(
this.getEntity());
// 获取总行数
int rowCount = (Integer) criteria.setProjection(
Projections.rowCount()).uniqueResult();
criteria.setProjection(null);
criteria.setFirstResult((pageNo - 1) * pageSize);
criteria.setMaxResults(pageSize);
List result = criteria.list();
pager = new Pager(pageSize, pageNo, rowCount, result);
} catch (RuntimeException re)
{
throw re;
} finally
{
return pager;
}
}
/**
* @function 分页显示符合所有的记录数，将查询结果封装为Pager
* @param pageNo
* 当前页数
* @param pageSize
* 每页显示的条数
* @param map
* 将查询条件封装为map
* @return 查询结果Pager
*/
public Pager findPageByCriteria(int pageNo, int pageSize, Map map)
{
Pager pager = null;
try
{
Criteria criteria = this.getSession().createCriteria(
this.getEntity());
if (map != null)
{
Set keys = map.keySet();
for (String key : keys)
{
criteria.add(Restrictions.like(key, map.get(key)));
}
}
// 获取根据条件分页查询的总行数
int rowCount = (Integer) criteria.setProjection(
Projections.rowCount()).uniqueResult();
criteria.setProjection(null);
criteria.setFirstResult((pageNo - 1) * pageSize);
criteria.setMaxResults(pageSize);
List result = criteria.list();
pager = new Pager(pageSize, pageNo, rowCount, result);
} catch (RuntimeException re)
{
throw re;
} finally
{
return pager;
}
}
/**
* @function 分页显示符合所有的记录数，将查询结果封装为Pager
* @param pageNo
* 当前页数
* @param pageSize
* 每页显示的条数
* @param criterions
* 不定参数Criterion
* @return 查询结果Pager
*/
public Pager findPageByCriteria(int pageNo, int pageSize,
Criterion... criterions)
{
Pager pager = null;
try
{
Criteria criteria = this.getSession().createCriteria(
this.getEntity());
if (criterions != null)
{
for (Criterion criterion : criterions)
{
if (criterion != null)
{
criteria.add(criterion);
}
}
}
// 获取根据条件分页查询的总行数
int rowCount = (Integer) criteria.setProjection(
Projections.rowCount()).uniqueResult();
criteria.setProjection(null);
criteria.setFirstResult((pageNo - 1) * pageSize);
criteria.setMaxResults(pageSize);
List result = criteria.list();
pager = new Pager(pageSize, pageNo, rowCount, result);
} catch (RuntimeException re)
{
throw re;
} finally
{
return pager;
}
}
/**
* @function 根据传递过来的Object,在数据库中查找语气匹配的记录
* @param pageNo
* 当前页数
* @param pageSize
* 每页显示的记录数
* @param object
* 将查询条件封装为Object
* @return 将查询结果封装为Pager返回
*/
public Pager findPageByExample(int pageNo, int pageSize, Object object)
{
Pager pager = null;
try
{
Criteria criteria = this.getSession().createCriteria(
this.getEntity());
if (object != null)
{
criteria.add(Example.create(object).enableLike());
}
// 获取根据条件分页查询的总行数
int rowCount = (Integer) criteria.setProjection(
Projections.rowCount()).uniqueResult();
criteria.setProjection(null);
criteria.setFirstResult((pageNo - 1) * pageSize);
criteria.setMaxResults(pageSize);
List result = criteria.list();
pager = new Pager(pageSize, pageNo, rowCount, result);
} catch (RuntimeException re)
{
throw re;
} finally
{
return pager;
}
}
}
BO层代码如下：
package com.aostarit.erp.bo;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.MatchMode;
import org.hibernate.criterion.Restrictions;
import com.aostarit.erp.dao.MendManagerDao;
import com.aostarit.erp.po.EicMend;
import com.aostarit.erp.util.Pager;
public class MendBo
{
/**
* 依靠Spring的依赖注入，注入抢修人员的Dao
*/
private MendManagerDao mendManagerDao;
public MendManagerDao getMendManagerDao()
{
return mendManagerDao;
}
public void setMendManagerDao(MendManagerDao mendManagerDao)
{
this.mendManagerDao = mendManagerDao;
try
{
// 设置该BO操作所对应的pojo
this.mendManagerDao.setEntity(Class
.forName("com.aostarit.erp.po.EicMend"));
} catch (ClassNotFoundException e)
{
e.printStackTrace();
}
}
/**
* @function 根据传递过来的列名，在数据库中查询该列不重复的记录,前台用下拉框显示
* @param column
* 传递过来的列名
* @return 该列不重复的记录
*/
public List getColumn(String column)
{
String table = "EicMend";
StringBuffer hql = new StringBuffer();
hql.append("select distinct(").append(column).append(") from ").append(
table).append(" where ").append(column).append(" is not null");
return mendManagerDao.getAllInfo(hql.toString());
}
/**
* @function 根据传递过来的分页的参数，分页查找数据库中的记录
* @param pageNo
* 当前的页码
* @param pageSize
* 每页显示的记录数
* @return 符合条件的记录数
*/
public Pager getAllInfo(int pageNo, int pageSize)
{
Pager pager = mendManagerDao.findPageAll(pageNo, pageSize);
return pager;
}
/**
* @function 将传递过来的参数封装成抢修人员Bean，分页查询符合条件的记录
* @param pageNo
* 当前的页码
* @param pageSize
* 每页显示的记录数
* @param mendName
* @param specialt
* @param post
* @return 将符合条件的记录数以及页码信息封装成PagerBean返回
*/
public Pager getInfoByQuery1(int pageNo, int pageSize, String mendName,
String specialty, String post)
{
EicMend eicMend = new EicMend();
if (mendName != null && mendName.length() > 0)
{
eicMend.setMendname(mendName);
}
if (specialty != null && specialty.length() > 0)
{
eicMend.setSpecialty(specialty);
}
if (post != null && post.length() > 0)
{
eicMend.setPost(post);
}
Pager pager = mendManagerDao.findPageByExample(pageNo, pageSize,
eicMend);
return pager;
}
/**
* @function 将传递过来的参数封装成抢修人员Bean，分页查询符合条件的记录
* @param pageNo
* 当前的页码
* @param pageSize
* 每页显示的记录数
* @param mendName
* 抢修人员的名称
* @param specialty
* 抢修人员的工种
* @param post
* 抢修人员的职称
* @return 将符合条件的记录数以及页码信息封装成PagerBean返回
*/
public Pager getInfoByQuery2(int pageNo, int pageSize, String mendName,
String specialty, String post)
{
Map map = new HashMap();
if (mendName != null && mendName.length() > 0)
{
map.put("mendname", "%" + mendName + "%");
}
if (specialty != null && specialty.length() > 0)
{
map.put("specialty", specialty);
}
if (post != null && post.length() > 0)
{
map.put("post", post);
}
Pager pager = mendManagerDao.findPageByCriteria(pageNo, pageSize, map);
return pager;
}
/**
* @function 将传递过来的参数封装成抢修人员Bean，分页查询符合条件的记录
* @param pageNo
* 当前的页码
* @param pageSize
* 每页显示的记录数
* @param mendName
* 抢修人员的名称
* @param specialty
* 抢修人员的工种
* @param post
* 抢修人员的职称
* @return 将符合条件的记录数以及页码信息封装成PagerBean返回
*/
public Pager getInfoByQuery3(int pageNo, int pageSize, String mendName,
String specialty, String post)
{
Criterion criterion1 = null, criterion2 = null, criterion3 = null;
if (mendName != null && mendName.length() > 0)
{
criterion1 = Restrictions.ilike("mendname", mendName,
MatchMode.ANYWHERE);
}
if (specialty != null && specialty.length() > 0)
{
criterion2 = Restrictions.ilike("specialty", specialty,
MatchMode.EXACT);
}
if (post != null && post.length() > 0)
{
criterion3 = Restrictions.ilike("post", post, MatchMode.EXACT);
}
Pager pager = mendManagerDao.findPageByCriteria(pageNo, pageSize,
criterion1, criterion2, criterion3);
return pager;
}
/**
* @function 根据所属单位的Id,分页查询相关信息
* @param pageNo
* 当前页码
* @param pageSize
* 每页显示的记录数
* @param deptId
* 所属单位的Id
* @return 将符合条件的记录数以及页码信息封装成PagerBean返回
*/
public Pager getInfoByDept(int pageNo, int pageSize, String deptId)
{
Criterion criterion1 = null;
if (deptId != null && deptId.length() > 0)
{
criterion1 = Restrictions.ilike("aorganization.orgCode", deptId,
MatchMode.EXACT);
}
Pager pager = mendManagerDao.findPageByCriteria(pageNo, pageSize,
criterion1);
return pager;
}
/**
* @function 根据抢修人员的主键Id，查询抢修人员的详细信息
* @param equipId
* 抢修人员的主键
* @return 将查询结果封装成抢修人员Bean返回
*/
public EicMend getBeanInfo(String mendId)
{
StringBuffer hql = new StringBuffer();
hql.append("from EicMend e where e.mendid = ").append(mendId);
return (EicMend) mendManagerDao.getBeanInfo(hql.toString());
}
}
注：MendBo类中，模糊查询采用两种方式：QBC和QBE，其中getInfoByQuery1为QBE查询，getInfoByQuery2采用map封装查询条件，getInfoByQuery3采用Criterion封装查询条件，在通过JDK1.5设置不定参数方法传递给DAO，三个方法均为实现同一目的，只是采取不同操作而已。实际项目中在Action中调用其一即可。各位大虾要是有什么好方法不吝赐教哈！
分享到：
相关推荐
java ssh通用DAO另类实现示例 java ssh通用DAO另类实现示例
ssh通用泛型DAO 共包含3个类：BaseHibernateDAO，Page，QueryParameter
基本上可以在SSH中通用的dao组件 sd fs fs df sd
基于注解ssh的通用dao的crud,spring4+struts2+hibernate4
再次打造SSH1整合下的通用泛型DAO+分页，基于HibernateTemplate，欢迎大家指正 - DAO - Java - JavaEye论坛_files
一个通用的基于泛型的dao层，可以减少程序的工作量,方法齐全
通用SSH2结构的增删查改标准代码, bean,HBM文件为自定义, service,dao接口为标准可重用 ...action 调用通用service,service调用通用dao 调用关系用spring 配址文件设置 因为上传限制问题,把lib目录下的jar文件都删掉了
这个是不同类型的表单通用的dao模式，简洁明了，注释清楚，可移植性很强
NULL 博文链接：https://ap0406708.iteye.com/blog/537709
该模板是SSH框架的整合，是为了方便开发人员所搭建的架构，里面有自定义标签分页，还有许多通用方法。具体的代码大家下来看看，就不多说了
struts2 spring hibernate maven 实现 商品管理，实现增加、删除、修改、查询 通用dao实现
使用ssh搭建框架+jpa+注解的使用 和通用Dao的使用集成SSH框架
标准的SSH项目~dao类经过了整合，继承了通用接口~并且实现了事务的配置，连接的是MYSQL数据库，程序拉下来直接能跑，首先你要有MYSQL数据库~
全自动生成Struts2 Hibernate3.6 Spring2.5 自动生成DAO,Service,Action,以及配置文件； 运行CreateSrc.java文件， 修改main()中的方法， 自定义要生成对象的名称； 运行后，请刷新工程可看到生成的文件
一、背景.........................................2 ...使用“工厂方法”模式实现DAO 工厂的策略.........................................12 使用抽象工厂模式.........................................13
教学-传智播客-项目视频经典之作巴巴运动网106集－28将Web层分页封装成通用模块源代码 所需要的jar文件： （一）、Hibernate: 位于 "\hibernate-distribution-3.3.2.GA" 目录下的jar文件: hibernate3.jar 位于 "\...
否则只能查看 11) Dao 操作优化 BaseDao.java 所有dao的通用方法，dao都必须继承此类 (反射泛型)实现步骤代码：1) 设计数据库:
该demo集成了spring+springmvc+hibernate框架，里面的dao、service、entity均采用注解形式，容易开发，另外该demo中dao采用注解形式，将所有实体dao需要用到的通用方法如insert，update，delete，分页查询等均采用...
在上次的 ssh 事务配置上修改了，可以做到配置通用性，只需要在配置中把要添加事务处理的 DAO 或 Mgr添加 <br>有什么问题可以给我留言：lovealo@163.com<br>
当前需要分支 dao、mongrel2 和 swagger-def - 'genericIO' 此外，需要一个 'dbkeys' 存储桶，形式为 'dbname={"key":""}' 安装模块： npm install git+ssh://git@github.com:OPENi-ict/crud_api.git 您将需要通过 ...