personassesdaoimpl.java

java高级引用管理综合朝鲜经java高级引用管理综合朝鲜经java高级引用管理综合朝鲜经java高级引用管理综合朝鲜经

package com.hbmDAO.impl;
import com.model.*;
import com.hbmDAO.*;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.hibernate.Session;
import org.springframework.dao.DataRetrievalFailureException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
public class PersonAssesDAOImpl extends HibernateDaoSupport implements PersonAssesDAO {
	public PersonAsses queryById(String id) {
        Object obj = getHibernateTemplate().load(PersonAsses.class, id);
        if(obj==null)
            throw new DataRetrievalFailureException("id not found: " + id);
        return (PersonAsses) obj;
    }

    @SuppressWarnings("unchecked")
    public List<PersonAsses> queryAll() {
        return getHibernateTemplate().find("from PersonAsses ");
    }
    @SuppressWarnings("unchecked")
    public List<PersonAsses> queryByHql(String hql) {
        return getHibernateTemplate().find(hql);
    }
    
    @SuppressWarnings("unchecked")
    public List getCount(String sql) {
//        return getHibernateTemplate().getSessionFactory().getCurrentSession().createSQLQuery("select count(*) from person_asses").list();
    	List<String> list=new ArrayList<String>();
    	try{
    	Session session = null;
		session = this.getSession();
		Connection con = session.connection();
		Statement stmt = con.createStatement(ResultSet.TYPE_FORWARD_ONLY,
				ResultSet.CONCUR_READ_ONLY);
		ResultSet rs = stmt.executeQuery(sql);
		while (rs.next()) {
			list.add(rs.getString(1));
		}
//		session.close();
    }catch(Exception ex){}
		return list;
    }
    public List<PersonAsses> queryByPage(String hql,int pageNum,int countPageRecord){
    	List<PersonAsses> list=getHibernateTemplate().find(hql);
    	if(countPageRecord>=list.size()){
			return list;
		}else if ((pageNum-1) * countPageRecord == 0){
			return list.subList(0, countPageRecord);
		}
		else if(pageNum*countPageRecord>=list.size()){
			return list.subList((pageNum - 1) * countPageRecord, list.size());
		}else{
			return list.subList((pageNum-1)*countPageRecord, pageNum*countPageRecord);
		}
    }
    public int[] getPageInfo(String hql,int countPageRecord){
		int countRecord=0;//总的记录数
		int countPage=0;//总的页数
		//List thisPage=null;
		List listAll=this.queryByHql(hql);
		
		countRecord=listAll.size();//获取总的记录数
		if(countRecord<=countPageRecord){ 
		    countPage=1;
		}
		else{
		    countPage=(countRecord % countPageRecord == 0)?(countRecord / countPageRecord):(countRecord / countPageRecord + 1);
	 
	    }

		int [] i={countRecord,countPage};
		return i;
	}
    public void insert(PersonAsses data) {
        getHibernateTemplate().save(data);
    }

    public void update(PersonAsses data) {
        getHibernateTemplate().update(data);
    }

    public void delete(PersonAsses data) {
        getHibernateTemplate().delete(
                getHibernateTemplate().load(PersonAsses.class, data.getPaid()));
    }
}