memberdaoimpl.java

跑步社区网站

package com.briup.run.dao;

import java.util.List;

import org.hibernate.Criteria;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.criterion.Expression;

import com.briup.run.common.exception.DataAccessException;
import com.briup.run.common.util.HibernateSessionFactory;
import com.briup.run.pojos.Graderecord;
import com.briup.run.pojos.Memberinfo;
import com.briup.run.pojos.Pointaction;
import com.briup.run.pojos.Pointrecord;

public class MemberDaoImpl implements IMemberDao {



	public Memberinfo findMemberinfoByName(String name)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		Query query =
              session.createQuery
              ("from Memberinfo where nickname=?");
		query.setString(0, name);
		
		return (Memberinfo) query.uniqueResult();
	}

	public List<Memberinfo> findMemberinfoByNum(int number)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query=session.createQuery("from Memberinfo   order by point DESC");
		query.setFirstResult(0);
		query.setMaxResults(number);
		List list=query.list();
		if(list.size()==0){
			return null;
		}
		return list;
	}

	public Graderecord findMemberinfoLevel(Long point)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		Query query =
              session.createQuery
              ("from Graderecord where ? BETWEEN minpoint AND maxpoint");
		query.setLong(0, point);
		return (Graderecord) query.uniqueResult();
	}

	public Integer findMemberinfoOnline() throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query=session.createQuery("select count(*) from Memberinfo where isonline=1");
		return (Integer) query.uniqueResult();
	}

	public Pointaction findPointactionByPointAction(String pointAction)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		Query query =
              session.createQuery
              ("from Pointaction where actionname=?");
		query.setString(0, pointAction);
		return (Pointaction) query.uniqueResult();
	}

	public void saveOrUpdateMemberinfo(Memberinfo memberinfo)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		session.saveOrUpdate(memberinfo);
		session.flush();
	}

	public void saveOrUpdatePointrecord(Pointrecord pointrecord)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		session.saveOrUpdate(pointrecord);
	}

	public Integer findMemberinfoNum() throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
		Query query =
              session.createQuery
              ("select count(*) from Memberinfo");
		return (Integer) query.uniqueResult();
	}

	public Memberinfo findOneMemberinfo(int sum) throws DataAccessException {
		int remod = (int)(Math.random()*sum);
		Session session = HibernateSessionFactory.getSession();
		Query query =session.createQuery("from Memberinfo");
		query.setFirstResult(remod);
		query.setMaxResults(1);
		return (Memberinfo) query.list().get(0);
	}

	public List<Memberinfo> findFriends(String age, String gender, String city)
			throws DataAccessException {
		Session session = HibernateSessionFactory.getSession();
    	Criteria criteria = session.createCriteria(Memberinfo.class);
    	if(!age.equals("unlimited")){
    		if(age.equals("1")){
    			criteria.add(Expression.between("age", 10, 19));
    		}
    		if(age.equals("2")){
    			criteria.add(Expression.between("age", 20, 29));
    		}
    		if(age.equals("3")){
    			criteria.add(Expression.between("age", 30, 39));
    		}
    	}
    	if(!gender.equals("unlimited")){
    		if(gender.equals("男")){
    			criteria.add(Expression.eq("gender", "男"));
    		}
    		if(gender.equals("女")){
    			criteria.add(Expression.eq("gender", "女"));
    		}
    	}
    	
    	if(!city.equals("unlimited")){
    		if(city.equals("上海")){
    			criteria.add(Expression.eq("provincecity", "上海"));
    		}
    		if(city.equals("北京")){
    			criteria.add(Expression.eq("provincecity", "北京"));
    		}
    		if(city.equals("天津")){
    			criteria.add(Expression.eq("provincecity", "天津"));
    		}
    	}
    	
		return criteria.list();
	}

	
}