messagedaobean.java

基于Spring2.5的精品课程网站

package org.adam.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.adam.DataSource.DBControl;
import org.adam.bean.MessageBean;

import org.adam.dao.MessageDAO;
@SuppressWarnings("unchecked")
public class MessageDAOBean implements MessageDAO {

	private DBControl db;
	
	public void delete(int message_id) {
		String sql="delete from message where message_id="+message_id;
		db.setDataInfo(sql);
	}

	public MessageBean getMessage(int message_id) {
		String sql="select * from message where message_id="+message_id;
		ResultSet rs=db.getDataInfo(sql);
		MessageBean msg=new MessageBean();
		try {
			while(rs.next()){
				msg.setMessage_id(rs.getInt("message_id"));
				msg.setStudent_id(rs.getInt("student_id"));
				msg.setTeacher_id(rs.getInt("teacher_id"));
				msg.setTitle(rs.getString("title"));
				msg.setMessage(rs.getString("message"));
				msg.setTime(rs.getString("time"));
				msg.setRemessage(rs.getString("remessage"));
			}
			return msg;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

	public List<MessageBean> getMessages(int teacher_id) {
		String sql="select * from message where teacher_id="+teacher_id;
		ResultSet rs=db.getDataInfo(sql);
		MessageBean msg;
		List<MessageBean> list=new ArrayList<MessageBean>();
		try {
			while(rs.next()){
				msg=new MessageBean();
				msg.setMessage_id(rs.getInt("message_id"));
				msg.setStudent_id(rs.getInt("student_id"));
				msg.setTeacher_id(rs.getInt("teacher_id"));
				msg.setTitle(rs.getString("title"));
				msg.setMessage(rs.getString("message"));
				msg.setTime(rs.getString("time"));
				msg.setRemessage(rs.getString("remessage"));
				list.add(msg);
			}
			return list;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

	public void resay(MessageBean message) {
		String sql="update message set remessage='"+message.getRemessage()+"' where message_id="+message.getMessage_id();
		db.setDataInfo(sql);
	}

	public void say(MessageBean message) {
		String sql="call addmessage("+message.getTeacher_id()+","+message.getStudent_id()+",'"+message.getTitle()+"','"+message.getMessage()+"','"+message.getTime()+"','"+message.getRemessage()+"')";
		db.setDataInfo(sql);
	}

	public DBControl getDb() {
		return db;
	}

	public void setDb(DBControl db) {
		this.db = db;
	}

	public List getMessages(int teacher_id, int nowpage,
			int pagecount) {
		String sql="select * from message,student where message.student_id=student.student_id and message.teacher_id="+teacher_id+" limit "+(nowpage-1)*pagecount+","+pagecount;
		System.out.println(sql);
		ResultSet rs=db.getDataInfo(sql);
		MessageBean msg;
		List<MessageBean> list=new ArrayList<MessageBean>();
		try {
			while(rs.next()){
				msg=new MessageBean();
				msg.setMessage_id(rs.getInt("message_id"));
				msg.setStudent_id(rs.getInt("student_id"));
				msg.setTeacher_id(rs.getInt("message.teacher_id"));
				msg.setTitle(rs.getString("title"));
				msg.setMessage(rs.getString("message"));
				msg.setTime(rs.getString("time"));
				msg.setRemessage(rs.getString("remessage"));
				msg.setStudentname(rs.getString("studentname"));
				msg.setStudentemail(rs.getString("studentemail"));
			    list.add(msg);
			}
			return list;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}finally{
			db.closeConnection();
		}
	}

	public int getCounts(int teacher_id) {
		String sql="select count(message_id)as messagecount from message where teacher_id="+teacher_id;
		ResultSet rs=db.getDataInfo(sql);
		int number=0;
		try {
			while(rs.next()){
				number=rs.getInt("messagecount");
			}
			return number;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			return 0;
		}finally{
			db.closeConnection();
		}
		
	}

}