在使用Java语言进行和数据库有关的的应用开发中，一般都使用JDBC来进行和数据库的交互，其中有一个关键的概念就是Connection（连接），它在Java中是一个类，代表了一个通道。通过它，使用数据的应用就可以从数据库访问数据了。

对于一个简单的数据库应用，由于对于数据库的访问不是很频繁。这时可以简单地在需要访问数据库时，就新创建一个连接，用完后就关闭它，这样做也不会带来什么明显的性能上的开销。但是对于一个复杂的数据库应用，情况就完全不同了。频繁的建立、关闭连接，会极大的减低系统的性能，因为对于连接的使用成了系统性能的瓶颈。

本文给出的方法可以有效的解决这个问题。在本方法中提出了一个合理、有效的连接管理策略，避免了对于连接的随意、无规则的使用。该策略的核心思想是：连接复用。通过建立一个数据库连接池以及一套连接使用管理策略，使得一个数据库连接可以得到高效、安全的复用，避免了数据库连接频繁建立、关闭的开销。另外，由于对JDBC中的原始连接进行了封装，从而方便了数据库应用对于连接的使用（特别是对于事务处理），提高了开发效率，也正是因为这个封装层的存在，隔离了应用的本身的处理逻辑和具体数据库访问逻辑，使应用本身的复用成为可能。

问题产生\r

我参与的项目是开发一个网管系统，不可避免的要和数据库打交道。刚开始时，由于对于数据库的访问不是很频繁，对于数据库连接的使用就是简单的需要时就建立，用完就关闭的策略，这很符合XP（eXtreme Programming）的口号："Do the Simplest Thing that Could Possibly Work"。确实，开始时工作的很好。随着项目的进展，对于数据库的访问开始变的频繁，问题就暴露出来了，原先的通过简单地获取和关闭数据库连接的方法将很大的影响系统的性能，这种影响是由于数据库资源管理器进程频繁的创建和摧毁那些连接对象而引起的。

此时，就有必要对数据库访问方法进行重构（refactoring），因为我们确实需要进行改进，来提高系统的性能。

解决方案

可以看出，问题的根源就是由于对于连接资源的低效管理造成的。对于共享资源，有一个很著名的设计模式：资源池。该模式正是为了解决资源频繁分配、释放所造成的问题的。把该模式应用到数据库连接管理领域，就是建立一个数据库连接池，提供一套高效的连接分配、使用策略，最终目标是实现连接的高效、安全的复用。

3.1、建立连接池

第一步，就是要建立一个静态的连接池，所谓静态是指，池中的连接是在系统初始化时就分配好的，并且不能够随意关闭的。Java中给我们提供很多容器类可以方便的用来构建连接池，如：Vector、Stack等。在系统初始化时，根据配置创建连接并放置在连接池中，以后所使用的连接都是从该连接池中获取的，这样就可以避免连接随意建立、关闭造成的开销（当然，我们没有办法避免Java的Garbage Collection带来的开销）。

3.2、分配、释放策略

有了这个连接池，下面我们就可以提供一套自定义的分配、释放策略。

当客户请求数据库连接时，首先看连接池中是否有空闲连接，这里的空闲是指，目前没有分配出去的连接。如果存在空闲连接则把连接分配给客户，并作相应处理，具体处理策略，在关键议题中会详述，主要的处理策略就是标记该连接为已分配。若连接池中没有空闲连接，就在已经分配出去的连接中，寻找一个合适的连接给客户（选择策略会在关键议题中详述），此时该连接在多个客户间复用。

当客户释放数据库连接时，可以根据该连接是否被复用，进行不同的处理。如果连接没有使用者，就放入到连接池中，而不是被关闭。

可以看出正是这套策略保证了数据库连接的有效复用。

3.3、配置策略

数据库连接池中到底要放置多少个连接，连接耗尽后该如何处理呢？这时一个配置策略。一般的配置策略是，开始时，根据具体的应用需求，给出一个初始的连接池中连接的数目以及一个连接池可以扩张到的最大连接数目。本方案就是按照这种策略实现的。

关键议题\r

本节将对上述解决方案中的关键细节进行详述，正是这些关键的策略保证了数据库连接复用的高效和安全。

4.1、引用记数

3.2节中的分配、释放策略对于有效复用连接非常重要，我们采用的方法也是采用了一个很有名的设计模式：Reference Counting（引用记数）。该模式在复用资源方面用的非常广泛，我们把该方法运用到对于连接的分配释放上。每一个数据库连接，保留一个引用记数，用来记录该连接的使用者的个数。具体的实现上，我们采用了两极连接池，空闲池和使用池。空闲池中存放目前还没有分配出去被使用的连接，一旦一个连接被分配出去，那么就会放入到使用池中，并且增加引用记数。

这样做有一个很大的好处，使得我们可以高效的使用连接，因为一旦空闲池中的连接被全部分配出去，我们就可以根据相应的策略从使用池中挑选出一个已经正在使用的连接用来复用，而不是随意拿出一个连接去复用。策略可以根据需要去选择，我们采用的策略比较简单：复用引用记数最小的连接。Java的面向对象特性，使得我们可以灵活的选择不同的策略（提供一个不同策略共用的抽象接口，各个具体的策略都实现这个接口，这样对于策略的处理逻辑就和策略的实现逻辑分离）。

4.2、事务处理\r

