`
gaogengzhi
  • 浏览: 107333 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

SSH通用查询DAO

阅读更多

        呵呵,第一次发帖,希望不要被群体鄙视。前段时间在公司做项目时负责几个小模块,功能很简单,实现动态参数查询分页就可以。因为本人刚进入工作,属于菜鸟级别,之前是针对每张表写一个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中调用其一即可。各位大虾要是有什么好方法不吝赐教哈!

 

分享到:
评论
4 楼 qizikang 2008-11-19  
我也是菜鸟
3 楼 awary 2008-11-19  
linkjava 写道
在DAO里没有实现多表关联查询

对,这种设计也没有办法实现多表关联.另外,可扩展性不好,比如将来想加个某几个常用的TABLE加个缓存,跟本无处下手..
2 楼 linkjava 2008-11-19  
在DAO里没有实现多表关联查询
1 楼 yhily2005 2008-11-13  
也没有什么而已

相关推荐

    ssh通用泛型DAO

    在这个主题中,我们将深入探讨"ssh通用泛型DAO"的相关知识点。 首先,我们来了解"BaseHibernateDAO"。BaseHibernateDAO是基于Hibernate框架的一个基类,它封装了常见的数据库操作,如增删查改(CRUD)。通过继承这...

    java ssh通用DAO另类实现示例

    总结:这个另类的Java SSH通用DAO实现利用了动态代理和Hibernate的特性,降低了代码复杂度,提高了代码复用性。它使得DAO层的维护变得更加简单,同时保持了良好的封装性和扩展性。在实际项目中,这样的设计可以显著...

    SSH中通用dao类

    在这个场景中,"SSH中通用DAO类"指的是在SSH框架下设计和实现的可以应用于多种业务场景的数据访问对象(Data Access Object)类。 DAO层是三层架构或MVC架构中的一个重要部分,主要负责与数据库进行交互,将业务...

    基于注解ssh的通用dao的crud

    总结起来,基于注解的SSH通用DAO的CRUD实现主要涉及以下步骤: 1. 使用Spring注解定义bean、组件扫描和依赖注入。 2. 在Struts2 Action中定义CRUD操作并使用注解配置请求路径和结果页面。 3. 利用Hibernate注解定义...

    ssh2 + dao泛型

    通过定义泛型接口或抽象类,我们可以创建一个通用的DAO模板,将具体的数据库操作与实体类的类型绑定。例如,我们可以创建一个名为`GenericDao<T>`的接口,其中`T`代表任何Java Bean对象。这样,每次需要操作新的实体...

    ssh通用基于泛型的dao

    标题“ssh通用基于泛型的dao”指的是使用SSH(Spring、Struts2、Hibernate)框架开发的一个通用的、基于泛型的DAO实现,它旨在提高开发效率,减少重复工作。 SSH框架是Java企业级应用开发的常用组合,Spring提供了...

    ssh整合下的通用泛型DAO+分页

    在这个特定的讨论中,我们聚焦于SSH1中的一个关键概念:通用泛型DAO(Data Access Object)以及分页功能的实现。DAO层是模型层和数据访问层之间的桥梁,它的主要职责是处理数据库操作,为业务层提供无状态的数据访问...

    SSH 通用分页插件

    综上所述,SSH通用分页插件是Java Web开发中的一个重要工具,它简化了数据分页的实现,提高了代码的可读性和维护性,是SSH框架下处理大数据量查询的必备组件。正确理解和使用此类插件,能够提升项目质量,优化用户...

    ssh三大框架通用配置

    SSH通用配置的核心在于理解这三个框架如何协作,以及如何在XML配置文件中定义和连接它们的各个组件。通过这样的配置,开发者可以快速搭建一个支持基本CRUD操作和分页查询的应用。实际开发中,还可以考虑引入MyBatis...

    Hibernate_通用DAO模式,一个写好的dao层

    本资源“Hibernate_通用DAO模式”提供了一种适用于不同类型表单的DAO实现,基于SSH(Struts2、Spring、Hibernate)框架,特别强调简洁、易懂和高可移植性。 首先,SSH框架是Java Web开发中的经典组合,Struts2负责...

    SSH 泛型DAO分页

    通过泛型,我们可以创建一个通用的DAO接口和实现,减少代码重复,提高代码复用。例如,我们可以创建一个`BaseDao<T>`接口,其中T代表任何实体类,然后针对每个实体类实现具体的DAO。 5. **分页**: 分页是Web应用中...

    通用SSH2结构的标准代码,通用dao实现类serviceImpl实现类

    通用SSH2结构的增删查改标准代码, bean,HBM文件为自定义, service,dao接口为标准可重用 ...action 调用通用service,service调用通用dao 调用关系用spring 配址文件设置 因为上传限制问题,把lib目录下的jar文件都删掉了

    eclipse下整合搭建ssh通用项目

    下面我们将详细讨论如何在Eclipse环境下整合并搭建一个SSH通用项目。 首先,我们需要理解SSH框架的每个组件: 1. Struts2:这是一个基于MVC设计模式的Java Web应用框架,用于处理用户请求,控制应用程序流程,并...

    SSH框架整合通用模板(内涵自定义标签分页)

    总的来说,SSH框架整合通用模板提供了一个成熟的开发环境,通过自定义标签分页、通用DAO和服务,使得开发人员可以快速构建应用,同时降低了维护成本。对于初学者或熟悉SSH的开发者来说,这是一个很好的学习和实践的...

    springmvc ssh通用的junit测试样例

    总的来说,Spring MVC SSH通用的JUnit测试样例是Java Web开发中不可或缺的工具,它们帮助开发者构建健壮、可维护的代码,同时提高开发效率。这些测试样例不仅提供了测试的模板,也是理解SSH和Spring MVC测试策略的...

    SSH框架构建-用户信息查询

    同时,Spring还提供了AOP(Aspect-Oriented Programming)功能,允许我们定义切面来处理日志、事务等通用行为,例如,在查询用户信息时,可以利用AOP记录操作日志或进行事务控制。 **Hibernate** 是一种流行的ORM...

    SSH泛型DAO+Proxool+DisPlayTag+Jquery easyui

    通过定义一个通用的DAO接口,可以创建一个适用于多种实体类的DAO实现,简化了数据库操作。 5. **Proxool**: Proxool 是一个轻量级的数据库连接池,它可以高效管理数据库连接,避免了频繁创建和销毁连接带来的性能...

    [code] ssh 分页,自定义标签,查找,泛化dao,中文参数的传递

    NULL 博文链接:https://ap0406708.iteye.com/blog/537709

    ssh投票管理系统

    5. **数据访问对象(DAO)**:与Hibernate配合,具体执行数据库查询和更新操作。 6. **模型(Model)**:定义了投票系统中的对象,如User、VotingTopic、Choice和Vote等。 7. **视图(View)**:主要由JSP页面组成...

Global site tag (gtag.js) - Google Analytics