?? 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); }// 根據(jù)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(); }// 根據(jù)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(); }// 根據(jù)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(); }// 根據(jù)sender(發(fā)件人)查詢已發(fā)送的信息 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(); }// 根據(jù)nickname查詢未讀取的短信數(shù)量 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 }*/}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -