jsp分页访问数据库实用的例子介绍.

在jsp开发中，在前台的数据展示页面，经常遇到这样的情况，很多条的数据，有几十上百条，而只显示10条，然后翻页显示下面的十条，如下图所示：

 

 

处理方式：一：首先sql语句，使用not in的方式处理，

在dao类里写一个方法

public List<> getAllByPage(int pageSize,pageNum){

……

 

String sql=”select top”+pageSize +” * from 表名x where 字段A not in (select top “+pageSize*(pageNum-1)+”  字段A from 表名x)”;

…….

rerun list;

}

其中，pageSize是页面要显示的条数，pageNum是要显示的页码,其中的sql语句基本是固定的,返回一个list对象。

二：在Biz里写一个方法，调用Dao里的这个getAllByPage方法，传入的也是两个参数，返回的也是list结果集。

三：在jsp页面以url传参的方式进行页面处理和数据的显示。

使用request对象获取传入的值，然后进行强制类型转换之后就可以作为参数，传入到Biz业务类的方法中去处理，返回的就是list结果集，然后使用表达式的方式在页面中进行显示就可以了。

综上：这就是分页显示数据的一个方法，

 

下面是一个小小的例子。

问题需求：开发一个小的留言板页面，页面能够以分页的形式显示所有留言信息，下放是一个发表留言的表单。

所有代码如下：

数据库如图：

实体类（entity）如下：

[java] view plaincopyprint?

1. package com.rz.entity;
3. import java.util.Date;
5. public class Message {
6.     private int id;             //留言id
7.     private String message;     //留言信息
8.     private String author;      //留言作者
9.     private Date postTime;      //留言时间
13.     public int getId() {
14.         return id;
15.     }
16.     public void setId(int id) {
17.         this.id = id;
18.     }
19.     public String getMessage() {
20.         return message;
21.     }
22.     public void setMessage(String message) {
23.         this.message = message;
24.     }
25.     public String getAuthor() {
26.         return author;
27.     }
28.     public void setAuthor(String author) {
29.         this.author = author;
30.     }
31.     public Date getPostTime() {
32.         return postTime;
33.     }
34.     public void setPostTime(Date postTime) {
35.         this.postTime = postTime;
36.     }
39. }

package com.rz.entity;

import java.util.Date;

public class Message {
	private int id;				//留言id
	private String message;		//留言信息
	private String author;		//留言作者
	private Date postTime;		//留言时间

	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getMessage() {
		return message;
	}
	public void setMessage(String message) {
		this.message = message;
	}
	public String getAuthor() {
		return author;
	}
	public void setAuthor(String author) {
		this.author = author;
	}
	public Date getPostTime() {
		return postTime;
	}
	public void setPostTime(Date postTime) {
		this.postTime = postTime;
	}

}

 

 

dao类如下：（包括链接jdbc数据库）

[java] view plaincopyprint?

