30d3907b913a001c1c71e0f80f7ae94d

是一个网上手机超市

package hall;

import java.sql.*;
import java.util.*;
import java.text.*;
import java.util.Date;

public class opMessage {
    private Vector messages;			
    private int page = 1;					//显示的页码
    private int pageSize=15;					//每页显示的留言数
    private int pageCount =0;				//页面总数
    private long recordCount =0;			        //查询的记录总数
    private String message = "";			        //出错信息提示
   // private String username = "";			     
    private DBWrapper myConnection = null;
    private String sqlStr = "";

    public opMessage()  throws Exception {
    	myConnection = DBWrapper.Instance();
    }
    
    public boolean addMessage(String name,String inContent){
    	boolean flag = false;
    	try{
    		Message tempMes = new Message();
    	//	System.out.println(tempMes.getMessageID());
    		Date tempDate = new Date();
    		tempMes.setleaverName(name);
    		tempMes.setContent(inContent); 
    		tempMes.setDate(tempDate);
    		
    		String sql = "INSERT INTO [messages]([messageName],[content],[time])values('" + tempMes.getLeaverName() + "','" + tempMes.getContent() 
    		+ "','" + tempMes.parseDate(tempDate)+ "')";
    		System.out.println(sql);
    		myConnection.runUpdate(sql);
    		
    		recordCount++;
    		pageCount = (int)(recordCount - 1) / pageSize + 1;
    		flag = true;
    	}catch(Exception e){
    		System.out.println(e);
    		flag = false;
    	}
    	    	
    	return flag;
    }
    
    public boolean get_allMessage() throws Exception {
    	sqlStr = "select count(*) from messages";    //取出记录数
    	int rscount = pageSize;
    	try{
    		ResultSet rs1 = myConnection.runQuery(sqlStr);
    		if (rs1.next()) 
    			recordCount = rs1.getInt(1);
    		rs1.close();
    	}catch (SQLException e){
    		System.out.print("count:"+e.getMessage());
        	return false;
    	}
    	//设定有多少pageCount
    	if (recordCount < 1)
    		pageCount = 0;
    	else
    		pageCount = (int)(recordCount - 1) / pageSize + 1;
    	//检查查看的页面数是否在范围内
    	if (page < 1)
        	page = 1;
        else if (page > pageCount)
        	page = pageCount;
        rscount = (int) recordCount % pageSize;	 // 最后一页记录数
          //sql为倒序取值
          sqlStr = "select  * from message ";
          if (page == 1){
        	  sqlStr = sqlStr + " order by messageID desc limit 0,"+pageSize;
          } else {
        	  sqlStr = sqlStr + " order by messageID desc limit "+(recordCount-pageSize*page) +","+(recordCount - pageSize * (page-1));
          }
          try{
          
        	ResultSet rs = myConnection.runQuery(sqlStr);
        	SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss");
        	messages = new Vector();
        	while (rs.next()){
        		Message mes = new Message();
        		mes.setleaverName(rs.getString("messageName"));
                mes.setContent(rs.getString("content"));
                Date tempDate = sdf.parse(rs.getString("time"));
                mes.setDate(tempDate);
                mes.setMessageID(rs.getLong("messageID"));
                
                messages.addElement(mes);
        		
        	}
        	rs.close();
                return true;
        }catch (SQLException e){
        	System.out.print(e.getMessage());
        	return false;
        }
    }
    
    public boolean delete(long inID) throws Exception {
	    sqlStr = "delete from message where messageID = "  + inID + "";
	    try{
	    	myConnection.runUpdate(sqlStr);
	    	recordCount--;
	    	return true;
	    }catch (SQLException e){
	    	   System.out.println(e);
	        return false;
	    }
    } 
    
    public int getPage() {				//显示的页码
		  return page;
	  }
	  public void setPage(int newpage) {
		  page = newpage;
	  }
	  
	  public int getPageSize(){			//每页显示的图书数
		  return pageSize;
	  }
	  public void setPageSize(int newpsize) {
		  pageSize = newpsize;
	  }
	
	  public int getPageCount() {		//页面总数
		  return pageCount;
	  }
	  public void setPageCount(int newpcount) {
		  pageCount = newpcount;
	  }
	
	  public long getRecordCount() {
		  return recordCount;
	  }
	  public void setRecordCount(long newrcount) {
		  recordCount= newrcount;
	  }
	
	  public String getMessage() {
		  return message;
	  }
	
	  public void setMessage(String msg) {
		  message = msg;
	  }
	
	 /* public void setUserName(String uName) {
		  username = uName;
	  }
	
	  public String getUserName() {
		  return username;
	  }*/
	  public Vector getMessages() {
		  return messages;
	  }
///////////////////////////////////////////
	  /*public static void main(String[] args){
		  
		  try{
			  opMessage temp =new opMessage();
			  temp.addMessage("aaa","bbbbb");
			  }
		  catch(Exception e){
			  System.out.println(e);
		  }
	  }*/
}