JDBC分页策略

分页策略
数据表记录按页取出,只显示当前页的数据
pageSize = 10,共105条
第一页:1-10
第二页:11-20
第N页:begin(n-1)*pageSize+1
 end:n * pageSize

第一种方式:基于缓存的分页策略
1)数据库从中全部取出,只显示当前页
2)只访问数据库一次,内存有压力.
3)用户只关心一小部分数据,浪费
4)好处是用户切换页面速度快,只有第一次取出时有延迟.
5)适合:数据量不大,用户每页都会查看.比如:审批作业

第二种方式:基于查询的分页策略
1)每次从数据库中只取一页的数据.
2)每次换页都要连接数据库,重新取数据.内存无压力
3)每页取数据时间都差不多.
4)适合:数据量大,但用户只查看小部分数据,比如:淘宝

例子3:基于缓存的分页策略
main: getData(3,10);//21-30
rs必须具备的功能;
1.跳到指定位置.
absolute(row); 指定绝对位置
relative(row); 指定相对位置;
2.不仅限于向前,可以向前或向后滚动.
next() 向后移动
previous() 向前移动
默认结果集:单向/单步
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);

如果希望可滚动的结果集
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);

getDate(int page,int pageSize){
 begin = (page-1) * pageSize +1 ;
 rs = stmt.exectueQuery(select * from mytemp_hqr);
 //指针指向begin
 rs.absolte(begin);
 while(遍历){
  rs.getInt("id");
  if(pageSize次) break;
 } 
}

容错:
1.如果用户输入负数或0, page =1
2.如果用户输入"abc", page =1
3.如果用户输入数字大于最大页,page =最后一页;

取数据的方式
rs = ...(selet id,name,salary from emp);
while(rs.next()){
 rs.getString(1);//列的索引
 rs.getString("id");//用列名代替列的索引,建议
}

其中用到的ConnectionUtils.java

package day1;
import java.io.*;
import java.sql.*;
import java.util.*;
/**
 * 工具类,负责读入属性文件中的参数
 * 注册驱动,获得连接,关闭资源
 * @author soft01
 *
 */
public class ConnectionUtils {
 private static String driver="oracle.jdbc.driver.OracleDriver";
 private static String url="jdbc:oracle:thin:@192.168.2.205:1521:hqr";
 private static String dbUser="openlab";
 private static String dbPwd ="open123";

 /**
  * 根据四个全局变量参数构造连接对象并返回
  * @return Connection对象 
  */
 public static Connection getConnection(){
  Connection conn = null;
  try {
   Class.forName(driver);
   conn = DriverManager.getConnection(url, dbUser, dbPwd);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return conn;
  
 }
 public static void close(ResultSet rs){
  if(rs != null){
   try {
    rs.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }
 public static void close(Statement stmt){
  if(stmt != null){
   try {
    stmt.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }
 public static void close(Connection conn){
  if(conn != null){
   try {
    conn.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }
 
}

源代码

package day2;
import java.sql.*;

import day1.ConnectionUtils;
public class BufferPageDemo {
 public static void main(String[] args) {
  //getData("-3",10);//21-30
  getTotalCount();
 }
 /**
  * 打印出第page页的数据
  * @param page 要查询第几页
  * @param pageSize 每页多少条
  */
 private static void getData(int page,int pageSize){
  String sql = "select * from mytemp_hqr";
  int begin = (page-1)*pageSize + 1 ; 
  
  Connection conn = ConnectionUtils.getConnection();
  Statement stmt = null;
  ResultSet rs = null;
  try{
   //获得支持可滚动结果集的语句对象
   stmt = conn.createStatement(
     ResultSet.TYPE_SCROLL_INSENSITIVE,
     ResultSet.CONCUR_READ_ONLY);
   //指针指向beforeFirst
   rs = stmt.executeQuery(sql);
   //指针不能超过现有的记录数,结果集不能<=0.绝对位置的起点是1
   
   //显示第page页的pageSize条记录
   //指针指向当页的起点
   rs.absolute(begin);
   for(int i = 0;i < pageSize; i++){
    System.out.println(rs.getInt("id"));
    //rs.next();
    if(!rs.next()){
     break;
    }
   }
   
  } catch(Exception e){
   e.printStackTrace();
  } finally{
   ConnectionUtils.close(rs);
   ConnectionUtils.close(stmt);
   ConnectionUtils.close(conn);
  }
 }
 
 //增加容错功能
 public static void getData(String page,int pageSize){
  int intPage =1;
  //解决用户输入的是字符串问题
  try{
   intPage = Integer.parseInt(page);;
  }catch(Exception e){
  }
  //解决用户输入的是负数问题
  if(intPage < 1){
   intPage = 1;
  }
  //解决用户输入的页数大于最大页
  //getTotalPage(pageSize)用来计算总页数
  int totalPages = getTotalPage(pageSize);
  if(intPage > totalPages){
   intPage = totalPages;
  }
  getData(intPage,pageSize);
 }
 private static int getTotalPage(int pageSize) {
  int totalCount = getTotalCount();
  int totalPage = 0;
  if(totalCount % pageSize == 0){
    totalPage = totalCount / pageSize;
  }else
    totalPage = totalCount / pageSize+1;    
  return totalPage;
 }
 /**
  * 计算数据表的总记录数
  * @return 总记录数
  */
 private static int getTotalCount() {
  int totalCount = 0;
  String sql = "select count(*) from mytemp_hqr";
  Connection conn = ConnectionUtils.getConnection();
  Statement stmt = null;
  ResultSet rs = null;
  try {
   stmt = conn.createStatement();
   rs = stmt.executeQuery(sql);
   rs.next();
   totalCount = rs.getInt(1);
  } catch (SQLException e) {
   e.printStackTrace();
  } finally{
   ConnectionUtils.close(rs);
   ConnectionUtils.close(stmt);
   ConnectionUtils.close(conn);
  }
  return totalCount;
 }
}

例子4:基于查询的分页策略
每次只向数据库获取一页的数据
String sql = "selet * from my temp_hqr
where 第11条到20条";
Connection conn = ...;
Statement stmt = conn...;
ResultSet rs = stmt ...(sql)
while(rs.next()){
}

Oracle取出第begin到end条记录的方式:
select * from
(select rownum rn,id from mytemp_hqr)
where rn between 11 and 20;

MYSQL中取出第begin到end条记录的方式:
select * from mytemp_hqr
limit 11,10;   ----limit begin,pageSize

源代码

package day2;
import day1.ConnectionUtils;
import java.sql.*;
/**
 * 基于查询的分页策略
 * @author soft01
 *
 */
public class SelectPageDemo {
 public static void main(String[] args) {
  getData(3,10);//21-30
 }
 /**
  * 显示指定页的数据
  * @param page 要显示的第几页
  * @param pageSize 每页显示多少条
  */
 public static void getData(int page,int pageSize){
  String sql = "select * from" +
    " (select rownum rn,id from mytemp_hqr)" +
    " where rn between ? and ?";
  int begin = (page-1)*pageSize +1;
  int end = page * pageSize;
  Connection conn = ConnectionUtils.getConnection();
  PreparedStatement stmt = null;
  ResultSet rs = null;
  try{
   stmt = conn.prepareStatement(sql);
   stmt.setInt(1, begin);
   stmt.setInt(2, end);
   rs = stmt.executeQuery();
   while(rs.next()){
    System.out.println(rs.getString("id"));
   }
  } catch (Exception e){
   e.printStackTrace();
  } finally{
   ConnectionUtils.close(rs);
   ConnectionUtils.close(stmt);
   ConnectionUtils.close(conn);
  }
 }
}