1. package com.rz.dao;
3. import com.rz.entity.*;
4. import java.sql.*;
5. import java.util.*;
7. public class MessageDao {
8.     private String driver=”com.microsoft.sqlserver.jdbc.SQLServerDriver”;
9.     private String url=”jdbc:sqlserver://localhost:1433;DataBaseName=message”;
10.     private String name=”sa”;
11.     private String password=”lishiyuzuji”;
15.     /**
16.      * 保存一条记录
17.      * @param message
18.      * @return
19.      */
20.     public int save(Message message){
21.         int line=0;             //保存记录的行数
22.         Connection con=null;
23.         PreparedStatement pstat=null;
24.         try{
25.             con=getConn();
26.             pstat=con.prepareStatement(“insert into TBL_MESSAGE(message,author,postTime) values(?,?,getdate())”);
27.             pstat.setString(1,message.getMessage());
28.             pstat.setString(2,message.getAuthor());
29.             line=pstat.executeUpdate();
31.         }catch(SQLException e){
32.             e.printStackTrace();
33.         }finally{
34.             closeAll(null,pstat,con);
35.         }
36.         return line;
37.     }
39.     /**
40.      * 分页显示信息
41.      * @param pageSize 每页显示的信息数量
42.      * @param pageNum  定位到那一页
43.      * @return
44.      */
45.     public List<Message> listByPage(int pageSize,int pageNum){
46.         Connection con=null;
47.         PreparedStatement pstat=null;
48.         ResultSet res=null;
49.         List<Message> list=new ArrayList<Message>();
50.         try{
51.             con=getConn();
52.             pstat=con.prepareStatement(“select top “+pageSize+
53.                     ” * from TBL_MESSAGE where id not in (select top “+pageSize*(pageNum-1)+
54.                     ” id from TBL_MESSAGE order by postTime) order by postTime”);
55.             res=pstat.executeQuery();
56.             while(res.next()){
57.                 Message message=new Message();
58.                 message.setId(res.getInt(1));
59.                 message.setMessage(res.getString(2));
60.                 message.setAuthor(res.getString(3));
61.                 message.setPostTime(res.getDate(4));
62.                 list.add(message);
63.             }
64.         }catch(SQLException e){
65.             e.printStackTrace();
66.         }finally{
67.             closeAll(res,pstat,con);
68.         }
69.         return list;
70.     }
72.     /**
73.      * 获得记录的总条数
74.      * @return  返回查询到的所有记录的总条数
75.      */
76.     public int getAllUserCount(){
77.         Connection con=null;
78.         PreparedStatement pstat=null;
79.         ResultSet res=null;
80.         int ret = 0;
81.         try{
82.             con=getConn();
83.             pstat=con.prepareStatement(“select count(*) from TBL_MESSAGE”);
84.             res=pstat.executeQuery();
85.             if(res.next()){
86.                 ret=res.getInt(1);
87.             }
88.         }catch(SQLException e){
89.             e.printStackTrace();
90.         }finally{
91.             closeAll(res,pstat,con);
92.         }
93.         return ret;
94.     }
98.     /**
99.      * 连接数据库
100.      */
101.     public Connection getConn(){
102.         Connection con=null;
103.         try{
104.             Class.forName(driver);
105.             con=DriverManager.getConnection(url,name,password);
106.         }catch(ClassNotFoundException e){
107.             e.printStackTrace();
108.         }catch(SQLException e){
109.             e.printStackTrace();
110.         }
111.         return con;
112.     }
116.     /**
117.      * 关闭数据库连接，而且三者是有顺序的，先关闭ResultSet连接，接着关闭Statement连接，最后关闭Connection连接
118.      * 并且还要抛出异常。数据库连接使用完毕以后需要关闭连接的，否则，连接数据库的“通道”就会继续增加，而数据库的连接
119.      * 能力也是有限的，大约是200个，因此需要在使用完数据库后将连接关闭掉。
120.      * @param res
121.      * @param stat
122.      * @param conn
123.      */
124.     public void closeAll(ResultSet res,PreparedStatement pstat,Connection con){
125.         try{
126.             if(res!=null){
127.                 res.close();
128.                 res=null;
129.             }
130.             if(pstat!=null){
131.                 pstat.close();
132.                 pstat=null;
133.             }
134.             if(con!=null){
135.                 con.close();
136.             }
137.         }catch(SQLException e){
138.             e.printStackTrace();
139.         }
141.     }
143. }

package com.rz.dao;

import com.rz.entity.*;
import java.sql.*;
import java.util.*;

public class MessageDao {
	private String driver="com.microsoft.sqlserver.jdbc.SQLServerDriver";
	private String url="jdbc:sqlserver://localhost:1433;DataBaseName=message";
	private String name="sa";
	private String password="lishiyuzuji";

	/**
	 * 保存一条记录
	 * @param message
	 * @return
	 */
	public int save(Message message){
		int line=0;				//保存记录的行数
		Connection con=null;
		PreparedStatement pstat=null;
		try{
			con=getConn();
			pstat=con.prepareStatement("insert into TBL_MESSAGE(message,author,postTime) values(?,?,getdate())");
			pstat.setString(1,message.getMessage());
			pstat.setString(2,message.getAuthor());
			line=pstat.executeUpdate();

		}catch(SQLException e){
			e.printStackTrace();
		}finally{
			closeAll(null,pstat,con);
		}
		return line;
	}

