opmessage.java

是一个网上手机超市

package hall;

/**
 * Project:    NWPU online shop
 * JDK version used: jdk1.5.0
 * Version: 	1.01
 * class opMessage 用来处理有关于留言的各种操作
 */

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 = 10; //每页显示的留言数

	private int pageCount = 0; //页面总数

	private long recordCount = 0; //查询的记录总数

	private DBWrapper myConnection = null;

	private String sqlStr = "";

	public opMessage() throws Exception {
		myConnection = DBWrapper.Instance();
	}

	/**
	 * boolean addMessage(String name, String inContent)
	 * Description :用户发表新留言
	 * @param String 用户名
	 * @param String 留言内容
	 * @return boolean 返回操作是否成功信息
	 */
	public boolean addMessage(String name, String inContent) {
		boolean flag = false;
		try {
			Message tempMes = new Message();
			Date tempDate = new Date();//由当地时间确定留言时间
			tempMes.setleaverName(name);
			tempMes.setContent(inContent);
			tempMes.setDate(tempDate);
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss");

			String sql = "INSERT INTO [messages]([messageName],[content],[time])values('"
					+ tempMes.getLeaverName()
					+ "','"
					+ tempMes.getContent()
					+ "','" + sdf.format(tempDate) + "')";
			myConnection.runUpdate(sql);

			recordCount++;
			pageCount = (int) (recordCount - 1) / pageSize + 1;
			flag = true;
		} catch (Exception e) {
			System.out.println(e);
			flag = false;
		}

		return flag;
	}

	/**
	 * boolean get_allMessage()
	 * Description :得到所有留言，并将用户所需要页的留言放进Vector中供别人或方法取用
	 * 
	 * @return boolean 返回操作是否成功信息
	 */
	public boolean get_allMessage() throws Exception {
		sqlStr = "select count(*) from messages"; //取出记录数
		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;

		try {

			sqlStr = "select  * from messages order by messageID";
			ResultSet rs = myConnection.runQuery(sqlStr);
			if (page == 1) {

			} else {
				for (int i = 0; i < pageSize * (page - 1); i++) {
					rs.next();
				}
			}
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss");
			messages = new Vector();
			for (int i = 0; i < pageSize; i++) {
				if (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);
				} else {
					break;
				}

			}
			rs.close();
			return true;
		} catch (SQLException e) {
			System.out.print(e.getMessage());
			return false;
		}
	}

	/**
	 * boolean delete(String inID)
	 * Description :删除用户的一条指定留言
	 * @param String 留言的ID
	 * @return boolean 返回操作是否成功信息
	 */
	public boolean delete(String 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;
		}
	}

	/**
	 * int getPage()
     * Description :得到要显示的页数
     * @return int
     */
	public int getPage() { 
		return page;
	}

	/**
	 * void setPage(int newpage)
     * Description :修改要显示的页数
     * @param int
     */
	public void setPage(int newpage) {
		page = newpage;
	}

	/**
	 * int getPageSize()
     * Description :得到每页要显示的收藏数
     * @return int
     */
	public int getPageSize() { 
		return pageSize;
	}

	/**
	 * void setPageSize(int newpsize)
     * Description :修改每页要显示的收藏数
     * @param int
     */
	public void setPageSize(int newpsize) {
		pageSize = newpsize;
	}

	/**
	 * int getPageCount()
     * Description :得到页面总数
     * @return int
     */
	public int getPageCount() { 
		return pageCount;
	}

	/**
	 * void setPageCount(int newpcount)
     * Description :修改页面总数
     * @param int
     */
	public void setPageCount(int newpcount) {
		pageCount = newpcount;
	}

	/**
	 * int getRecordCount()
     * Description :得到记录总数
     * @return long
     */
	public long getRecordCount() {
		return recordCount;
	}

	/**
	 * void setRecordCount(long newrcount)
     * Description :修改记录总数
     * @param long
     */
	public void setRecordCount(long newrcount) {
		recordCount = newrcount;
	}

	/**
	 * Vector getCollectList()
     * Description :得到存储留言的Vector 
     * @return Vector
     */
	public Vector getMessages() {
		return messages;
	}
}