前面谈到的都是关于使用数据库连接进行普通的数据库访问。对于事务处理，情况就变得比较复杂。因为事务本身要求原子性的保证，此时就要求对于数据库的操作符合"All-All-Nothing"原则，即要么全部完成，要么什么都不做。如果简单的采用上述的连接复用的策略，就会发生问题，因为没有办法控制属于同一个事务的多个数据库操作方法的动作，可能这些数据库操作是在多个连接上进行的，并且这些连接可能被其他非事务方法复用。

Connection本身具有提供了对于事务的支持，可以通过设置Connection的AutoCommit属性为false，显式的调用commit或者rollback方法来实现。但是要安全、高效的进行Connection进行复用，就必须提供相应的事务支持机制。我们采用的方法是：采用显式的事务支撑方法，每一个事务独占一个连接。这种方法可以大大降低对于事务处理的复杂性（如果事务不独占一条连接，那么要保证事务的原子性并且又不妨碍复用该连接的其他和该事务无关的操作，基本上不可能，除非Connection类是你开发的），并且又不会妨碍连接的复用，因为隶属于该事务的所有数据库操作都是通过这一个连接完成的，并且事务方法又复用了其他一些数据库方法。

在我们的连接管理服务提供了显式的事务开始、结束（commit或者rollback）声明，以及一个事务注册表，用于登记事务发起者和事务使用的连接的对应关系，通过该表，使用事务的部分和我们的连接管理部分就隔离开，因为该表是在运行时根据实际的调用情况，动态生成的。事务使用的连接在该事务运行中不能被复用。

当使用者需要使用事务方法时，首先调用连接管理服务提供的beginTrans方法，该方法主要处理流程如下(伪码描述)：

           public void beginTrans( ) {
                    …
                conn = getIdleConnectionFromPoll( );
                userId = getUserId( );
                registerTrans(userId, conn);
                    …
}

在我们的实现中，用户标识是通过使用者所在的线程来标识的。后面的所有对于数据库的访问都是通过查找该注册表，使用已经分配的连接来完成的。当事务结束时，从注册表中删除相应表项。

对于嵌套的事务如何处理呢？我们采用的方法仍为引用记数，不过这里的引用记数是指的"嵌套层次"，具体的细节，不再赘述。

4.3、封装

从上面的论述可以看出，普通的数据库方法和事务方法对于连接的使用（分配、释放）是不同的，为了便于使用，对外提供一致的操作接口，我们对连接进行了封装：即普通连接和事务连接。在此，我们利用了Java中的强大的面向对象特性：多态。普通连接和事务连接均实现了一个DbConnection接口，对于接口中定义的方法，分别根据自己的特点作了不同的实现，这样在对于连接的处理上就非常的一致了。

4.4、并发问题\r

为了是我们的连接管理服务有更大的通用性，就必须要考虑到多线程环境，即并发问题。在一个多线程的环境下，我们必须要保证连接管理自身数据的一致性和连接内部数据是一致性，还好Java提供对这方面的很好的支持（synchronized关键字），这样我们就很容易使连接管理成为线程安全的。

5、结论

本文给出了一个基本的连接管理框架，在其中使用了一些广泛使用的设计模式（资源池，引用记数等），使得高效、安全的复用数据库连接成为可能。当然，还有一些问题没有考虑到，比如：没有实现对不同种类的数据库的联合管理；没有提供定时检测机制，查询连接的状态等。另外在连接管理的使用包装上比起一些商用的系统还显粗糙，但是底层的基理是一致的，所以通过本文相信对于这些商用的产品中的相关功能会有更好的理解。

参考文献
《Thinking in Java》Bruce Eckel

《Real-Time Design Patterns》 Bruce Powel Dougladd

我的方法是，根据用户点击导航条上的页号(offset)，到DB中读取该页的数据(不是一次全部读出)，点到哪页读哪页的数据，JBX + tomcat + oracle下测试通过，数据库用的表是oracle的emp表。

********分页类Pager.java，负责生成分页导航条********

package page;

/**
 * 分页代码
 * <p>Title: 分页</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: BCS</p>
 * @author Alex
 * @version 1.0
 */
public class Pager {
  private int offset;
  private int size;
  private int length;
  private String url;
  private String pageHeader;
  public Pager(int offset, int size, int length, String url, String pageHeader) {
    this.offset = offset;
    this.size = size;
    this.length = length;
    this.url = url;
    this.pageHeader = pageHeader;
  }

