messagemanager.java

基于J2EE的网络物流系统 用户操作： 1． 录入出库商品信息 2． 查询出库单信息 3． 录入入库商品信息 4． 查询入库单信息 5． 查询商品位置信息 6． 查询商品信息 7． 查

package com.logistic.business;

import com.logistic.data.DataConnect;
import com.logistic.model.MessageInfo;
import java.sql.ResultSet;
import java.sql.Statement;
import com.logistic.business.PageAble;
import java.util.Vector;
import com.logistic.dao.IMessageDAO;

public class MessageManager implements IMessageDAO{
	
	DataConnect dc=new DataConnect();
	ResultSet   rs=null;
	Statement    stat=null;
		
	public   Vector MessageSearch(String strsql,int page){
		
		Vector items=new Vector();
		try{
			
			stat=dc.getStmtread();
			rs=stat.executeQuery(strsql);
			PageAble pgb=new PageAble(rs);
			pgb.setPagesize(5);
			pgb.setCurrentpage(1);
			pgb.gotoPage(page);
			
			rs.absolute(pgb.getRowscount());
			int i=0;
			do{
				items.add(new MessageInfo(rs.getString("ID"),rs.getString("MessageId"),rs.getString("EmployeeId"),rs.getString("MessageTitle"),rs.getString("MessageTime"),rs.getString("MessageContent")));
			   }while(rs.next()&&i<pgb.getCurrentPageRowsCount());
	
			}catch(Exception ex){
			ex.printStackTrace();
			}finally{dc.close();}
		return items;
		
	}
	
	public int AddMessage(String messageid,String employeeid,String mpostdatetime,String messagetitle,String messagecontent){
		
		int flag=-10;
		try{
		String	mid=messageid;
		String  eid=employeeid;
		String  mdt=mpostdatetime;
		String  mt=messagetitle;
		String  mc=messagecontent;
		
		String sqls="insert into messageinfotable(MessageId,EmployeeId,MessageTitle,MessageTime,MessageContent)values('"+mid+"','"+eid+"','"+mdt+"','"+mt+"','"+mc+"')";
		 
		flag=0;
		flag=dc.updata(sqls);
		if(flag>0){
			   System.out.print("公告信息添加成功!");
		  }else{
			  System.out.print("公告信息添加失败!");
		  }
		}catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
	return flag;
	}
	
	public int DelMessage(String messageid){
		
		String delmessage="delete from messageinfotable where MessageId="+messageid;
		
		int flag=0;
		
		try{
			flag=dc.updata(delmessage);
			if(flag>0){
				System.out.println("公告信息删除成功，编号:"+messageid);
			   }else{
				System.out.println("公告信息删除失败，编号:"+messageid);
			         }
		    }catch(Exception ex){ex.printStackTrace();}finally{dc.close();}
			
	    return flag;
		
	}
	
}