messageda.java

医药供应链管理系统

package com.captainli.dboperation;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import com.captainli.bean.MessageBean;
import com.captainli.util.GetConnection;

/**
 * message表数据库操作类
 * @author CaptainLi
 *
 */
public class MessageDA {
	private Connection conn = GetConnection.getConn();
	private PreparedStatement pstmt = null;
	private Statement stmt = null;
	private ResultSet rs = null;
	/**
	 * 关闭数据库对象
	 *
	 */
	public void closeDB(){
		try {
			if(rs != null){
				rs.close();
			}
			if(stmt != null){
				stmt.close();
			}
			if(pstmt != null){
				pstmt.close();
			}
			if(conn != null){
				conn.close();
			}
		} catch (Exception e) {
			e.getStackTrace();
		}
	}
	/**
	 * 加入消息
	 * @param bean
	 */
	public void addMessage(MessageBean bean){
		String sql = "insert into message values (?, ?, ?, ?, ?)";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, bean.getM_content());
			pstmt.setInt(2, bean.getM_reciever());
			pstmt.setInt(3, bean.getM_sender());
			pstmt.setString(4, bean.getM_time());
			pstmt.setBoolean(5, bean.isM_type());
			pstmt.execute();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			closeDB();
		}
	}
	/**
	 * 通过接受人查找未读信息
	 * @param m_reciever
	 * @return
	 */
	public boolean showMessage(int m_reciever){
		String sql = "select * from message where m_type = 0 and m_reciever = ?";
		boolean flag = false;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, m_reciever);
			rs = pstmt.executeQuery();
			if(rs.next()){
				flag = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			closeDB();
		}
		return flag;
	}
	/**
	 * 修改消息为已读
	 * @param m_reciever
	 * @param p_no
	 */
	public void updateMessage(int m_reciever){
		String sql = "update message set m_type = ? where m_reciever = ?";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setBoolean(1, true);
			pstmt.setInt(2, m_reciever);
			pstmt.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			closeDB();
		}
	}
	/**
	 * 通过接受者返回未读信息集合
	 * @param m_reciever
	 * @return
	 */
	public ArrayList showMessageBean(int m_reciever){
		ArrayList arry = new ArrayList();
		MessageBean bean = null;
		String sql = "select * from message where m_type = 0 and m_reciever = ?";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, m_reciever);
			rs = pstmt.executeQuery();
			while(rs.next()){
				bean = new MessageBean();
				bean.setM_content(rs.getString("m_content"));
				bean.setM_time(rs.getString("m_time"));
				arry.add(bean);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			closeDB();
		}
		return arry;
	}
}