  /**
   * 返回分页导航条
   * @param offset int 起始记录的位置
   * @param size int 总记录数
   * @param length int 步长
   * @param url String .do的url
   * @param pageHeader String 导航条的前缀文字提示
   * @return String
   */
  public String getPageNavigation() {
    String pageNavigation = ""; //最终返回的分页导航条
    //记录数超过一页,需要分页
    if (size > length) {
      String pref; //前缀
      if (url.indexOf("?") > -1) {
        //如果url中已经包含了其他的参数,就把offset参数接在后面
        pref = "&";
      }
      else {
        //如果url中没有别的参数
        pref = "?";
      }
      //如果导航条包含header
      if (pageHeader != null && pageHeader.length() > 0) {
        pageNavigation = pageHeader + " : ";
      }
      //如果不是第一页,导航条将包含“<<”(第一页)和“<”(前一页)
      if (offset > 0) {
        pageNavigation += "<a href='" + url + pref + "offset=0'>[<<]</a>\n" +
            "<a href='" + url + pref + "offset=" + (offset - length) +
            "'>[<]</a>\n";
      }
      //导航条中,排头的那一页的offset值
      int startOffset;
      //位于导航条中间的那一页的offset值(半径)
      int radius = constants.MAX_PAGE_INDEX / 2 * length;
      //如果当前的offset值小于半径
      if (offset < radius || this.pageCount() <= constants.MAX_PAGE_INDEX) {
        //那么第一页排头
        startOffset = 0;
      }
      else if (offset < size - radius) {
        startOffset = offset - radius;
      }
      else {
        startOffset = (size / length - constants.MAX_PAGE_INDEX) * length;
      }
      for (int i = startOffset;
           i < size && i < startOffset + constants.MAX_PAGE_INDEX * length;
           i += length) {
        if (i == offset) {
          //当前页号,加粗显示
          pageNavigation += "<b>" + (i / length + 1) + "</b>\n";
        }
        else {
          //其他页号,包含超链接
          pageNavigation += "<a href='" + url + pref + "offset=" + i + "'>" +
              (i / length + 1) + "</a>\n";
        }
      }
      //如果不是最后一页,导航条将包含“>”(下一页)和“>>”(最后一页)
      if (offset < size - length) {
        pageNavigation += "<a href='" + url + pref + "offset=" +
            (offset + length) + "'>[>]</a>\n" +
            "<a href='" + url + pref + "offset=" + lastPageOffset() +
            "'>[>>]</a>\n";
      }
//      System.out.println("radius : " + radius);
//      System.out.println("start offset : " + startOffset);
      return pageNavigation;
    }
    //记录不超过一页,不需要分页
    else {
      return "";
    }
  }

  /**
   * 返回分页后的总页数
   * @param size int 总记录数
   * @param length int 每页的记录数
   * @return int
   */
  public int pageCount() {
    int pagecount = 0;
    if (size % length == 0) {
      pagecount = size / length;
    }
    else {
      pagecount = size / length + 1;
    }
    return pagecount;
  }

  /**
   * 返回最后一页的记录数
   * @param size int 总记录数
   * @param length int 每页的记录数
   * @return int
   */
  public int lastPageSize() {
    int lastpagesize = 0;
    if (size % length == 0) {
      lastpagesize = length;
    }
    else {
      lastpagesize = size % length;
    }
    return lastpagesize;
  }

  /**
   * 返回最后一页的起始记录位置
   * @param size int 总记录数
   * @param length int 每页的记录数
   * @return int
   */
  public int lastPageOffset() {
    return size - lastPageSize();
  }

  public int getOffset() {
    return offset;
  }

  public void setOffset(int offset) {
    this.offset = offset;
  }

  public int getSize() {
    return size;
  }

  public void setSize(int size) {
    this.size = size;
  }

  public int getLength() {
    return length;
  }

  public void setLength(int length) {
    this.length = length;
  }

  public String getUrl() {
    return url;
  }

  public void setUrl(String url) {
    this.url = url;
  }

  public String getPageHeader() {
    return pageHeader;
  }

  public void setPageHeader(String pageHeader) {
    this.pageHeader = pageHeader;
  }
}

********数据处理类empDAO.java，负责访问DB，获取当前页面需要显示的记录********

package page;

import java.sql.*;
import java.util.*;

public class empDAO {
  public empDAO() {
  }

