messagedaoimpl.java

通过网站展示学校风采、文化、优点与特色

package com.mvc.dao.impl;

import java.util.List;

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

import com.mvc.common.HibernateSessionFactory;
import com.mvc.dao.IMessageDao;
import com.mvc.dao.bean.JinfengMemberinfo;
import com.mvc.dao.bean.JinfengMessage;
import com.mvc.dao.bean.JinfengStudents;

public class MessageDaoImpl implements IMessageDao {
//	 删除客户
	public void delMemberinfo(JinfengMemberinfo memberinfo) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		session.delete(memberinfo);
		
	}
//	删除短信
	public void delMessage(JinfengMessage message) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		session.delete(message);
		
	}
//	 删除学员
	public void delStudents(JinfengStudents student) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		session.delete(student);
		
	}
//	 根据id查询短信息
	public JinfengMessage findMessageById(Long id) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		Query query=session.createQuery("from JinfengMessage where id=?");
		query.setLong(0, id);
		return (JinfengMessage) query.uniqueResult();
	}
//	 根据receiver(收件人)查询新信息
	public List findNewMessages(String nickname) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		Query query=session.createQuery("from JinfengMessage where receiver=? and receiverstatus=0");
		query.setString(0, nickname);
		return query.list();
	}
//	 根据receiver查询已接收到的信息
	public List findReMessages(String nickname) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		Query query=session.createQuery("from JinfengMessage where receiver=?");
		query.setString(0, nickname);
		return query.list();
	}
//	 根据sender(发件人)查询已发送的信息
	public List findSeMessages(String nickname) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		Query query=session.createQuery("from JinfengMessage where sender=?");
		query.setString(0, nickname);
		return query.list();
		
	}

//	 根据nickname查询未读取的短信数量
	public int findUnreadedMessagesNumber(String nickname) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		Query query=session.createQuery("from JinfengMessage where receiver=? and  status=0");
		query.setString(0, nickname);
		return query.list().size();
	}

/*	public void saveMemberinfo(JinfengMemberinfo memberinfo) throws Exception {
		
		
	}*/

	public void saveMessage(JinfengMessage message) throws Exception {
		Session session= HibernateSessionFactory.currentSession();
		//System.out.println("bbbbbbbbb");
		session.saveOrUpdate(message);
		
	}

	/*public void saveStudents(JinfengStudents student) throws Exception {
		// TODO Auto-generated method stub
		
	}
*/
}