messagemanagerdao.java

老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的

package com.wl.dao;

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

import com.wl.dbconnection.DBManager;
import com.wl.entity.MessageInfo;

/**
 * 公告信息dao方法
 * 
 * @author yuan xinfeng
 * 
 */
public class MessageManagerDAO {

	public MessageManagerDAO() {

	}

	/**
	 * 添加公告信息
	 * 
	 * @param messageid
	 * @param employeeid
	 * @param mpostdatetime
	 * @param messagetitle
	 * @param messagecontent
	 * @return boolean
	 */
	public boolean AddMessage(String messageid, int employeeid,
			String mpostdatetime, String messagetitle, String messagecontent) {
		String mid = messageid;// 公告信息Id
		int eid = employeeid;// 发布公告的职员Id
		String mdt = mpostdatetime;// 公告发布时间
		String mt = messagetitle;// 公告标题
		String mc = messagecontent;// 公告内容
		String sqls = "insert into messageinfotable(MessageId,EmployeeId,MessageTitle,MessageTime,MessageContent)values(?,?,?,?,?)";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sqls);
			db.ps.setString(1, mid);
			db.ps.setInt(2, eid);
			db.ps.setString(3, mdt);
			db.ps.setString(4, mt);
			db.ps.setString(5, mc);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			System.out.println("数据库打开失败！");
			e.printStackTrace();
			return false;
		} finally {
			db.closeDB();// 关闭数据库
		}
		return true;
	}

	/**
	 * 按照公告信息Id删除公告信息
	 * 
	 * @param messageid
	 * @return boolean
	 */
	public boolean DelMessage(String messageid) {
		String delmessage = "delete from messageinfotable where MessageId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(delmessage);
			db.ps.setString(1, messageid);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			System.out.println("数据库连接失败！");
			e.printStackTrace();
			return false;
		} finally {
			db.closeDB();// 关闭数据库
		}
		return true;
	}

	/**
	 * 按照公告信息标题删除公告信息
	 * 
	 * @param messagetitle
	 * @return boolean
	 */
	public boolean DelMessageByTitle(String messagetitle) {
		String delmessage = "delete from messageinfotable where MessageTitle=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(delmessage);
			db.ps.setString(1, messagetitle);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			System.out.println("数据库连接失败！");
			e.printStackTrace();
			return false;
		} finally {
			db.closeDB();// 关闭数据库
		}
		return true;
	}

	/**
	 * 根据公告发布时间删除公告信息
	 * 
	 * @param messagetime
	 * @return boolean
	 */
	public boolean delMessageByTime(String messagetime) {
		String sql = "delete from messageinfotable where MessageTime=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, messagetime);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			System.out.println("数据库连接失败！");
			e.printStackTrace();
			return false;
		} finally {
			db.closeDB();// 关闭数据库
		}

		return true;
	}

	/**
	 * 根据公告信息id查询公告信息
	 * 
	 * @param messageid
	 * @return list
	 */
	public List<MessageInfo> selectMessageInfoBymessageId(String messageid) {
		List<MessageInfo> list = new ArrayList<MessageInfo>();
		String sql = "select * from  messageinfotable  where MessageId=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, messageid);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				messageid = rs.getString("MessageId");
				int employeeid = rs.getInt("EmployeeId");
				String messagetitle = rs.getString("MessageTitle");
				String messagetime = rs.getString("MessageTime");
				String messagecontent = rs.getString("MessageContent");
				MessageInfo messageinfo = new MessageInfo(id, messageid,
						employeeid, messagetitle, messagetime, messagecontent);
				list.add(messageinfo);
			}
		} catch (SQLException e) {
			System.out.println("数据库连接失败!");
			e.printStackTrace();
		} finally {
			db.closeDB();
		}

		return list;
	}

	/**
	 * 根据公告标题查询公告信息
	 * 
	 * @param messagetitle
	 * @return list
	 */
	public List<MessageInfo> selectMessageInfoBymessageTitle(String messagetitle) {
		List<MessageInfo> list = new ArrayList<MessageInfo>();
		String sql = "select * from  messageinfotable  where MessageTitle=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, messagetitle);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				String messageid = rs.getString("MessageId");
				int employeeid = rs.getInt("EmployeeId");
				messagetitle = rs.getString("MessageTitle");
				String messagetime = rs.getString("MessageTime");
				String messagecontent = rs.getString("MessageContent");
				MessageInfo messageinfo = new MessageInfo(id, messageid,
						employeeid, messagetitle, messagetime, messagecontent);
				list.add(messageinfo);
			}
		} catch (SQLException e) {
			System.out.println("数据库连接失败!");
			e.printStackTrace();
		} finally {
			db.closeDB();
		}

		return list;
	}

	/**
	 * 根据公告发布时间查询公告信息
	 * 
	 * @param messagetime
	 * @return list
	 */
	public List<MessageInfo> selectMessageInfoBymessageTime(String messagetime) {
		List<MessageInfo> list = new ArrayList<MessageInfo>();
		String sql = "select * from  messageinfotable  where MessageTime=?";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, messagetime);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				String messageid = rs.getString("MessageId");
				int employeeid = rs.getInt("EmployeeId");
				String messagetitle = rs.getString("MessageTitle");
				messagetime = rs.getString("MessageTime");
				String messagecontent = rs.getString("MessageContent");
				MessageInfo messageinfo = new MessageInfo(id, messageid,
						employeeid, messagetitle, messagetime, messagecontent);
				list.add(messageinfo);
			}
		} catch (SQLException e) {
			System.out.println("数据库连接失败!");
			e.printStackTrace();
		} finally {
			db.closeDB();
		}

		return list;
	}
	/**
	 * 查询所有的公告信息
	 * @return list
	 */
	public List<MessageInfo> selectMessageInfo() {
		List<MessageInfo> list = new ArrayList<MessageInfo>();
		String sql = "select messageinfotable.id,MessageId," +
				"messageinfotable.EmployeeId,MessageTitle,MessageTime," +
				"MessageContent,loginName from  messageinfotable,LoginTable " +
				"where messageinfotable.EmployeeId=LoginTable.id";
		DBManager db = new DBManager();// 实例化数据库对象
		db.openDB();// 打开数据库
		try {
			db.ps = db.conn.prepareStatement(sql);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				String messageid = rs.getString("MessageId");
				String name=rs.getString("LoginName");
				int employeeid = rs.getInt("EmployeeId");
				String messagetitle = rs.getString("MessageTitle");
				String messagetime = rs.getString("MessageTime");
				String messagecontent = rs.getString("MessageContent");
				MessageInfo messageinfo = new MessageInfo(id,messageid,name,
						employeeid, messagetitle, messagetime, messagecontent);
				list.add(messageinfo);
			}
		} catch (SQLException e) {
			System.out.println("数据库连接失败!");
			e.printStackTrace();
		} finally {
			db.closeDB();
		}

		return list;
	}
