中文字幕在线一二,а√在线天堂官网,99视频在线

CoolYongZi — Wed, 01 Aug 2007 08:15:00 GMT

在基于JDBC的数据库应用开发中�Q�数据库�q�接的管理是一个难点，因�ؓ它是军_��该应用性能的一个重要因素。本文在�Ҏ��据库�q�接�q�行透彻分析的基��上，提出�q�实��C��一个高效的�q�接��理�{�略�Q��得开发高性能的数据库应用变得相对�Ҏ��。特别是�Q�对于连接管理中的两个难点：事务和多�U�程问题�q�行了深入的剖析�Q��ƈ�l�出了一个基于设计模式的解决�Ҏ��?br>介绍

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

对于一个简单的数据库应用，�׃��对于数据库的讉K��不是很频�J�。这时可以简单地在需要访问数据库�Ӟ��新创徏一个连接，用完后就关闭它，�q�样做也不会带来什么明昄��性能上的开销。但是对于一个复杂的数据库应用，情况��完全不同了。频�J�的建立、关闭连接，会极大的减低�pȝ��的性能�Q�因为对于连接的使用成了�pȝ��性能的瓶颈�?/p>

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

问题产生\r

我参与的��目是开发一个网��系�l�，不可避免的要和数据库打交道。刚开始时�Q�由于对于数据库的访问不是很频繁�Q�对于数据库�q�接的��用就是简单的需要时��徏立，用完��关闭的�{�略�Q�这很符合XP�Q�eXtreme Programming�Q�的口号�Q?Do the Simplest Thing that Could Possibly Work"。确实，开始时工作的很好。随着��目的进展，对于数据库的讉K��开始变的频�J�，问题��暴露出来了�Q�原先的通过��单地获取和关闭数据库�q�接的方法将很大的媄响系�l�的性能�Q�这�U�媄响是�׃��数据库资源管理器�q�程频繁的创建和摧毁那些�q�接对象而引��L��?/p>

此时�Q�就有必要对数据库访问方法进行重构（refactoring�Q�，因�ؓ我们��实需要进行改�q�，来提高系�l�的性能�?/p>

解决�Ҏ��

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

3.1、徏立连接池

�W�一步，��是要徏立一个静态的�q�接池，所谓静态是指，池中的连接是在系�l�初始化时就分配好的�Q��ƈ且不能够随意关闭的。Java中给我们提供很多容器�c�d��以方便的用来构徏�q�接池，如：Vector、Stack�{�。在�pȝ��初始化时�Q�根据配�|�创��接�ƈ攄��在连接池中，以后所使用的连接都是从该连接池中获取的�Q�这样就可以避免�q�接随意建立、关闭造成的开销�Q�当�Ӟ��我们没有办法避免Java的Garbage Collection带来的开销�Q��?/p>

3.2、分配、释攄��?/p>

有了�q�个�q�接池，下面我们��可以提供一套自定义的分配、释攄��略�?/p>

当客戯��求数据库�q�接�Ӟ��首先看连接池中是否有�I�闲�q�接�Q�这里的�I�闲是指�Q�目前没有分配出�ȝ��q�接。如果存在空闲连接则把连接分配给客户�Q��ƈ作相应处理，具体处理�{�略�Q�在关键议题中会详述�Q�主要的处理�{�略��是标记该连接�ؓ已分配。若�q�接池中没有�I�闲�q�接�Q�就在已�l�分配出�ȝ��q�接中，��L��一个合适的�q�接�l�客��P��选择�{�略会在关键议题中详�q�ͼ��Q�此时该�q�接在多个客户间复用�?/p>

当客户释放数据库�q�接�Ӟ��可以�Ҏ��该连接是否被复用�Q�进行不同的处理。如果连接没有��用者，��放入到�q�接池中�Q�而不是被关闭�?/p>

可以看出正是�q�套�{�略保证了数据库�q�接的有效复用�?/p>

3.3、配�|�策�?/p>

数据库连接池中到底要攄��多少个连接，�q�接耗尽后该如何处理呢？�q�时一个配�|�策略。一般的配置�{�略是，开始时�Q�根据具体的应用需求，�l�出一个初始的�q�接池中�q�接的数目以及一个连接池可以扩张到的最大连接数目。本�Ҏ��是按照�q�种�{�略实现的�?/p>

关键议题\r

本节��对上述解决�Ҏ��中的关键�l�节�q�行详述�Q�正是这些关键的�{�略保证了数据库�q�接复用的高效和安全�?/p>

4.1、引用记�?/p>

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

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

4.2、事务处理\r

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

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

在我们的�q�接��理服务提供了显式的事务开始、结束（commit或者rollback�Q�声明，以及一个事务注册表�Q�用于登��C��务发赯��和事务使用的连接的对应关系�Q�通过该表�Q��用事务的部分和我们的�q�接��理部分��隔��d��Q�因��表是在运行时�Ҏ��实际的调用情况，动态生成的。事务��用的�q�接在该事务�q�行中不能被复用�?/p>

当��用者需要��用事务方法时�Q�首先调用连接管理服务提供的beginTrans�Ҏ��Q�该�Ҏ��主要处理��程如下(伪码描述)�Q?/p>

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

在我们的实现中，用户标识是通过使用者所在的�U�程来标识的。后面的所有对于数据库的访问都是通过查找该注册表�Q��用已�l�分配的�q�接来完成的。当事务�l�束�Ӟ��从注册表中删除相应表��V�?/p>

对于嵌套的事务如何处理呢�Q�我们采用的�Ҏ��仍�ؓ引用记数�Q�不�q�这里的引用记数是指�?嵌套层次"�Q�具体的�l�节�Q�不再赘�q��?/p>

4.3、封�?/p>

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

4.4、�ƈ发问题\r

��Z��是我们的�q�接��理服务有更大的通用性，��必��要考虑到多�U�程环境�Q�即�q�发问题。在一个多�U�程的环境下�Q�我们必��要保证�q�接��理自��n数据的一致性和�q�接内部数据是一致性，�q�好Java提供对这斚w��的很好的支持�Q�synchronized关键字）�Q�这��h��们就很容易�ɘq�接��理成�ؓ�U�程安全的�?/p>

5、结�?/p>

本文�l�出了一个基本的�q�接��理框架�Q�在其中使用了一些广泛��用的设计模式�Q�资源池�Q�引用记数等�Q�，使得高效、安全的复用数据库连接成为可能。当�Ӟ��q�有一些问题没有考虑刎ͼ�比如�Q�没有实现对不同�U�类的数据库的联合管理；没有提供定时��机�Ӟ��查询�q�接的状态等。另外在�q�接��理的��用包装上比�v一些商用的�pȝ��q�显�_�糙�Q�但是底层的基理是一致的�Q�所以通过本文�怿�对于�q�些商用的��品中的相兛_��能会有更好的理解�?/p>

参考文�?br>《Thinking in Java》Bruce Eckel

《Real-Time Design Patterns�?Bruce Powel Dougladd

CoolYongZi 2007-08-01 16:15 发表评论

Struts分页

CoolYongZi — Wed, 01 Aug 2007 08:11:00 GMT

拜读了bibiye的《一个高效简�z�的Struts分页�Ҏ��(原创)》后�Q�根据bibiye的方法，自己修改了一下，也弄了一个struts下的分页�Q�大家见�W�了�Q?/p>

我的�Ҏ��是，�Ҏ��用户点击��D��条上的页�?offset)�Q�到DB中读取该��늚�数据(不是一�ơ全部读�?�Q�点到哪��读哪页的数据，JBX + tomcat + oracle下测试通过�Q�数据库用的表是oracle的emp表�?/p>

********分页�c�Pager.java�Q�负责生成分��导航条********

package page;

/**
* 分页代码
*

Title: 分页

Description:

Company: BCS

* @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;
}

/**
   * �q�回分页��D��?br>   * @param offset int 起始记录的位�|?br>   * @param size int 总记录数
   * @param length int 步长
   * @param url String .do的url
   * @param pageHeader String ��D��条的前缀文字提示
   * @return String
   */
public String getPageNavigation() {
    String pageNavigation = ""; //最�l�返回的分页��D��?br>    //记录数超�q�一��?需要分��?br>    if (size > length) {
      String pref; //前缀
      if (url.indexOf("?") > -1) {
        //如果url中已�l�包含了其他的参�?��把offset参数接在后面
        pref = "&";
      }
      else {
        //如果url中没有别的参�?br>        pref = "?";
      }
      //如果��D��条包含header
      if (pageHeader != null && pageHeader.length() > 0) {
        pageNavigation = pageHeader + " : ";
      }
      //如果不是�W�一��?��D��条将包含“<<”(�W�一��?�?#8220;<”(前一��?
      if (offset > 0) {
        pageNavigation += "[<<]\n" +
            "[<]\n";
      }
      //��D��条中,排头的那一��늚�offset�?br>      int startOffset;
      //位于��D��条中间的那一��늚�offset�?半径)
      int radius = constants.MAX_PAGE_INDEX / 2 * length;
      //如果当前的offset值小于半�?br>      if (offset < radius || this.pageCount() <= constants.MAX_PAGE_INDEX) {
        //那么�W�一��|��?br>        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 += "" + (i / length + 1) + "\n";
        }
        else {
          //其他��号,包含��链�?br>          pageNavigation += "" +
              (i / length + 1) + "\n";
        }
      }
      //如果不是最后一��?��D��条将包含“>”(下一��?�?#8220;>>”(最后一��?
      if (offset < size - length) {
        pageNavigation += "[>]\n" +
            "[>>]\n";
      }
//      System.out.println("radius : " + radius);
//      System.out.println("start offset : " + startOffset);
      return pageNavigation;
    }
    //记录不超�q�一��?不需要分��?br>    else {
      return "";
    }
}

/**
   * �q�回分页后的总页�?br>   * @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;
}

/**
   * �q�回最后一��늚�记录�?br>   * @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;
}

/**
   * �q�回最后一��늚�起始记录位置
   * @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;
}
}

********数据处理�c�empDAO.java�Q�负责访问DB�Q�获取当前页面需要显�C�的记录********

package page;

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

public class empDAO {
public empDAO() {
}

/**
   * 从offset位置起始,�q�回length条记�?br>   * @param offset int 起始的记录位�|?br>   * @param length int 步长
   * @param conn Connection 数据库连�?br>   * @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); //起始记录的位�|?br>      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;
}

/**
   * �q�回�ȝ��记录�?br>   * @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;
}
}

********业务�c�empBO.java�Q�调用empDAO�c?*******

package page;

import java.util.*;

/**
* BO�c?br> *

Title: 分页

Description:

Company: BCS

* @author Alex
* @version 1.0
*/
public class empBO {
private DBPool db = DBPool.newInstance();
private empDAO empdao = new empDAO();

public empBO() {
}

/**
   * 从offset位置起始,�q�回length条记�?br>   * @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;
}

/**
   * �q�回�ȝ��记录�?br>   * @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�c�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; //记录默认从第一条开始显�C?br> }

public int getOffset() {
return offset;
}

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

}

********Action�c�empAction.java�Q�控制器�Q�调用BO�c�，Pager�c?*******

package page;

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

import org.apache.struts.action.*;

/**
* 分页��试的Action
*

Title: 分页

Description:

Company: BCS

* @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();
      //获取外部传进来的起始记录�?br>      int offset = ( (empForm) actionForm).getOffset();
      //获取每页的记录数
      int pagesize = constants.PAGE_SIZE;
      //获取记录集合,从offset开�?取length条记�?br>      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");
      //获取分页��D��?br>      //String pageNavigation = p.getPageNavigation();
      //��url字符串和记录集合,存入request�?br>      request.setAttribute("pager", p);
      request.setAttribute("emps", emps);
    }
    catch (Exception e) {
      e.printStackTrace();
      return actionMapping.findForward("failure");
    }
    return actionMapping.findForward("success");
}
}

********数据库连接池�c�DBPool.java�Q�可以��用tomcat的连接池�Q�也可以不用�Q�这里关闭了********

package page;

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

import org.apache.commons.logging.*;

/**
* �pȝ��q�接池类
*

Title: Gantoo@91.com>
*

Description:

Company: BCS

* @author Alex
* @version 1.0
*/
public class DBPool {
Log log = LogFactory.getLog("DBPool"); //日志�?br> private DBPool() {
}

private Connection conn = null;

/* true:使用�q�接�?br>     false:不��用连接池,采用JDBC直接�q�接 */
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();
}

/**
   * 切换是否使用�q�接�?br>   * */
public Connection getConnection() {
    if (USE_DB_POOL) {
      conn = getConnectionByDBPool();
    }
    else {
      conn = getConnectionDirect();
    }
    return conn;
}

/**
   * 直接采用JDBC�q�接数据�?br>   * */
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;
}

/**
   * 采用�q�接�?br>   * */
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;
}

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

********包含帔R��的类constants.java�Q�常�?*******

package page;

/**
* 定义工程中公用的帔R��
*

Title: 分页

Description:

Company: BCS

* @author Alex
* @version 1.0
*/
public final class constants {
public static final int MAX_PAGE_INDEX = 5; //��脚昄��多少��?br> public static final int PAGE_SIZE = 2; //每页的记录数
}

********��试jsp��面index.jsp�Q��ؓ了方便测试，嵌入了java代码�Q�能昄��p��********

<%@ 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.*"%>

Show'>http://localhost:8088/page/showEmp.do?offset=0">Show Me All Of The 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() + "
");
}
    out.print("当前��|�� " + emps.size() + " 条记�?lt;br>");
    out.print("

");
%>

<%
Pager pager = (Pager)request.getAttribute("pager");
out.print(pager.getPageNavigation() + "

");
out.print("共有记录 " + pager.getSize() + " �?lt;br>");
out.print("每页�?" + pager.getLength() + " 条记�?lt;br>");
out.print("共分 " + pager.pageCount() + " ��?lt;br>");
%>

********配置文�gstruts-config.xml********

在网上看了几个Structs分页�Q�感觉不是很完善�Q�于是根据自��q��l�验�Q�写了一个相寚w��效简�z�的分页�Ҏ��。由于本人水�q�x��限，如果大家有什么更好的��x��Q�欢�q�不吝赐教�?br>　　
　　一�?开发环�?br>　　
　　我的开发环境是�Q�JBuilder x + Weblogic 8.1 + Oracle 9i + Windows 2003 �Q�如果朋友们的开发环境不一样亦无妨�?br>　　
　　二、开发思�\
　　
　　既然讲的是Struts�Q�那自然��M��了MVC�Q�分��|��C�Z��是如此�?br>　　
　　1�?建立数据库和对应的表�Q�本例的表是TCertificate�?br>　　
　　2�?建立适当的模型组�Ӟ��对应你要查询数据库中的表。这部分由DAO数据讉K��层来实现�Q�如果有的朋友对DAO不熟悉可以查询一下相兌��料。本例由CertificateDAO.java来实现�?br>　　
　　3 、徏立分��|��需要的模型�l��g�Q�由javaBean来充当，�q�与CertificateDAO实现分离。网上介�l�的很多�Ҏ��Q�都存在着数据与分��늻�件藕合的现象�Q�这也是本方法与其它分页�Ҏ��的主要不同之处�?br>　　
　　4、徏立控制器�l��g�Q�这部分由Struts 中的Action来实现。主要负责将实例化CertificateDAO�Q�只取要昄��的数据记录，存入ArrayList对象然后�q�回�Q��ƈ攑ֈ�request中。而分��部分则�Ҏ��分页条�g�Q�单独进行构造，避免了与DAO混在一��L��情况发生。网上其它介�l�的一些分��|��法中�Q�基本上都是一�ơ性读出所有查询的数据�Q�然后再由分��늛�关组件进行构造。这��P��如果数据量大的话�Q�很�Ҏ��形成瓉��。在本例中由于不是一�ơ性地��d��查询的所有数据，而只是读��Z��个页面要昄��的数据记录，�q�就节省了很多不必要的数据传输，提高了效率。本例中为CertificateAction.java�?br>　　
　　5、徏立视囄��Ӟ��q�部分由jsp来充当，��Z��不出现java 代码�Q�我们��用Struts提供的标�{�ֺ��Q�主要负责从request中取出刚刚放入的对象�Q�通过反复调用CertificateAction以及action参数�Q�而实现分��|��C�。本例中为listcertificate.jsp�?br>　　
　　6�?建立�q��|�struts-config.xml�?br>　　
　　三、实例代�?br>　　
　　��定好上面的开发思�\后，代码的实现就有单可��@了�?br>　　
　　1、徏数据库和相应的表�?br>　　
　　2、数据逻辑层的相关代码�?br>　　
　　1�Q�、通用的DAO�c�：CommonDAO.java
　　
　　�q�是一个很多DAO都要�l�承到的通用DAO�c�，是我�Ҏ��实践�ȝ��出来的，��Z��减少��幅�Q�这里只昄��和本例相关的代码�?br>　　
　　java代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　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;
　　}
　　}
　　}
　　
　　�q�个�c�M��要是通过子类传进来的先进�l�果集，取得查询的记录��L��Q��ƈ�Ҏ��据库�q�接�q�行��单的��理�?br>　　
　　2�Q�、对数据库进行访问：CertificateDAO.java
　　
　　java代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　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 �Ҏ��在父�c�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)是查得所有要昄��的数据，�q�放入ArrayList中。看�q�网上有些例子，把数据记录放入ArrayList的动作过�E�直接在while循环体里完成�Q�如果字�D�多的话�Q�会造成�Ҏ��q�于宠大�Q�又不美观�?�q�里�Q�数据记录放入ArrayList的动作过�E�由rs2VO�Ҏ��完成�Q�就比较整洁了。另外，if (rs != null && rs.next ()) 配合while ( (countRows++ < limit) && rs.next ()) 是�ؓ了程序的健壮性考虑的，�E�分析一下不隑־�出结论�?br>　　
　　3、徏立控制器�l��g�Q�CertificateAction.java
　　
　　java代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　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条记�?br>　　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;　 //��页时的起始记录所在游�?br>　　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中取出，�q�放入一个ArrayList 中，然后通过配置文�g再��Y件View的JSP��c�?br>　　
　　5、徏立视图listcertificate.jsp文�g�?br>　　
　　jsp代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　
　　<%@ 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" %>
　　
　　

　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　" class="a02">
　　Previous
　　
　　
　　
　　" class="a02">
　　Next
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　


"/>

　　
　　6、对应的配置文�gstruts-config.xml�?br>　　
　　java代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　
　　
　　

　　……
　　

　　
　　7、最后当然是最重要的分��代码了�Q�Pager.java
　　
　　java代码:
　　
　　代码�Q?br>　　--------------------------------------------------------------------------------
　　package com.xindeco.common;
　　
　　import java.util.* ;
　　public class Pager {
　　private static int MAX_PAGE_INDEX = 10; //��脚昄��多少��?br>　　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 = ""+HEADER+": ";
　　if (offset > 0) {
　　header += "&[<< Prev]\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　　if (i == offset) {
　　header += ""+(i/size+1)+"\n";
　　} else {
　　header += "&"+(i/size+1)+"\n";
　　}
　　}
　　if(offset < length - size) {
　　header += "&[Next >>]\n";
　　}
　　header += "";
　　return header;
　　} else {
　　return "";
　　}
　　}
　　}
　　
　　�q�部分代码的实现相当��z�，但已�l��够完成所需了�?

CoolYongZi 2007-08-01 16:11 发表评论

Java�q�接��C��同数据库

CoolYongZi — Wed, 01 Aug 2007 08:02:00 GMT

1、Oracle8/8i/9i数据库（thin模式�Q?
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url="jdbc:oracle:thin:@localhost:1521:orcl";
//orcl为数据库的SID
String user="test";
String password="test";
Connection conn= DriverManager.getConnection(url,user,password);

2、DB2数据�?
Class.forName("com.ibm.db2.jdbc.app.DB2Driver ").newInstance();
String url="jdbc:db2://localhost:5000/sample";
//sample��Z��的数据库�?
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��Z��的数据库�?
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数据�?br>con = DriverManager.getConnection("jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=C:/data/Access/test1.mdb","dba","sql");

CoolYongZi 2007-08-01 16:02 发表评论