	/**
	 * 分页显示信息
	 * @param pageSize 每页显示的信息数量
	 * @param pageNum  定位到那一页
	 * @return
	 */
	public List<Message> listByPage(int pageSize,int pageNum){
		Connection con=null;
		PreparedStatement pstat=null;
		ResultSet res=null;
		List<Message> list=new ArrayList<Message>();
		try{
			con=getConn();
			pstat=con.prepareStatement("select top "+pageSize+
					" * from TBL_MESSAGE where id not in (select top "+pageSize*(pageNum-1)+
					" id from TBL_MESSAGE order by postTime) order by postTime");
			res=pstat.executeQuery();
			while(res.next()){
				Message message=new Message();
				message.setId(res.getInt(1));
				message.setMessage(res.getString(2));
				message.setAuthor(res.getString(3));
				message.setPostTime(res.getDate(4));
				list.add(message);
			}
		}catch(SQLException e){
			e.printStackTrace();
		}finally{
			closeAll(res,pstat,con);
		}
		return list;
	}

	/**
	 * 获得记录的总条数
	 * @return	返回查询到的所有记录的总条数
	 */
	public int getAllUserCount(){
		Connection con=null;
		PreparedStatement pstat=null;
		ResultSet res=null;
		int ret = 0;
		try{
			con=getConn();
			pstat=con.prepareStatement("select count(*) from TBL_MESSAGE");
			res=pstat.executeQuery();
			if(res.next()){
				ret=res.getInt(1);
			}
		}catch(SQLException e){
			e.printStackTrace();
		}finally{
			closeAll(res,pstat,con);
		}
		return ret;
	}

	/**
	 * 连接数据库
	 */
	public Connection getConn(){
		Connection con=null;
		try{
			Class.forName(driver);
			con=DriverManager.getConnection(url,name,password);
		}catch(ClassNotFoundException e){
			e.printStackTrace();
		}catch(SQLException e){
			e.printStackTrace();
		}
		return con;
	}

	/**
	 * 关闭数据库连接，而且三者是有顺序的，先关闭ResultSet连接，接着关闭Statement连接，最后关闭Connection连接
	 * 并且还要抛出异常。数据库连接使用完毕以后需要关闭连接的，否则，连接数据库的“通道”就会继续增加，而数据库的连接
	 * 能力也是有限的，大约是200个，因此需要在使用完数据库后将连接关闭掉。
	 * @param res
	 * @param stat
	 * @param conn
	 */
	public void closeAll(ResultSet res,PreparedStatement pstat,Connection con){
		try{
			if(res!=null){
				res.close();
				res=null;
			}
			if(pstat!=null){
				pstat.close();
				pstat=null;
			}
			if(con!=null){
				con.close();
			}
		}catch(SQLException e){
			e.printStackTrace();
		}

	}

}

 

Biz类如下（调用dao的相关方法来实现业务处理）:

 

[java] view plaincopyprint?

1. package com.rz.Biz;
2. import java.util.*;
3. import com.rz.dao.*;
4. import com.rz.entity.*;
5. public class MessageBiz {
6.     /**
7.      * 保存一条信息
8.      * @param message
9.      */
10.     public void saveMessage(Message message){
11.         MessageDao messageDao=new MessageDao();
12.         messageDao.save(message);
13.     }
14.     /**
15.      * 根据页码来查询数据
16.      * @param page
17.      * @return
18.      */
19.     public List<Message> listByPage(int pageSize,int pageNum){
20.         MessageDao messageDao=new MessageDao();
21.         return messageDao.listByPage(pageSize,pageNum);
22.     }
24.     /**
25.      * 返回查询到的记录的总条数
26.      * @return
27.      */
28.     public int getAllUserCount(){
29.         MessageDao messageDao=new MessageDao();
30.         return messageDao.getAllUserCount();
31.     }
32. }

package com.rz.Biz;
import java.util.*;
import com.rz.dao.*;
import com.rz.entity.*;
public class MessageBiz {
	/**
	 * 保存一条信息
	 * @param message
	 */
	public void saveMessage(Message message){
		MessageDao messageDao=new MessageDao();
		messageDao.save(message);
	}
	/**
	 * 根据页码来查询数据
	 * @param page
	 * @return
	 */
	public List<Message> listByPage(int pageSize,int pageNum){
		MessageDao messageDao=new MessageDao();
		return messageDao.listByPage(pageSize,pageNum);
	}

