Servlet研发中JDBC的高级应用

发布时间：2023-08-01 15:07:12 所属栏目：教程来源：

导读：　　连结数据库

　　JDBC使用数据库URL来说明数据库驱动程序。数据库URL类似于通用的URL，但SUN 在定义时作了一点简化，其语法如下：

　　Jdbc::[node]/[database]

　　其中子协议（subprotocal）定义驱

　　连结数据库

　　JDBC使用数据库URL来说明数据库驱动程序。数据库URL类似于通用的URL，但SUN 在定义时作了一点简化，其语法如下：

　　Jdbc::[node]/[database]

　　其中子协议（subprotocal）定义驱动程序类型，node提供网络数据库的位置和端口号，后面跟可选的参数。例如：

　　String url=”jdbc:inetdae:myserver:1433?language=us-english&sql7=true”

　　表示采用inetdae驱动程序连接1433端口上的myserver数据库服务器，选择语言为美国英语，数据库的版本是mssql server 7.0。

　　java应用通过指定DriverManager装入一个驱动程序类。语法如下：

　　Class.forName(“”);

　　或

　　Class.forName(“”).newInstance();

　　然后，DriverManager创建一个特定的连接：

　　Connection connection=DriverManager.getConnection(url,login,password)；

　　Connection接口通过指定数据库位置，登录名和密码连接数据库。Connection接口创建一个Statement实例执行需要的查询：

　　Statement stmt=connection.createStatement();

　　Statement具有各种方法（API），如executeQuery，execute等可以返回查询的结果集。结果集是一个ResultSet对象。具体的可以通过jdbc开发文档查看。可以sun的站点上下载

　　下面例子来说明：

　　import java.sql.*; // 输入JDBC package

　　String url = "jdbc:inetdae:myserver:1433";// 主机名和端口

　　String login = "user";// 登录名

　　String password = "";// 密码

　　try {

　　　　DriverManager.setLogStream(System.out); file://为显示一些的信息打开一个流

　　　　file://调用驱动程序，其名字为com.inet.tds.TdsDriver

　　　　file://Class.forName("com.inet.tds.TdsDriver")；

　　　　file://设置超时

　　　　DriverManager.setLoginTimeout(10);

　　　　file://打开一个连接

　　　　Connection connection = DriverManager.getConnection(url,login,password);

　　　　file://得到数据库驱动程序版本

　　　　　DatabaseMetaData conMD = connection.getMetaData();

　　　　　System.out.println("Driver Name:/t" + conMD.getDriverName());

　　　　　System.out.println("Driver Version:/t" + conMD.getDriverVersion());

　　　　file://选择数据库

　　　　connection.setCatalog( "MyDatabase");

　　　　file://创建Statement

　　　　Statement st = connection.createStatement();

　　　　file://执行查询

　　　　ResultSet rs = st.executeQuery("SELECT * FROM mytable");

　　　　file://取得结果，输出到屏幕

　　　　while (rs.next()){

　　　　　　　for(int j=1; j<=rs.getMetaData().getColumnCount(); j++){

　　　　　　　　System.out.print( rs.getObject(j)+"/t");

　　　　　　　}

　　　　　System.out.println();

　　　　}

　　　　file://关闭对象

　　　　st.close();

　　　　　　connection.close();

　　　　} catch(Exception e) {

　　　　　　e.printStackTrace();

　　　　}

　　　　建立连结池

　　　　一个动态的网站频繁地从数据库中取得数据来构成html页面。每一次请求一个页面都会发生数据库操作。但连接数据库却是一个需要消耗大量时间的工作，因为请求连接需要建立通讯，分配资源，进行权限认证。这些工作很少能在一两秒内完成。所以，建立一个连接，然后再后续的查询中都使用此连接会大大地提高性能。因为servlet可以在不同的请求间保持状态，因此采用数据库连接池是一个直接的解决方案。

　　　　Servlet在服务器的进程空间中驻留，可以方便而持久地维护数据库连接。接下来，我们介绍一个完整的连接池的实现。在实现中，有一个连接池管理器管理连接池对象，其中每一个连接池保持一组数据库连接对象，这些对象可为任何servlet所使用。

　　　　一、数据库连接池类 DBConnectionPool,提供如下的方法：

　　　　1、从池中取得一个打开的连接；

　　　　2、将一个连接返回池中；

　　　　3、在关闭时释放所有的资源，并关闭所有的连接。

　　　　另外，DBConnectionPool还处理连接失败，比如超时，通讯失败等错误，并且根据预定义的参数限制池中的连接数。

　　　　二、管理者类，DBConnetionManager，是一个容器将连接池封装在内，并管理所有的连接池。它的方法有：

　　　　1、调用和注册所有的jdbc驱动程序；

　　　　2、根据参数表创建DBConnectionPool对象；

　　　　3、映射连接池的名字和DBConnectionPool实例；

　　　　4、当所有的连接客户退出后，关闭全部连接池。

　　　　这些类的实现，以及如何在servlet中使用连接池的应用在随后的文章中讲解

　　　　DBConnectionPool类代表一个由url标识的数据库连接池。前面，我们已经提到，jdbc的url由三个部分组成：协议标识（总是jdbc）,子协议标识（例如，odbc.oracle）,和数据库标识（跟特定的数据库有关）。连接池也具有一个名字，供客户程序引用。另外，连接池还有一个用户名，一个密码和一个最大允许连接数。如果web应用允许所有的用户使用某些数据库操作，而另一些操作是有限制的，则可以创建两个连接池，具有同样的url,不同的user name和password，分别处理两类不同的操作权限。现把DBConnectionPool详细介绍如下：

　　　　三、DBConnectionPool的构造

　　　　构造函数取得上述的所有参数：