  /**
   * 从offset位置起始,返回length条记录
   * @param offset int 起始的记录位置
   * @param length int 步长
   * @param conn Connection 数据库连接
   * @return ArrayList
   */
  public ArrayList findAllEmp(int offset, int length, Connection conn) throws
      SQLException {
    PreparedStatement ps = null;
    ResultSet rs = null;
    ArrayList emps = new ArrayList();
    empVO empvo = null;
    String strSql = "select empno, ename from emp where rowid not in (select rowid from emp where rownum <= ?) and rownum <= ?";
    try {
      ps = conn.prepareStatement(strSql);
      ps.setInt(1, offset); //起始记录的位置
      ps.setInt(2, length); //步长
      rs = ps.executeQuery();
      while (rs != null && rs.next()) {
        empvo = new empVO();
        empvo.setEmpno(rs.getInt("empno"));
        empvo.setEname(rs.getString("ename"));
        emps.add(empvo);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
      throw ex;
    }
    return emps;
  }

  /**
   * 返回总的记录数
   * @param conn Connection
   * @throws SQLException
   * @return int
   */
  public int getRsTotalCount(Connection conn) throws SQLException {
    PreparedStatement ps = null;
    ResultSet rs = null;
    int rsCount = 0;
    String strSql = "select count(empno) as empCount from emp";
    try {
      ps = conn.prepareStatement(strSql);
      rs = ps.executeQuery();
      if (rs != null && rs.next()) {
        rsCount = rs.getInt("empCount");
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
      throw ex;
    }
    return rsCount;
  }
}

********业务类empBO.java，调用empDAO类********

package page;

import java.util.*;

/**
 * BO类
 * <p>Title: 分页</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: BCS</p>
 * @author Alex
 * @version 1.0
 */
public class empBO {
  private DBPool db = DBPool.newInstance();
  private empDAO empdao = new empDAO();

  public empBO() {
  }

  /**
   * 从offset位置起始,返回length条记录
   * @param offset int 起始
   * @param length int 步长
   * @throws Exception
   * @return ArrayList
   */
  public ArrayList findAllEmp(int offset, int length) throws Exception {
    ArrayList emps = new ArrayList();
    try {
      emps = empdao.findAllEmp(offset, length, db.getConnection());
    }
    catch (Exception ex) {
      throw ex;
    }
    finally {
      db.release();
    }
    return emps;
  }

  /**
   * 返回总的记录数
   * @throws Exception
   * @return int
   */
  public int getRsTotalCount() throws Exception {
    int rsCount = 0;
    try {
      rsCount = empdao.getRsTotalCount(db.getConnection());
    }
    catch (Exception ex) {
      throw ex;
    }
    finally {
      db.release();
    }
    return rsCount;
  }
}

********ActionForm类empForm.java********

package page;

import javax.servlet.http.*;

import org.apache.struts.action.*;

public class empForm
    extends ActionForm {
  private int offset; //起始记录的位置//每页显示的记录数
  public ActionErrors validate(ActionMapping actionMapping,
                               HttpServletRequest httpServletRequest) {
    /**@todo: finish this method, this is just the skeleton.*/
    return null;
  }

  public void reset(ActionMapping actionMapping,
                    HttpServletRequest httpServletRequest) {
    this.offset = 0; //记录默认从第一条开始显示
  }

  public int getOffset() {
    return offset;
  }

  public void setOffset(int offset) {
    this.offset = offset;
  }

}

********Action类empAction.java，控制器，调用BO类，Pager类********

package page;

import java.util.*;
import javax.servlet.http.*;

import org.apache.struts.action.*;

/**
 * 分页测试的Action
 * <p>Title: 分页</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: BCS</p>
 * @author Alex
 * @version 1.0
 */
public class empAction
    extends Action {

  public ActionForward execute(ActionMapping actionMapping,
                               ActionForm actionForm,
                               HttpServletRequest httpServletRequest,
                               HttpServletResponse httpServletResponse) {
    empForm empform = (empForm) actionForm;
    return performList(actionMapping, actionForm, httpServletRequest,
                       httpServletResponse);
  }

  private ActionForward performList(ActionMapping actionMapping,
                                    ActionForm actionForm,
                                    HttpServletRequest request,
                                    HttpServletResponse response) {
    try {
      empBO empbo = new empBO();
      //获取外部传进来的起始记录号
      int offset = ( (empForm) actionForm).getOffset();
      //获取每页的记录数
      int pagesize = constants.PAGE_SIZE;
      //获取记录集合,从offset开始,取length条记录
      ArrayList emps = empbo.findAllEmp(offset, pagesize);
      //计算所有记录的条数(总记录数)
      int size = empbo.getRsTotalCount();
      //外部url地址,得到形如: http://localhost:8088/bugMIS/showlist.do 的String
      String url = request.getContextPath() + actionMapping.getPath() + ".do";
      //实例化分页类
      Pager p = new Pager(offset, size, pagesize, url, "Page Navigation");
      //获取分页导航条
      //String pageNavigation = p.getPageNavigation();
      //将url字符串和记录集合,存入request中
      request.setAttribute("pager", p);
      request.setAttribute("emps", emps);
    }
    catch (Exception e) {
      e.printStackTrace();
      return actionMapping.findForward("failure");
    }
    return actionMapping.findForward("success");
  }
}

********数据库连接池类DBPool.java，可以使用tomcat的连接池，也可以不用，这里关闭了********

package page;

import java.sql.*;
import javax.naming.*;
import javax.sql.*;

import org.apache.commons.logging.*;

/**
 * 系统连接池类
 * <p>Title: Gantoo@91.com</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: BCS</p>
 * @author Alex
 * @version 1.0
 */
public class DBPool {
  Log log = LogFactory.getLog("DBPool"); //日志机
  private DBPool() {
  }

  private Connection conn = null;

  /* true:使用连接池
     false:不使用连接池,采用JDBC直接连接 */
  private final static boolean USE_DB_POOL = false;
  private final static String jndi_DataSource = "jdbc/BugMIS_ora";
  private final static String jdbcdriver =
      "oracle.jdbc.driver.OracleDriver";
  private final static String url =
      "jdbc:oracle:thin:@localhost:1521:myo9";
  private final static String user = "scott";
  private final static String pass = "tiger";

  public static DBPool newInstance() {
    return new DBPool();
  }

  /**
   * 切换是否使用连接池
   * */
  public Connection getConnection() {
    if (USE_DB_POOL) {
      conn = getConnectionByDBPool();
    }
    else {
      conn = getConnectionDirect();
    }
    return conn;
  }

  /**
   * 直接采用JDBC连接数据库
   * */
  private Connection getConnectionDirect() {
    try {
      Class.forName(jdbcdriver).newInstance();
      conn = DriverManager.getConnection(url, user, pass);
    }
    catch (SQLException ex) {
      log.error("Error Connection! " + ex.getMessage());
    }
    catch (ClassNotFoundException ex) {
      log.error("Driver Not Found! " + ex.getMessage());
    }
    catch (IllegalAccessException ex) {
      log.error(ex.getMessage());
    }
    catch (InstantiationException ex) {
      log.error(ex.getMessage());
    }
    return conn;
  }

  /**
   * 采用连接池
   * */
  private Connection getConnectionByDBPool() {
    try {
      Context initCtx = new InitialContext();
      Context ctx = (Context) initCtx.lookup("java:/comp/env");
      DataSource ds = (DataSource) ctx.lookup(jndi_DataSource);
      conn = ds.getConnection();
    }
    catch (NamingException ex) {
      log.error("Data Source Not Found! " + ex.getMessage());
      //System.out.println("未找到数据源" + ex.getMessage());
    }
    catch (SQLException ex1) {
      log.error("Error Connection! " + ex1.getMessage());
      //System.out.println("错误的数据连接" + ex1.getMessage());
    }
    return conn;
  }

  /**
   * 释放连接
   * */
  public void release() {
    try {
      if (!conn.isClosed()) {
        conn.close();
      }
    }
    catch (SQLException ex) {
      log.error("Connection Closing Error! " + ex.getMessage());
      //System.out.println("连接关闭失败" + ex.getMessage());
    }
  }
}

********包含常量的类constants.java，常量********

package page;

/**
 * 定义工程中公用的常量
 * <p>Title: 分页</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: BCS</p>
 * @author Alex
 * @version 1.0
 */
public final class constants {
  public static final int MAX_PAGE_INDEX = 5; //页脚显示多少页
  public static final int PAGE_SIZE = 2; //每页的记录数
}

********测试jsp页面index.jsp，为了方便测试，嵌入了java代码，能显示就行********

<%@ taglib uri="/WEB-INF/struts-logic.tld" prefix="logic" %>
<%@ taglib uri="/WEB-INF/struts-bean.tld" prefix="bean" %>
<%@ taglib uri="/WEB-INF/struts-html.tld" prefix="html" %>
<%@ page contentType="text/html; charset=GBK" import="java.util.*,page.*"%>
<html:html>
<head>
<title></title>
<style type="text/css">
.pt9 {  font: 10pt "宋体"}
body { font: 10pt "宋体" ; margin: 15px}
td {  font-size: 10pt}
a:hover {  font-size: 10pt; color: red; text-decoration: underline}
a:link {  font-size: 10pt; color: blue; text-decoration: underline}
a:active {  font-size: 10pt; color: blue; text-decoration: underline}
a:visited { font-size: 10pt; color: blue; text-decoration: underline }
</style>
</head>
<body bgcolor="#ffffff">

<p><a href="http://localhost:8088/page/showEmp.do?offset=0">Show Me All Of The Emps</a></p>

<logic:present name="emps">
  <%
  ArrayList emps = (ArrayList)request.getAttribute("emps");
  Iterator it = emps.iterator();
  empVO empvo;
  while(it!=null && it.hasNext()){
    empvo = (empVO)it.next();
    out.print(empvo.getEmpno() + "  ");
    out.print(empvo.getEname() + "<br>");
  }
    out.print("当前页有 " + emps.size() + " 条记录<br>");
    out.print("<p>");
  %>
</logic:present>

<logic:present name="pager">
  <%
  Pager pager = (Pager)request.getAttribute("pager");
  out.print(pager.getPageNavigation() + "<p>");
  out.print("共有记录 " + pager.getSize() + " 条<br>");
  out.print("每页有 " + pager.getLength() + " 条记录<br>");
  out.print("共分 " + pager.pageCount() + " 页<br>");
  %>
</logic:present>
</body>
</html:html>

********配置文件struts-config.xml********

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE struts-config PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 1.1//EN" "http://jakarta.apache.org/struts/dtds/struts-config_1_1.dtd">
<struts-config>
  <form-beans>
    <form-bean name="empForm" type="page.empForm" />
  </form-beans>
  <action-mappings>
    <action input="/index.jsp" name="empForm" path="/showEmp" scope="request" type="page.empAction" validate="false">
      <forward name="faiure" path="/index.jsp" />
      <forward name="success" path="/index.jsp" />
    </action>
  </action-mappings>
</struts-config>

在网上看了几个Structs分页，感觉不是很完善，于是根据自己的经验，写了一个相对高效简洁的分页方法。由于本人水平有限，如果大家有什么更好的想法，欢迎不吝赐教。
　　
　　一、 开发环境
　　
　　我的开发环境是：JBuilder x + Weblogic 8.1 + Oracle 9i + Windows 2003 ，如果朋友们的开发环境不一样亦无妨。
　　
　　二、开发思路
　　
　　既然讲的是Struts，那自然离不了MVC，分页显示也是如此。
　　
　　1、 建立数据库和对应的表，本例的表是TCertificate。
　　
　　2、 建立适当的模型组件，对应你要查询数据库中的表。这部分由DAO数据访问层来实现，如果有的朋友对DAO不熟悉可以查询一下相关资料。本例由CertificateDAO.java来实现。
　　
　　3 、建立分页所需要的模型组件，由javaBean来充当，并与CertificateDAO实现分离。网上介绍的很多方法，都存在着数据与分页组件藕合的现象，这也是本方法与其它分页方法的主要不同之处。
　　
　　4、建立控制器组件，这部分由Struts 中的Action来实现。主要负责将实例化CertificateDAO，只取要显示的数据记录，存入ArrayList对象然后返回，并放到request中。而分页部分则根据分页条件，单独进行构造，避免了与DAO混在一起的情况发生。网上其它介绍的一些分页方法中，基本上都是一次性读出所有查询的数据，然后再由分页相关组件进行构造。这样，如果数据量大的话，很容易形成瓶颈。在本例中由于不是一次性地读出查询的所有数据，而只是读出一个页面要显示的数据记录，这就节省了很多不必要的数据传输，提高了效率。本例中为CertificateAction.java。
　　
　　5、建立视图组件，这部分由jsp来充当，为了不出现java 代码，我们使用Struts提供的标签库，主要负责从request中取出刚刚放入的对象，通过反复调用CertificateAction以及action参数，而实现分页显示。本例中为listcertificate.jsp。
　　
　　6、 建立并配置struts-config.xml。
　　
　　三、实例代码
　　
　　确定好上面的开发思路后，代码的实现就有单可循了。
　　
　　1、建数据库和相应的表。
　　
　　2、数据逻辑层的相关代码。
　　
　　1）、通用的DAO类：CommonDAO.java
　　
　　这是一个很多DAO都要继承到的通用DAO类，是我根据实践总结出来的，为了减少篇幅，这里只显示和本例相关的代码。
　　
　　java代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　package com.xindeco.business ;
　　import java.io.*;
　　import java.sql.*;
　　import java.util.*;
　　import javax.sql.*;
　　import java.lang.IllegalAccessException;
　　import java.lang.reflect.InvocationTargetException;
　　import org.apache.commons.beanutils.BeanUtils;
　　public class DAO
　　{
　　protected DataSource ds;
　　/**
　　* 说明:取得当前查询的总记录数
　　*/
　　public int getRows ()
　　{
　　return this.count;
　　}
　　public void rsHandler (ResultSet rs, int offset, int limit)
　　{
　　try
　　{
　　count = 0;
　　rs.absolute ( -1) ;
　　count = rs.getRow () ;
　　if (offset <= 0)
　　{
　　rs.beforeFirst () ;
　　}
　　else
　　{
　　rs.absolute (offset) ;
　　}
　　}
　　catch (Exception e)
　　{
　　e.printStackTrace () ;
　　}
　　}
　　public DAO(DataSource ds) {
　　this.ds = ds;
　　}
　　
　　public void setDataSource(DataSource ds) {
　　this.ds = ds;
　　}
　　
　　protected void close(ResultSet rs) {
　　if (rs != null) {
　　try {
　　rs.close();
　　} catch (SQLException e) {
　　}
　　rs = null;
　　}
　　}
　　
　　protected void close(PreparedStatement pstmt) {
　　if (pstmt != null) {
　　try {
　　pstmt.close();
　　} catch (SQLException e) {
　　}
　　pstmt = null;
　　}
　　}
　　protected void close(Connection conn) {
　　if (conn != null) {
　　try {
　　conn.close();
　　} catch (SQLException e) {
　　e.printStackTrace();
　　}
　　conn = null;
　　}
　　}
　　
　　protected void rollback(Connection conn) {
　　if (conn != null) {
　　try {
　　conn.rollback();
　　} catch (SQLException e) {
　　e.printStackTrace();
　　}
　　conn = null;
　　}
　　}
　　}
　　
　　这个类主要是通过子类传进来的先进结果集，取得查询的记录总数，并对数据库连接进行简单的管理。
　　
　　2）、对数据库进行访问：CertificateDAO.java
　　
　　java代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　package com.xindeco.business;
　　
　　import java.io.*;
　　import java.sql.*;
　　import java.util.*;
　　import javax.sql.*;
　　
　　import com.xindeco.common.dbconn.DbConn;
　　
　　public class CertificateDAO extends DAO
　　{
　　
　　public NationDAO(DataSource ds) {
　　super(ds);
　　}
　　
　　public List findCertificateList(int offset,int limit) throws SQLException
　　{
　　int countRows = 0 ;
　　ArrayList list = null ;
　　Connection conn = null;
　　PreparedStatement pstmt = null;
　　ResultSet rs = null;
　　try
　　{
　　conn = ds.getConnection();
　　String sql =
　　"SELECT certificateID, certificateCode,certificateName,photoURL,"
　　+ "description,graduateID FROM TCertificate " ;
　　pstmt = conn.prepareStatement(sql);
　　rs = pstmt.executeQuery();
　　/*对游标进行处理，rsHandler 方法在父类DAO中*/
　　this.rsHandler(rs,offset,limit);
　　if (rs != null && rs.next ())
　　{
　　list = new ArrayList () ;
　　do
　　{
　　countRows++ ;
　　list.add (rs2VO (rs)) ;
　　}
　　while ( (countRows++ < limit) && rs.next ()) ;
　　}
　　close(rs);
　　close(pstmt);
　　} catch (SQLException e) {
　　close(rs);
　　close(pstmt);
　　rollback(conn);
　　e.printStackTrace();
　　}
　　finally {
　　close(conn);
　　}
　　return list ;
　　}
　　
　　private CertificateVO rs2VO (ResultSet rs)
　　{
　　try
　　{
　　CertificateVO certificateVO = new CertificateVO () ;
　　certificateVO.setCertificateID (rs.getInt ("certificateID")) ;
　　certificateVO.setCertificateCode (rs.getString ("certificateCode")) ;
　　certificateVO.setCertificateName (rs.getString ("certificateName")) ;
　　certificateVO.setPhotoURL (rs.getString ("photoURL")) ;
　　certificateVO.setDescription (rs.getString ("description")) ;
　　certificateVO.setGraduateID (rs.getInt ("graduateID")) ;
　　return certificateVO ;
　　}
　　catch (Exception ex)
　　{
　　ex.printStackTrace () ;
　　return null ;
　　}
　　}
　　}
　　
　　findCertificateList(int offset,int limit)是查得所有要显示的数据，并放入ArrayList中。看过网上有些例子，把数据记录放入ArrayList的动作过程直接在while循环体里完成，如果字段多的话，会造成方法过于宠大，又不美观。 这里，数据记录放入ArrayList的动作过程由rs2VO方法完成，就比较整洁了。另外，if (rs != null && rs.next ()) 配合while ( (countRows++ < limit) && rs.next ()) 是为了程序的健壮性考虑的，稍分析一下不难得出结论。
　　
　　3、建立控制器组件：CertificateAction.java
　　
　　java代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　package com.xindeco.presentation;
　　
　　import javax.sql.* ;
　　import java.util.* ;
　　
　　import javax.servlet.http.* ;
　　import javax.servlet.* ;
　　
　　import org.apache.struts.action.* ;
　　import org.apache.struts.util.* ;
　　
　　import com.xindeco.common.Pager;
　　import com.xindeco.business.graduatedata.CertificateDAO ;
　　
　　public class CertificateAction
　　extends Action
　　{
　　private static final int PAGE_LENGTH = 5 ; //每页显示5条记录
　　public ActionForward execute (ActionMapping mapping, Actionform form,
　　HttpServletRequest request,
　　HttpServletResponse response)
　　{
　　ActionForward myforward = null ;
　　String myaction = mapping.getParameter () ;
　　
　　if (isCancelled (request))
　　{
　　return mapping.findForward ("failure") ;
　　}
　　if ("".equalsIgnoreCase (myaction))
　　{
　　myforward = mapping.findForward ("failure") ;
　　}
　　else if　　　　("LIST".equalsIgnoreCase (myaction))
　　{
　　myforward = performList (mapping, form, request, response) ;
　　}
　　else
　　{
　　myforward = mapping.findForward ("failure") ;
　　}
　　return myforward ;
　　}
　　
　　private ActionForward performList (ActionMapping mapping,
　　Actionform actionform,
　　HttpServletRequest request,
　　HttpServletResponse response)
　　{
　　try
　　{
　　DataSource ds = (DataSource) servlet.getServletContext().getAttribute(Action.DATA_SOURCE_KEY);
　　
　　CertificateDAO　 certificateDAO　= new CertificateDAO　(ds) ;
　　
　　int offset = 0;　 //翻页时的起始记录所在游标
　　int length = PAGE_LENGTH;
　　String pageOffset = request.getParameter("pager.offset");
　　if (pageOffset == null || pageOffset.equals("")) {
　　offset = 0;
　　} else {
　　offset = Integer.parseInt(pageOffset);
　　}
　　List certificateList = certificateDAO .findCertificateList (offset,length) ;
　　int size = certificateDAO.getRows(); //　取得总记录数
　　String url = request.getContextPath()+"/"+mapping.getPath()+".do";
　　String pagerHeader = Pager.generate(offset, size, length, url); //分页处理
　　
　　request.setAttribute ("pager", pagerHeader) ;
　　request.setAttribute ("list", certificateList) ;
　　}
　　catch (Exception e)
　　{
　　e.printStackTrace();
　　return mapping.findForward ("error") ;
　　}
　　return mapping.findForward ("success") ;
　　}
　　}
　　
　　CertificateAction.java主要是把数据从DAO中取出，并放入一个ArrayList 中，然后通过配置文件再软件View的JSP页。
　　
　　5、建立视图listcertificate.jsp文件。
　　
　　jsp代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　
　　<%@ page contentType="text/html; charset=GBK" %>
　　<%@ taglib uri="/WEB-INF/struts-template.tld" prefix="template" %>
　　<%@ taglib uri="/WEB-INF/struts-html.tld" prefix="html" %>
　　<%@ taglib uri="/WEB-INF/struts-bean.tld" prefix="bean" %>
　　<%@ taglib uri="/WEB-INF/struts-logic.tld" prefix="logic" %>
　　
　　<table bgcolor="#666666" cellpadding="1" cellspacing="0" border="0" width="500">
　　<tr>
　　<td>
　　<table cellpadding="0" cellspacing="0" border="0" width="500">
　　<tr>
　　<td bgcolor="#fecc51">&</td>
　　</tr>
　　</table>
　　</td>
　　</tr>
　　<tr>
　　<td>
　　<table cellpadding="0" cellspacing="0" border="0" width="500">
　　<tr>
　　<td bgcolor="#d6e0ed">
　　&&<bean:message key="label.list4certificate"/>
　　</td>
　　</tr>
　　<tr bgcolor="#FFFFFF">
　　<td width="5%"></td><td width="19%"></td><td width="76%"></td>
　　</tr>
　　<tr>
　　<td>
　　<table bgcolor="#f2f2f2" width="500" cellspacing="0" border="0">
　　<tr bgcolor="#bacce1">
　　<td><b><bean:message key="Certificate.select"/> </b></td>
　　<td><b><bean:message key="Certificate.certificateID"/> </b></td>
　　<td><b><bean:message key="Certificate.certificateCode"/></b></td>
　　<td><b><bean:message key="Certificate.certificateName"/></b></td>
　　<td><b><bean:message key="Certificate.view"/></b></td>
　　</tr>
　　
　　<bean:write name="pager" property="description"/>
　　<logic:equal name="pager" property="hasPrevious" value="true">
　　<a href="/graduatedata/list.do?viewPage=<bean:write name="pager" property="previousPage"/>" class="a02">
　　Previous
　　</a>
　　</logic:equal>
　　<logic:equal name="pager" property="hasNext" value="true">
　　<a href="/graduatedata/list.do?viewPage=<bean:write name="pager" property="nextPage"/>" class="a02">
　　Next
　　</a>
　　</logic:equal>
　　
　　<logic:notEmpty name="list" scope="request">
　　<logic:iterate id="certificate" name="list" type="com.xindeco.business.graduatedata.CertificateVO"scope="request">
　　<tr bgcolor="#FFFFFF">
　　<td><html:text property="name" value="<bean:write name="certificate" property="certificateID" scope="page"/>"/>
　　</td>
　　<td> <bean:write name="certificate" property="certificateID" scope="page"/></td>
　　<td> <bean:write name="certificate" property="certificateCode" scope="page"/></td>
　　<td> <bean:write name="certificate" property="certificateName" scope="page"/></td>
　　<td> <bean:write name="certificate" property="photoURL" scope="page"/></td>
　　</tr>
　　</logic:iterate>
　　</logic:notEmpty>
　　</table>
　　</td>
　　</tr>
　　</table>
　　</td>
　　</tr>
　　</table>
　　
　　6、对应的配置文件struts-config.xml。
　　
　　java代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　<?xml version="1.0" encoding="UTF-8"?>
　　<!DOCTYPE struts-config PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 1.1//EN" "http://jakarta.apache.org/struts/dtds/struts-config_1_1.dtd">
　　<struts-config>
　　<form-beans>
　　<form-bean name="certificateform" type="com.xindeco.presentation.graduatedata.Certificateform" />
　　</form-beans>
　　<global-forwards>
　　<forward name="error" path="/error/error.jsp" />
　　</global-forwards>
　　<action-mappings>
　　<action name="certificateform" parameter="LIST" path="/graduatedata/list" scope="request" type="com.xindeco.presentation.graduatedata.CertificateAction" validate="true">
　　<forward name="success" path="/graduatedata/listcertificate.jsp" />
　　</action>
　　</action-mappings>
　　……
　　</struts-config>
　　
　　7、最后当然是最重要的分页代码了：Pager.java
　　
　　java代码:
　　
　　代码：
　　--------------------------------------------------------------------------------
　　package com.xindeco.common;
　　
　　import java.util.* ;
　　public class Pager {
　　private static int MAX_PAGE_INDEX = 10; //页脚显示多少页
　　private static String HEADER = "Result page";
　　
　　public static String generate(int offset, int length, int size, String url) {
　　if (length > size) {
　　String pref;
　　if (url.indexOf("?") > -1) {
　　pref = "&";
　　} else {
　　pref = "?";
　　}
　　String header = "<font face='Helvetica' size='-1'>"+HEADER+": ";
　　if (offset > 0) {
　　header += "&<a href=\""+url+pref+"pager.offset="+(offset-size)+"\">[<< Prev]</a>\n";
　　}
　　int start;
　　int radius = MAX_PAGE_INDEX/2*size;
　　if (offset < radius) {
　　start = 0;
　　} else if(offset < length-radius) {
　　start = offset - radius;
　　} else {
　　start = (length/size-MAX_PAGE_INDEX)*size;
　　}
　　for(int i=start;i<length && i < start + MAX_PAGE_INDEX*size;i+=size) {
　　if (i == offset) {
　　header += "<b>"+(i/size+1)+"</b>\n";
　　} else {
　　header += "&<a href=\""+url+pref+"pager.offset="+i+"\">"+(i/size+1)+"</a>\n";
　　}
　　}
　　if(offset < length - size) {
　　header += "&<a href=\""+url+pref+"pager.offset="+((int)offset+(int)size)+"\">[Next >>]</a>\n";
　　}
　　header += "</font>";
　　return header;
　　} else {
　　return "";
　　}
　　}
　　}
　　
　　这部分代码的实现相当简洁，但已经足够完成所需了。

2、DB2数据库
Class.forName("com.ibm.db2.jdbc.app.DB2Driver ").newInstance();
String url="jdbc:db2://localhost:5000/sample";
//sample为你的数据库名
String user="admin";
String password="";
Connection conn= DriverManager.getConnection(url,user,password);

3、Sql Server7.0/2000数据库
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
String url="jdbc:microsoft:sqlserver://localhost:1433;databasename=pubs";
//mydb为数据库
String user="sa";
String password="";
Connection conn= DriverManager.getConnection(url,user,password);

4、Sybase数据库
Class.forName("com.sybase.jdbc.SybDriver").newInstance();
String url =" jdbc:sybase:Tds:localhost:5007/myDB";
//myDB为你的数据库名
Properties sysProps = System.getProperties();
SysProps.put("user","userid");
SysProps.put("password","user_password");
Connection conn= DriverManager.getConnection(url, SysProps);

5、Informix数据库
Class.forName("com.informix.jdbc.IfxDriver").newInstance();
String url =
"jdbc:informix-sqli://123.45.67.89:1533/myDB:INFORMIXSERVER=myserver;
user=testuser;password=testpassword";
//myDB为数据库名
Connection conn= DriverManager.getConnection(url);

6、MySQL数据库
Class.forName("org.gjt.mm.mysql.Driver").newInstance();
String url ="jdbc:mysql://localhost/myDB?user=soft&password=soft1234&useUnicode=true&characterEncoding=8859_1"
//myDB为数据库名
Connection conn= DriverManager.getConnection(url);

7、PostgreSQL数据库
Class.forName("org.postgresql.Driver").newInstance();
String url ="jdbc:postgresql://localhost/myDB"
//myDB为数据库名
String user="myuser";
String password="mypassword";
Connection conn= DriverManager.getConnection(url,user,password);
8、access数据库
con = DriverManager.getConnection("jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=C:/data/Access/test1.mdb","dba","sql");