	/**
	 * 返回查询到的记录的总条数
	 * @return
	 */
	public int getAllUserCount(){
		MessageDao messageDao=new MessageDao();
		return messageDao.getAllUserCount();
	}
}

测试index页面代码如下：

[html] view plaincopyprint?

1. <%@ page language=”java” import=”java.util.*,com.rz.Biz.*, com.rz.entity.*” contentType=”text/html; charset=utf-8″%>
4. <!DOCTYPE HTML PUBLIC “-//W3C//DTD HTML 4.01 Transitional//EN”>
5. <html>
6.   <head>
7.     <title>留言板系统</title>
8.      <script>
9.         function check(){
10.             var name=document.form.text.value;
11.             var pass=document.form.textarea.value;
12.             if(name.length==0){
13.                 alert(“用户名不得为空！”);
14.                 return false;
15.             }
16.             if(pass.length==0){
17.                 alert(“留言信息不能为空！”);
18.                 return false;
19.             }
20.             return true;
21.         }
22.     </script>
23.   </head>
25.   <body style=”text-align:center;”>
26.     <h1>Beta留言板</h1>
27.     <div style=”width:800px; border:#CCCCCC solid 1px;”>
28.         <%
29.             String p=request.getParameter(“p”);
30.             int pageNum=1;          //定义页数
31.             int pageSize=10;        //定义每一页显示的个数
32.             if(p!=null){            //判断传入的输入值是否为空，并且进行强制类型转换
33.                 pageNum=Integer.parseInt(p);
34.             }
36.             MessageBiz messageBiz=new MessageBiz();
37.             List<Message> list=messageBiz.listByPage(pageSize,pageNum); //根据传入的两个参数，返回一个list集合
39.             for(int i=list.size()-1;i>=0;i–){
40.                 Message message=new Message();
41.                 message=(Message)list.get(i);
42.         %>
44.         <div style=”width:800px;”>
45.             <div style=”background-color:#CCCCCC; text-align:left;”>作者：<%=message.getAuthor() %>
46.                        <%=message.getPostTime() %>
47.             </div>
48.             <div style=”text-align:right;”><%=i+1+(pageNum-1)*pageSize %>#</div>
49.             <div><%=message.getMessage() %>
50.             </div>
51.         </div>
52.         <%
53.             }
54.             //获得最大页码
55.             int maxPage;
56.             int reCount=messageBiz.getAllUserCount();
57.             if(reCount%pageSize==0)
58.                 maxPage=reCount/pageSize;
59.             else
60.                 maxPage=(reCount/pageSize)+1;
62.             int backPage=(pageNum==1) ? 1 :pageNum-1;
63.             int nextPage=(pageNum==maxPage) ? maxPage : pageNum+1;
64.         %>
65.     </div>
68.     <div style=”width:800px; height:30px; border:#000033 solid 0px; margin-top:12px; text-align:right;”>
69.         <div style=”width:50px; height:15px; border:#CCCCCC solid 1px; display:inline; cursor:pointer;”>
70.             <a href=”index.jsp?p=<%=backPage %>”>上一页</a>
71.         </div>
72.         <div style=”width:50px; height:15px; border:#CCCCCC solid 1px; display:inline; margin-left:12px; margin-right:20px; cursor:pointer;”>
73.             <a href=”index.jsp?p=<%=nextPage %>”>下一页</a>
74.         </div>
75.     </div>
76.     <div style=” width:800px; height:300px; border:#333333 solid 0px;”>
77.         <form name=”form” action=”doPost.jsp” method=”post” onSubmit=”return check()”>
78.             <table>
79.                     <tr>
80.                         <td>用户名：</td>
81.                         <td><input type=”text” name=”text”/></td>
82.                     </tr>
83.                     <tr>
84.                         <td>留言信息：</td>
85.                         <td><textarea name=”textarea” style=”width:400px; height:200px;”></textarea></td>
86.                     </tr>
87.                     <tr><td><input type=”submit” value=”提交”/></td></tr>
88.                 </table>
89.         </form>
90.     </div>
91.   </body>
92. </html>

