Servlet分页查询

Posted 2020-10-06 KeepUp~

分页查询：

1.逻辑分页查询：用户第一次访问时就把全部数据访问出来，添加到一个大集合中，然后放到session中，进行转发。通过页码等的计算，把要显示的内容添加到一个小集合中，转发、遍历小集合以显示当前页码的数据

代码实现：

 

Dao:

 

package general.page.query;

 

import java.lang.reflect.InvocationTargetException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

 

import org.apache.commons.beanutils.BeanUtils;

 

public class PageQueryDao {
private static Connection con=null;
private static PreparedStatement prst=null;
private static ResultSet rs=null;
public static<T> List<T> pageQuery(Class<T> clazz,String sql,Object...objects) throws SQLException, InstantiationException, IllegalAccessException, InvocationTargetException{
List<T> beanList=new ArrayList<T>();
Connection con=C3P0Tool.getConnection();
prst=con.prepareCall(sql);
for(int i=0;i<objects.length;i++){
prst.setObject(i+1,objects[i]);
}
rs=prst.executeQuery();
List<String> columnLabelList=getColumnlabel(rs);
Map<String,Object> map=new HashMap<String,Object>();
List<Map<String,Object>> list=new ArrayList<Map<String,Object>>();
while(rs.next()){
if(columnLabelList.size()>0){
for(String columnLabel:columnLabelList){
Object fieldValue=rs.getObject(columnLabel);
map.put(columnLabel, fieldValue);
}

}
}
list.add(map);

//增强for遍历，要判断集合是否为空
if(list.size()>0){
T t=null;
for(Map<String,Object> mapList:list){
for(Map.Entry<String, Object> entry:map.entrySet()){
t=clazz.newInstance();
String columnlabel=entry.getKey();
Object fieldValue=entry.getValue();
BeanUtils.setProperty(t, columnlabel, fieldValue);
}
}
beanList.add(t);
}
return beanList;
}
public static List<String> getColumnlabel(ResultSet rs) throws SQLException{
List<String> columnLabelList=new ArrayList<String>();
ResultSetMetaData rsmd=rs.getMetaData();
int columnCount=rsmd.getColumnCount();
for(int i=0;i<columnCount;i++){
String columnLabel=rsmd.getColumnLabel(columnCount+1);
columnLabelList.add(columnLabel);
}
return columnLabelList;
}

 

}

 

 Servlet：

package general.page.query;

import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

public class pageQueryServlet extends HttpServlet {

public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
request.setCharacterEncoding("utf-8");
response.setContentType("text/html;charset=utf-8");
int pageNo=Integer.parseInt(request.getParameter("pageNo")==null?"1":request.getParameter("pageNo"));
int pageSize=10;
HttpSession session=request.getSession();
List<Student> bigList = (List<Student>)session.getAttribute("bigList");

//如果第一次访问
if(bigList == null){

//实体类的字段名，要与属性的别名相同
String sql="select sno no,sname name,ssex sex,sbirth birth,zno zn,sclass zclass from student";
try {
bigList=new ArrayList<Student>();
bigList=PageQueryDao.pageQuery(Student.class, sql);
session.setAttribute("bigList", bigList);
request.getRequestDispatcher("/show.jsp").forward(request, response);
} catch (InstantiationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

 

 

//添加显示记录的小集合

List<T> smallList=new ArrayList<T>();

 //计算显示的记录从几行到几行

//定义开始行

int beginIndex=pageSize*(pageNo-1);

//定义结束行

int endIndex=pageSize*pageNo>bigList.size()?bigList.size():pageSize*pageNo;

//注意：集合的索引是从零开始的

for(int i=beginIndex;i<endIndex;i++){

smallList.add(bigList.get(i));

}

request.setAttribute("smallList",smallList);

//转发

 

2.物理分页查询：通过分页查询的SQL进行查询，所查询的结果集中的内容就是当前页面要显示的内容

代码实现：（以Student类，mysql数据库（sql="select * from tbName limit ? offset ?"）为例，limit限制显示的size,offset跳过前pageNo-1页的记录） 

public List<Student> getStudentList(int pageNo,int pageSize String sql){

List<Student> list=new ArrayList<Student>();

Connection con=null;

PreparedStatement prst=null;

ResultSet rs=null;

con=c3p0.getConnection();

prst=con.prepareStatement(sql);

prst.setInt(1,pageSize);

prst.setInt(2,pageSize*(pageNo-1));

rs.executeQuery();

while(rs.next()){

Student student=new Student();

student.setString(rs.get(1));

　　　　.

　　　　.

　　　　.

}

list.add(student);

//转发

}

总结逻辑分页查询和物理分页查询的区别：

逻辑分页查询：

1.是把所有的相关记录都查出来，然后再通过计算得出在显示页面上要显示的记录，不实实在在的对记录进行分页。

 

2.如果需要查询的数据量过大，session将耗费大量的内存； 3.因为是在session中获取数据，如果第二次或者更多此的不关闭浏览器访问，会直接访问session，从而不能保证数据是最新的。

 

3.这种分页很少使用。但是在数据量小，不会被修改的数据，使用逻辑分页会提高程序的执行效率。

 

物理分页查询：

1.是通过sql语句的编写只查询出想要显示的记录

 

2.数据能够保证最新，由于根据分页条件会查询出少量的数据，所以不会占用太多的内存。

 

 3.物理分页使用了数据库自身带的机制，所以这样的SQL语句不通用，导致不能进行数据库的移植。