messengerdaoimpl.java

跑步社区网站

package com.briup.run.dao;

import java.util.List;

import org.hibernate.Query;
import org.hibernate.Session;

import com.briup.run.common.exception.DataAccessException;
import com.briup.run.common.util.HibernateSessionFactory;
import com.briup.run.pojos.Blackrecord;
import com.briup.run.pojos.Friendrecord;
import com.briup.run.pojos.Memberinfo;
import com.briup.run.pojos.Messagerecord;


public class MessengerDaoImpl implements IMessengerDao {

	public Integer findNewMessageNum(String nickname)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query = session.createQuery("select count(*) from Messagerecord where receiver=? and status=0");
		query.setString(0, nickname);		
		return (Integer) query.uniqueResult();
	}


	public void saveOrUpdateFriend(Friendrecord friend)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		session.saveOrUpdate(friend);
		
	}


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


	public List<Friendrecord> findAllFriend(String name)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query = session.createQuery("from Friendrecord where selfname=?");
		query.setString(0, name);
		
		return query.list();
	}


	public List<Blackrecord> findAllBlack(String name)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query = session.createQuery("from Blackrecord where selfname=?");
		query.setString(0, name);
		
		return query.list();
	}


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


	public void removeBlack(Blackrecord black) throws DataAccessException {
		// TODO Auto-generated method stub
		Session session=HibernateSessionFactory.getSession();
		session.delete(black);
	}


	public void removeFriend(Friendrecord friend) throws DataAccessException {
		// TODO Auto-generated method stub
		Session session=HibernateSessionFactory.getSession();
		session.delete(friend);
	}


	public void saveOrUpdateBlack(Blackrecord black) throws DataAccessException {
		// TODO Auto-generated method stub
		Session session=HibernateSessionFactory.getSession();
		session.saveOrUpdate(black);
	}


	public void saveOrUpdateMessange(Messagerecord message)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		session.saveOrUpdate(message);
	}


	public List<Messagerecord> findReceiverMessageByName(String name)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query = session.createQuery("from Messagerecord where receiver=? and receiverstatus=0");
		query.setString(0, name);
		return query.list();
	}
	
	public List<Messagerecord> findSenderMessageByName(String name)
	throws DataAccessException {
			Session session=HibernateSessionFactory.getSession();
			Query query = session.createQuery("from Messagerecord where sender=? and senderstatus=0");
			query.setString(0, name);
			return query.list();
}





	public Messagerecord findMessagerecordByTitle(String title)
			throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		Query query = session.createQuery("from Messagerecord where title=?");
		query.setString(0, title);
		return (Messagerecord) query.uniqueResult();
	}


	public void removeMessage(Messagerecord message) throws DataAccessException {
		Session session=HibernateSessionFactory.getSession();
		session.delete(message);
	}

}