　　public DBConnectionPool(String name, String URL, String user,

　　String password, int maxConn) {

　　　this.name = name;

　　　this.URL = URL;

　　　this.user = user;

　　　this.password = password;

　　　this.maxConn = maxConn;

　　}

　　　　将所有的参数保存在实例变量中。

　　　　四、从池中打开一个连接

　　　　DBConnectionPool提供两种方法来检查连接。两种方法都返回一个可用的连接，如果没有多余的连接，则创建一个新的连接。如果最大连接数已经达到，第一个方法返回null，第二个方法则等待一个连接被其他进程释放。

　　public synchronized Connection getConnection() {

　　　Connection con =>http://www.knowsky.com

　　　　con = (Connection) freeConnections.firstElement();

　　　　freeConnections.removeElementAt(0);

　　　　try {

　　　　　if (con.isClosed()) {

　　　　　　log("Removed bad connection from " + name);

　　　　　　// Try again recursively

　　　　　　con = getConnection();

　　　　　}

　　　　}

　　　　catch (SQLException e) {

　　　　　log("Removed bad connection from " + name);

　　　　　// Try again recursively

　　　　　con = getConnection();

　　　　}

　　　}

　　　else if (maxConn == 0 || checkedOut < maxConn) {

　　　　con = newConnection();

　　　}

　　　if (con != null) {

　　　　checkedOut++;

　　　}

　　　return con;

　　}

　　　　所有空闲的连接对象保存在一个叫freeConnections 的Vector中。如果存在至少一个空闲的连接，getConnection()返回其中第一个连接。下面，将会看到，进程释放的连接返回到freeConnections的末尾。这样，最大限度地避免了数据库因一个连接不活动而意外将其关闭的风险。

　　　　再返回客户之前，isClosed()检查连接是否有效。如果连接被关闭了，或者一个错误发生，该方法递归调用取得另一个连接。

　　　　如果没有可用的连接，该方法检查是否最大连接数被设置为0表示无限连接数，或者达到了最大连接数。如果可以创建新的连接，则创建一个新的连接。否则，返回null。

　　　　方法newConnection()用来创建一个新的连接。这是一个私有方法，基于用户名和密码来确定是否可以创建新的连接。

　　private Connection newConnection() {

　　　Connection con = null;

　　　try {

　　　　if (user == null) {

　　　　 con = DriverManager.getConnection(URL);

　　　　}

　　　　else {

　　　　　con = DriverManager.getConnection(URL, user, password);

　　　　}

　　　　log("Created a new connection in pool " + name);

　　　}

　　　catch (SQLException e) {

　　　　log(e, "Can not create a new connection for " + URL);

　　　　return null;

　　　}

　　　return con;

　　}

　　　　jdbc的DriverManager提供一系列的getConnection（）方法，可以使用url和用户名，密码等参数创建一个连接。

　　　　第二个getConnection()方法带有一个超时参数 timeout,当该参数指定的毫秒数表示客户愿意为一个连接等待的时间。这个方法调用前一个方法。

　　public synchronized Connection getConnection(long timeout) {

　　　long startTime = new Date().getTime();

　　　Connection con;

　　　while ((con = getConnection()) == null) {

　　　　try {

　　　　　wait(timeout);

　　　　}

　　　　catch (InterruptedException e) {}

　　　　if ((new Date().getTime() - startTime) >= timeout) {

　　　　　// Timeout has expired

　　　　　return null;

　　　　}

　　　}

　　　return con;

　　}

　　　　局部变量startTime初始化当前的时间。一个while循环首先尝试获得一个连接，如果失败，wait()函数被调用来等待需要的时间。后面会看到，Wait()函数会在另一个进程调用notify()或者notifyAll()时返回，或者等到时间流逝完毕。为了确定wait()是因为何种原因返回，我们用开始时间减去当前时间，检查是否大于timeout。如果结果大于timeout,返回null,否则，在此调用getConnection()函数。

　　　　五、将一个连接返回池中

　　　　DBConnectionPool类中有一个freeConnection方法以返回的连接作为参数，将连接返回连接池。

　　public synchronized void freeConnection(Connection con) {

　　　// Put the connection at the end of the Vector

　　　freeConnections.addElement(con);

　　　checkedOut--;

　　　notifyAll();

　　}

　　　　连接被加在freeConnections向量的最后，占用的连接数减1，调用notifyAll()函数通知其他等待的客户现在有了一个连接。

　　　　六、关闭

　　　　大多数servlet引擎提供完整的关闭方法。数据库连接池需要得到通知以正确地关闭所有的连接。DBConnectionManager负责协调关闭事件，但连接由各个连接池自己负责关闭。方法relase()由DBConnectionManager调用。

　　public synchronized void release() {

　　　Enumeration allConnections = freeConnections.elements();

　　　while (allConnections.hasMoreElements()) {

　　　　Connection con = (Connection) allConnections.nextElement();

　　　　try {

　　　　　con.close();

　　　　　log("Closed connection for pool " + name);

　　　　}

　　　　catch (SQLException e) {

　　　　　log(e, "Can not close connection for pool " + name);

　　　　}

　　　}

　　　freeConnections.removeAllElements();

　　}

　　　　本方法遍历freeConnections向量以关闭所有的连接。

　　　　DBConnetionManager的构造函数是私有函数，以避免其他类创建其实例。

　　private DBConnectionManager() {

　　init();

　　}

　　　　DBConnetionManager的客户调用getInstance()方法来得到该类的单一实例的引用。

　　static synchronized public DBConnectionManager getInstance() {

　　if (instance == null) {

　　　instance = new DBConnectionManager();

　　}

　　clients++;

　　return instance;

　　}

（编辑：聊城站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!