/**
 * 根据公告编号删除公告信息
 * @param id
 * @return
 */  
public boolean deleteMessageById(int id){
	  DBManager dbmanager=new DBManager();
	  boolean flage=dbmanager.openDB();
	  if(flage){
		  try{
		  dbmanager.ps=dbmanager.conn.prepareStatement("delete messageinfotable where id=?");
		  dbmanager.ps.setInt(1,id);
		  dbmanager.ps.executeUpdate();
		  }
		  catch(Exception e){
			  System.out.print("数据删除失败！");
		  }
		  finally{
			  dbmanager.closeDB();
		  }
		  return true;  
	  }
	  else{
		  return false;
	  }
  }
/**
 * tian xiaoshun
 * @param messageId
 * @return
 */
public MessageInfo selectMessageInfoById(int messageId) {
	String sql = "select messageinfotable.id,MessageId," +
				"messageinfotable.EmployeeId,MessageTitle,MessageTime," +
				"MessageContent,loginName from  messageinfotable,LoginTable " +
				"where messageinfotable.EmployeeId=LoginTable.id and messageinfotable.id=?";
	DBManager db = new DBManager();// 实例化数据库对象
	boolean flage=db.openDB();// 打开数据库
	MessageInfo messageinfo=null;
	if(flage){
	try {
		db.ps = db.conn.prepareStatement(sql);
		db.ps.setInt(1, messageId);
		ResultSet rs = db.ps.executeQuery();
		while (rs.next()) {
			int id = rs.getInt("Id");
			String messageid = rs.getString("MessageId");
			String name=rs.getString("LoginName");
			int employeeid = rs.getInt("EmployeeId");
			String messagetitle = rs.getString("MessageTitle");
			String messagetime = rs.getString("MessageTime");
			String messagecontent = rs.getString("MessageContent");
			messageinfo = new MessageInfo(id,messageid,name,
					employeeid, messagetitle, messagetime, messagecontent);
		}
	} catch (SQLException e) {
		System.out.println("查询出错!");
		e.printStackTrace();
	}
	finally {
		db.closeDB();
	}
	}
	else
	{
		System.out.print("数据库打开失败！");
	}
	return messageinfo;
}
/**
 * 根据Id修改公告表
 * @param messagecontent
 * @param id
 * @return
 */
  public boolean updataMessage(String messagecontent,int id){
	  DBManager db=new DBManager();
	  boolean flage=db.openDB();
	  if(flage){
	   try{
	   db.ps=db.conn.prepareStatement("update  messageinfotable  set messagecontent=? where id=?");	
	   db.ps.setString(1,messagecontent);
	   db.ps.setInt(2,id);
	   db.ps.executeUpdate();
	   }
	   catch(Exception e){
		   return false;
	   }
	  return true;  
	  }
	  else{
		  return false;
	  }
  }
}