此分页程序用到三个文件test.jsp和Pagination.java和DBConnect.java,和一个简单数据库test的表test,测试用的web发布服务器为resin-2.1.6)其中test用于显示分页结果,DBConnect.java用于连接mysql数据库,Pagination.java用于封装分页程序,而且DBConnect.java和Pagination.java放在WEB-INF下的classes(注意,如果没有的话就新建一个),数据库用的是mysql.
1、create database test ----------建立数据库test
create table test(id int not null,name varchar(25));---------建立数据表test有两个字段,id和name类型分别是整形 和 字符型(有关mysql的操作请注意本站的数据库方面)
2、DBConnect.java
import java.sql.*;
public class DBConnect{
String sDBDriver="org.gjt.mm.mysql.Driver";//设置驱动变量(jdbc的驱动程序放在WEB-INF下的lib目录下)
String sConnStr="jdbc:mysql://127.0.0.1:3306/test?user=root&password=";//创建连接,数据库名test,连接mysql的用户名是root,密码为空(如果你的mysql有用户名和密码请填上你的用户名和密码)
Connection conn=null;
ResultSet rs=null;
public DBConnect(){
try{
Class.forName(sDBDriver);// 创建数据库驱动
}
catch(java.lang.ClassNotFoundException e){
System.out.println("Jdbc_conn():"+e.getMessage());
}
}
// 数据更新,本文只用到查询。
public void executeUpdate(String sql)throws Exception{
sql=new String(sql.getBytes("GBK"),"ISO8859_1");
try{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
conn.close();
stmt.close();
}
catch(SQLException ex){
System.out.println("sql.executeUpdate:"+ex.getMessage());
}
}
// 查询
public ResultSet executeQuery(String sql)throws Exception{
rs=null;
try{
sql=new String(sql.getBytes("GBK"),"ISO8859_1");// 字符的转换
conn=DriverManager.getConnection(sConnStr);// 创建连接
Statement stmt=conn.createStatement();// 数据操作对象
rs=stmt.executeQuery(sql);//执行sql
conn.close();// 关闭连接
stmt.close();// 关闭对象
}
catch(SQLException ex){
System.out.println("sql.executeQuery:"+ex.getMessage());
}
return rs;
}
}
用Pagination.java封装分页类,在test.jsp里显示
2、Pagination.java--------封装分页的类
import java.sql.*;
import javax.servlet.*;// 引入servlet包
import javax.servlet.http.*;
import java.math.*;
public class Pagination{
private String strPage = null;// page参数变量
private int curPages;// page参数内部的值
private int m_rows; // 设置每页显示的页数
private int pages;// 总页数
// 取得test.jsp里的test.jsp?page=<%=curPages-1%>或是page=<%=curPages+1%>的值给变量strPage
public String strPage(HttpServletRequest request, String page){
try{
strPage = request.getParameter(page);// request对象取得page的值
}
catch(Exception e){
System.out.println("delcolumn"+e.getMessage());
}
return strPage;// 返回这个值。
}
// 页面数
public int curPages(String strPage){
try{
if(strPage == null){// 默认没有就设置是第一页
curPages = 1;
}
else{
curPages = Integer.parseInt(strPage);// 取得strPage的整数值
if(curPages < 1)// 如果小于1,同样返回是第一页
curPages = 1;
}
}
catch(Exception e){
System.out.print("curPages");
}
return curPages;// 返回页面数
}
// 设置每页要显示的记录数
public void setRows(int rows){
m_rows=rows;
}
// 取得页数
public int getPages(int rowcounts){
int test;// 变量
test=rowcounts%m_rows;// 取得余数
if(test==0)
pages = rowcounts/m_rows;// 每页显示的整数
else
pages=rowcounts/m_rows+1;// 不是的话就加一
return pages;// 返回页数
}
// 结果集的返回
public ResultSet getPageSet(ResultSet rs,int curPages){
if(curPages==1){
return rs;// 如果是就一页的话,就返回这个rs
}
else{
int i=1;
try{
while(rs.next()){
i=i+1;
if(i>((curPages-1)*m_rows))
break;// 退出
}
return rs;// 从退出开始将结果集返回
}
catch(Exception e){
System.out.print(e.getMessage());
}
}
return rs;
}
}
3.test.jsp --------显示页面
<%@ page contentType="text/html;charset=gb2312"%>
<%@ page import="java.sql.*"%>
<%
int curPages = Pagination.curPages(Pagination.strPage(request,"page"));//Pagination.strPage(request,"page")取page值传递给curPages()方法
Pagination.setRows(10);//设置每页显示10条
%>
<%
ResultSet rs_count=sql.executeQuery("select count(*) as t from test");//传递进数据库处理的javabean
rs_count.next();
int resultconts=rs_count.getInt("t");//取得总的数据数
int totalPages = Pagination.getPages(resultconts);//取出总页数
ResultSet rs=m_pages.getPageSet(sql.executeQuery("select * from test"),curPages);//获取指针的结果集参数是(结果集,页数)
%>
分类表
1 |
2 |
3 |
<%int i=1;%>
<%while (rt.next()){%>
<%=rt.getString("id")%> |
<%=rt.getString("name")%> |
<%
i=i+1;
if(i>10)
break;
}
%>
<%if(curPages>1){%>">上一页<%}%><%if(curPages">下一页<%}%>