<%@ page language="java" import="java.util.*,com.rz.Biz.*, com.rz.entity.*" contentType="text/html; charset=utf-8"%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <title>留言板系统</title>
     <script>
    	function check(){
    		var name=document.form.text.value;
    		var pass=document.form.textarea.value;
    		if(name.length==0){
    			alert("用户名不得为空！");
    			return false;
    		}
    		if(pass.length==0){
    			alert("留言信息不能为空！");
    			return false;
    		}
    		return true;
    	}
    </script>
  </head>

  <body style="text-align:center;">
  	<h1>Beta留言板</h1>
	<div style="width:800px; border:#CCCCCC solid 1px;">
		<%
			String p=request.getParameter("p");
			int pageNum=1;			//定义页数
			int pageSize=10;		//定义每一页显示的个数
			if(p!=null){			//判断传入的输入值是否为空，并且进行强制类型转换
			 	pageNum=Integer.parseInt(p);
		 	}

  			MessageBiz messageBiz=new MessageBiz();
  			List<Message> list=messageBiz.listByPage(pageSize,pageNum); //根据传入的两个参数，返回一个list集合

  			for(int i=list.size()-1;i>=0;i--){
  				Message message=new Message();
  				message=(Message)list.get(i);
  		%>

		<div style="width:800px;">
			<div style="background-color:#CCCCCC; text-align:left;">作者：<%=message.getAuthor() %>
				       <%=message.getPostTime() %>
			</div>
			<div style="text-align:right;"><%=i+1+(pageNum-1)*pageSize %>#</div>
			<div><%=message.getMessage() %>
			</div>
		</div>
		<%
			}
			//获得最大页码
			int maxPage;
			int reCount=messageBiz.getAllUserCount();
			if(reCount%pageSize==0)
				maxPage=reCount/pageSize;
			else
				maxPage=(reCount/pageSize)+1;

			int backPage=(pageNum==1) ? 1 :pageNum-1;
			int nextPage=(pageNum==maxPage) ? maxPage : pageNum+1;
  	 	%>
	</div>

	<div style="width:800px; height:30px; border:#000033 solid 0px; margin-top:12px; text-align:right;">
		<div style="width:50px; height:15px; border:#CCCCCC solid 1px; display:inline; cursor:pointer;">
			<a href="index.jsp?p=<%=backPage %>">上一页</a>
		</div>
		<div style="width:50px; height:15px; border:#CCCCCC solid 1px; display:inline; margin-left:12px; margin-right:20px; cursor:pointer;">
			<a href="index.jsp?p=<%=nextPage %>">下一页</a>
		</div>
	</div>
	<div style=" width:800px; height:300px; border:#333333 solid 0px;">
		<form name="form" action="doPost.jsp" method="post" onSubmit="return check()">
			<table>
		    		<tr>
		    			<td>用户名：</td>
		    			<td><input type="text" name="text"/></td>
		    		</tr>
		    		<tr>
		    			<td>留言信息：</td>
		    			<td><textarea name="textarea" style="width:400px; height:200px;"></textarea></td>
		    		</tr>
		    		<tr><td><input type="submit" value="提交"/></td></tr>
		       	</table>
		</form>
	</div>
  </body>
</html>

处理表单提交的jsp页面doPost.jsp如下：

[html] view plaincopyprint?

1. <%@ page language=”java” import=”java.util.*,com.rz.Biz.*, com.rz.entity.*” contentType=”text/html; charset=utf-8″%>
2. <%
3.     request.setCharacterEncoding(“utf-8″);
4.     String author=request.getParameter(“text”);
5.     String message=request.getParameter(“textarea”);
7.     Message messages=new Message();
8.     messages.setAuthor(author);
9.     messages.setMessage(message);
10.     MessageBiz messageBiz=new MessageBiz();
11.     messageBiz.saveMessage(messages);
12.     response.sendRedirect(“index.jsp”);
13. %>

<%@ page language="java" import="java.util.*,com.rz.Biz.*, com.rz.entity.*" contentType="text/html; charset=utf-8"%>
<%
	request.setCharacterEncoding("utf-8");
	String author=request.getParameter("text");
	String message=request.getParameter("textarea");

	Message messages=new Message();
	messages.setAuthor(author);
	messages.setMessage(message);
	MessageBiz messageBiz=new MessageBiz();
	messageBiz.saveMessage(messages);
	response.sendRedirect("index.jsp");
 %>

页面效果如下：

http://blog.csdn.net/lishiyuzuji/article/details/6758257