messagedaoimple.java

主要包括有消息的发布、删除、查看消息、查看消息内容、还有一些用户的注册、登录等采用的是struts+hibernate开发

package com.dao;

import com.model.Messages;
import com.model.Users;

import org.hibernate.*;
import com.hibernate.*;
import java.util.*;
public class MessageDaoImple implements MessageDao {

	public Messages getMessageById(int id) {
		Session session = HibernateUtils.getSession();
		session.beginTransaction();
		
		Messages message = (Messages)session.get(Messages.class, id);
		
		session.getTransaction().commit();
		HibernateUtils.closeSession();
		return message;
	}

	@SuppressWarnings("unchecked")
	public Messages getMessageByTitle(String title) {
		Session session = HibernateUtils.getSession();
		session.beginTransaction();
		
		List list = session.createQuery("from Messages where title="+title)
		                               .list();
		Messages message = (Messages)list.get(0);
		
		session.getTransaction().commit();
		HibernateUtils.closeSession();
		return message;
	}

	public void deleteMessages(String[] arr) {
		Session session = HibernateUtils.getSession();
		session.beginTransaction();
		
		for(int i = 0;i<arr.length;i++) {
			int id = Integer.parseInt(arr[i]);
			Messages message = (Messages)session.get(Messages.class, id);
			session.delete(message);
		}
		session.getTransaction().commit();
		HibernateUtils.closeSession();
	}

	public void saveMessage(String title, String content, Users user) {
		Session session = HibernateUtils.getSession();
		session.beginTransaction();
		
		Messages message = new Messages();
		message.setTitle(title);
		message.setContent(content);
		message.setUserId(user);
		message.setReaded(0);
		
		session.save(message);
		session.getTransaction().commit();
		HibernateUtils.closeSession();
		
	}

	public void updateMessage(int id) {
		Session session = HibernateUtils.getSession();
		session.beginTransaction();
		
		Messages message = (Messages)session.get(Messages.class, id);
		
	     message.setReaded(1);
	     session.getTransaction().commit();
	     HibernateUtils.closeSession();
		
	}

}