pages.java

jsp超市管理系统系统,是用经典的MVC设计模式开发的非常适合初学者学习。

package com.mybean;

import java.io.*;
import java.sql.*;
import com.dbconn.*;
import javax.servlet.http.HttpServletRequest;

public class Pages implements Serializable{

	/**
	 * @author LiPeng
	 */
	private static final long serialVersionUID = -1965040378925800598L;

	public final static int PAGE_SIZE = 3;		//每页显示记录数   
	private long totals; 							//总记录数
	private int allPage; 							//总页数
	private int currentPage; 						//当前页数
	private int startItem; 						//每页的开始行
	private String fileName;						//文件名
	private HttpServletRequest request;   
		
	/////////////////////////////////////////////////////////////////////////////////////
		
	/**
	 * 列表所有商品id1
	 */
	public static String limitQuery(int rowStart, int rowEnd){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, goods.* FROM goods ORDER BY tname) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	/**
	 * 列表所有员工id2
	 */	
	public static String limitQuery2(int rowStart, int rowEnd){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, consumer.* FROM consumer ORDER BY id) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }	
	
	/////////////////////////////////////////////////////////////////////////////////////
	
	/**
	 * 按条件查询商品
	 */
	
	//按条件查询商品
	public static String query1(int rowStart, int rowEnd, String content){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, goods.* FROM goods WHERE tname='"+content+"' ORDER BY tname) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	public static String query2(int rowStart, int rowEnd, String content){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, goods.* FROM goods WHERE type='"+content+"' ORDER BY tname) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	public static String query3(int rowStart, int rowEnd, String content){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, goods.* FROM goods WHERE code='"+content+"' ORDER BY tname) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }

	/////////////////////////////////////////////////////////////////////////////////
	
	/**
	 * 进货记录查询
	 */	
	
	//查询所有记录
	public static String limitQuery3(int rowStart, int rowEnd){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按时间查询
	public static String limitQuery4(int rowStart, int rowEnd, int time){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id AND time='"+time+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按商品名称查询
	public static String limitQuery7(int rowStart, int rowEnd, String tname){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id AND tname='"+tname+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
		//System.out.println(querySql);
		return querySql;
   }
	
	//按条形码查询
	public static String limitQuery8(int rowStart, int rowEnd, String code){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id AND code='"+code+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }

	//按商品类型查询
	public static String limitQuery9(int rowStart, int rowEnd, String type){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id AND type='"+type+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按操作员查询
	public static String limitQuery10(int rowStart, int rowEnd, String opid){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, buy.* FROM buy,goods WHERE buy.goodsid=goods.id AND opid='"+opid+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	/////////////////////////////////////////////////////////////////////////////////
	
	/**
	 * 销售记录查询
	 */	
	
	//查询所有销售记录
	public static String limitQuery11(int rowStart, int rowEnd){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按商品名称查询
	public static String limitQuery12(int rowStart, int rowEnd, String tname){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id AND tname='"+tname+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
		//System.out.println(querySql);
		return querySql;
   }
	
	//按条形码查询
	public static String limitQuery13(int rowStart, int rowEnd, String code){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id AND code='"+code+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按商品类型查询
	public static String limitQuery14(int rowStart, int rowEnd, String type){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id AND type='"+type+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }

	//按操作员查询
	public static String limitQuery15(int rowStart, int rowEnd, String opid){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id AND opid='"+opid+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	//按时间查询
	public static String limitQuery16(int rowStart, int rowEnd, int time){
		String querySql = "SELECT * FROM (SELECT rownum AS rn, code, tname, sell.* FROM sell,goods WHERE sell.goodsid=goods.id AND time='"+time+"' ORDER BY time) WHERE rn BETWEEN '"+rowStart+"' AND '"+rowEnd+"'";
        return querySql;
   }
	
	////////////////////////////////////////////////////////////////////////////////////////////////////
	
	public Pages(int currentPage, int totals, String fileName, HttpServletRequest request){		
		this(currentPage, totals, fileName);
		this.request = (HttpServletRequest)request;
	}
 
	private Pages(int currentPage, int totals, String fileName){
		
		if (currentPage <= 0){
			currentPage = 1;
		}
		int totalPages = totals / PAGE_SIZE;
		if (totals % PAGE_SIZE > 0){
			totalPages++;
		}
		this.currentPage = currentPage;
		this.totals = totals;
		this.fileName = fileName;
		if (currentPage > totalPages){
			this.currentPage = totalPages;
		}		
		doPageBreak();
	}
	
	/////////////////////////////////////////////////////////////////////////////////////
	
	public void doPageBreak(){
		allPage = (int) Math.ceil((totals + PAGE_SIZE - 1) / PAGE_SIZE);
		if(currentPage>0)
		{
		    startItem = (currentPage - 1) * PAGE_SIZE;
		}
		else
		{
		    startItem = 0;
		}
		getPageBreakStr();

	}

	private void getPageBreakStr(){

		StringBuffer sb = new StringBuffer();
		if (this.currentPage > 1){
            sb.append("[<a id='_firstPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=1' >");
            sb.append("首页");
            sb.append("</a>] ");
            sb.append("[<a id='_prePage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append((currentPage - 1));
            sb.append("'>");
            sb.append(" 上一页");
            sb.append("</a>] ");
		}
		else{
			sb.append("[首页] [上一页] ");
		}
		if (this.currentPage < this.allPage){
            sb.append("[<a id='_nextPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append((currentPage + 1));
            sb.append("' >");
            sb.append("下一页");
            sb.append("</a>] ");
            sb.append("[<a id='_endPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append(this.allPage);
            sb.append("' >");
            sb.append(" 尾页");
            sb.append("</a>] ");
		}
		else{
			sb.append("[下一页] [尾页] ");
		}
	}
    
	public String allString(){
		StringBuffer sb = new StringBuffer();
				sb.append("共")
				.append(totals)
				.append("条记录")
				.append(" 共")
				.append(allPage)
				.append("页")
				.append(" 当前第")
				.append(currentPage)
				.append("页    ");
		if (this.currentPage > 1){
            sb.append("[<a id='_firstPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=1' >");
            sb.append("首页");
            sb.append("</a>] ");
            sb.append("[<a id='_prePage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append((currentPage - 1));
            sb.append("'>");
            sb.append(" 上一页");
            sb.append("</a>] ");
		}
		else{
			sb.append("[首页] [上一页] ");
		}
		if (this.currentPage < this.allPage){
            sb.append("[<a id='_nextPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append((currentPage + 1));
            sb.append("' >");
            sb.append("下一页");
            sb.append("</a>] ");
            sb.append("[<a id='_endPage' ");
            sb.append("href='");
            sb.append(this.fileName);
            sb.append("&page=");
            sb.append(this.allPage);
            sb.append("' >");
            sb.append(" 尾页");
            sb.append("</a>] ");
		}
		else{
			sb.append("[下一页] [尾页] ");
		}
		return sb.toString();
	}
	
	
	 /**
	   * 计算strSql语句所统计的记录总数 
	   */
	  public static int allRecords(String sql){
			 int allRecords = 0;
			 
			 ResultSet rs = null;
			 PreparedStatement ps = null;

			 ConnManager connManager = new ConnManager();
			 Connection conn = connManager.getConnection("market");
			
			try {
				ps = conn.prepareStatement(sql);
				rs = ps.executeQuery();
				//System.out.println(sql);
				
				if(rs.next()){
					allRecords = rs.getInt(1);
				}
			} 
			catch (SQLException sqle) {
				sqle.printStackTrace();	
			}
			finally{
			    try{
			    	if(rs != null){ rs.close(); }
			    	if(ps != null){ ps.close(); }
			    }
				catch(SQLException sqle){
					System.out.println(sqle);
				}
				connManager.releaseConnection("market", conn);
		    }
			return allRecords;
		}
	  
		/////////////////////////////////////////////////////////////////////////////////////
		
		public HttpServletRequest getRequest(){
			return request;
		}
		public void setRequest(HttpServletRequest request){
			this.request = request;
		}	
		
		public String getFileName(){
			return fileName;
		}

		public void setFileName(String fileName){
			this.fileName = fileName;
		}

		public int getAllPage(){
			return allPage;
		}

		public void setAllPage(int allPage){
			this.allPage = allPage;
		}

		public int getCurrentPage(){
			return currentPage;
		}

		public void setCurrentPage(int currentPage){
			this.currentPage = currentPage;
		}

		public int getStartItem(){
			return startItem;
		}

		public void setStartItem(int startItem){
			this.startItem = startItem;
		}

		public long getTotals() {
			return totals;
		}
}