JDBC数据源和连接池

仙尘

   
    一,  建立数据库连接的两种方式:
    1,  首先调用Class.forName()方法加载数据库驱动,然后调用DriverManager.getConnection()方法建立连接.
    2,  在javax.sql包中,定义了DataSource接口,提供了另一种建立数据库连接的方式.在程序中,通过向一个JNDI(Java Naming and  Directory Interface)服务器查询,即调用Context接口的lookup()方法,来得到DataSource对象,然后调用DataSource对象的getConnection()方法建立连接

    二,  为了能重复利用数据库连接对象,提高对请求的响应时间和服务器的性能,可以采用连接池技术.连接池技术预先建立多个数据库连接对象,然后将连接对象保存到连接池中,当客户请求到来时,从池中取出一个连接对象为客户服务,当请求完成时,客户程序调用close()方法,将连接对象放回池中.
   
    三,  在第1中方式中,客户程序得到的连接对象是物理连接,调用连接对象的close()方法将关闭连接,而采用连接池技术,客户程序得到的连接对象是连接池中物理连接的一个句柄,调用连接对象的close()方法,物理连接并没有关闭,数据源的实现只是删除了客户程序中的连接对象和池中的连接对象之间的联系.
   
    四,  在Tomcat中,在元素的内容中使用元素配置JDBC数据源

    五,  使用JDBC数据源连接数据库
    1, 配置JDBC数据源,编辑%CATALINA_HOME%\conf\server.xml文件或本WEB应用程序运行目录的配置文件%CATALINA_HOME%\conf\Catalina\localhost\ch08.xml
                                     ch08.xml

   
           maxActive="50" maxIdle="30" maxWait="10000"
           username="pl" password="123"
           driverClassName="com.mysql.jdbc.Driver"
           url="jdbc:mysql://localhost:3306/bookstore?autoReconnect=true" />


2, 编写GetDBinfoServlet2.java



package cn.apache.pl;

import java.io.*;
import java.sql.*;
import java.util.ArrayList;
import javax.servlet.*;
import javax.servlet.http.*;

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


public class GetDBInfoServlet2 extends HttpServlet
{
    private String url;
    private String user;
    private String password;
   
    public void doGet(HttpServletRequest req, HttpServletResponse resp)
       throws IOException, ServletException
    {
       Connection conn = null;
       Statement stmt = null;
       ResultSet rs = null;
      
       try
       {
           /*
            *通过向一个JNDI(Java Naming and  Directory Interface)服务器查询,即调用
            *Context接口的lookup()方法,来得到DataSource对象,然后调用DataSource对象的
            *getConnection()方法建立连接
            */
           Context ctx = new InitialContext();
         DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/bookstore");
         conn = ds.getConnection();
           
           
           resp.setContentType("text/html; charset=gb2312");
           PrintWriter out = resp.getWriter();
           out.println("");
           out.println("数据库表的信息");
           out.println("");
           
           //调用请求对象的getParameter()方法得到查询的表名
           String tableName = req.getParameter("tableName");
           
           //如果表名为空,则执行if块内的代码
           if(null == tableName || tableName.equals(""))
           {
              /*
               *调用连接对象的getMetaData()方法得到DatabaseMetaData对象
               *用于获取数据库的信息
               */
              DatabaseMetaData dbMeta = conn.getMetaData();
              
              /*
               *调用DatabaseMetaData对象的getTables()得到,传递"TABLE"参数
               *(代码中使用new String[]{"TABLE"})获取数据库中所有表的信息,
               *返回一个结果集对象
               *还可以传递"VIEW",获取数据库中视图的信息
               */
              rs = dbMeta.getTables(null, null, null, new String[]{"TABLE"});
              
              //输出一个表单
              out.println("");
              
              //表单中有一个列表框
              out.println("");
              while(rs.next())
              {
                  //调用getString("TABLE_NAME")得到表的名字
                  out.println("");
                  out.println(rs.getString("TABLE_NAME"));
                  out.println("");
              }
              out.println("");
              
              out.println("提交\">");
              out.println("");
           }
           
           //如果用户提交了表名参数,则执行else块
           else
           {
              stmt = conn.createStatement();
              
              //查询表中所有字段,返回结果集
              rs = stmt.executeQuery("select * from "+tableName);
              
              /*
               *调用ResultSet对象的getMetaData()方法ResultSetMetaData对象
               *用于获取描述数据表结构的元数据
               */
              ResultSetMetaData rsMeta = rs.getMetaData();
              
              //调用ResultSetMetaData对象的getColumnCount()方法得到结果集中列的总数
              int columnCount = rsMeta.getColumnCount();
              
              //以表格形式输出表的结构
              out.println("");
              out.println("表的结构");
              out.println("字段名字段类型最大字符宽度");
              
              //构造一个ArrayList集合对象,用于存储表中字段的名字
              ArrayList al = new ArrayList();
              
              for(int i=1; i
              {
                  out.println("");
                  
                  //调用ResultSetMetaData对象的getColumnName()方法得到列的名字,即"字段名"
                  String columnName = rsMeta.getColumnName(i);
                  
                  out.println(""+columnName+"");
                  
                  //将列的名字保存到ArrayList集合中
                  al.add(columnName);
                  
                  /*
                   *调用ResultSetMetaData对象的getColumnTypeName()方法得到列的
                   *数据库特定的类型名("字段类型") 和 列的最大字符宽度("最大字符宽度")
                   */
                  out.println(""+rsMeta.getColumnTypeName(i)+"");
                  out.println(""+rsMeta.getColumnDisplaySize(i)+"");
              }
              
              out.println("");
              
              //以表格形式输出表中的数据
              out.println("");
              out.println("表中的数据");
              out.println("");
              
              //通过for循环取出存储在ArrayList集合中的列名,作为表格的表头
              for(int i=0; i
              {
                  out.println(""+al.get(i)+"");
              }
              
              while(rs.next())
              {
                  out.println("");
                  for(int i=1; i
                  {
                     //一律采用getString()方法得到String类型的数据
                     out.println(""+rs.getString(i)+"");
                  }
                  out.println("");
              }
              out.println("");
           }
           out.println("");
           out.close();
       }catch(NamingException ne)
      {
         ne.printStackTrace();
      }catch(SQLException se)
       {
           se.printStackTrace();
       }finally
       {
           if(rs != null)
           {
              try
              {
                  rs.close();
              }catch(SQLException se)
              {
                  se.printStackTrace();
              }
              rs = null;           
           }
           if(stmt != null)
           {
              try
              {
                  stmt.close();
              }catch(SQLException se)
              {
                  se.printStackTrace();
              }
              stmt = null;
           }
           if(conn != null)
           {
              try
              {
                  conn.close();
              }catch(SQLException se)
              {
                  se.printStackTrace();
              }
              conn = null;
           }
       }
    }
}


3, 部署Servlet



    GetDBInfoServlet2
    cn.apache.pl.GetDBInfoServlet2

    GetDBInfoServlet2
    /getdbinfo2


4, 运行GetDBInfoServlet

启动Tomact服务器,在浏览器中打开: http://localhost:8080/ch08/getdbinfo2

选择account表后,点”提交”,打开
         表的结构
字段名
字段类型
最大字符宽度
userid
VARCHAR
20
balance
FLOAT
6

表中的数据
userid
balance
彭磊
500.00
徐璐
1000.50

再选”bookinfo”, 点”提交”,打开
           表的结构
字段名
字段类型
最大字符宽度
id
INTEGER
11
title
VARCHAR
100
author
VARCHAR
100
bookconcern
VARCHAR
200
publish_date
DATE
10
price
FLOAT
4
amount
SMALLINT
6
remark
VARCHAR
400

                                     表中的数据
id
title
author
bookconcern
publish_date
price
amount
remark
1
JAVA从入门到精通
孙卫琴
电子工业出版社
2004-06-01
34.00
35
null
2
JSP应用开发详解
刘小华
清华大学出版社
2005-10-03
56.00
20
null
3
MySQL数据库编程
孙鑫
人民邮电出版社
2006-06-29
78.00
10
null
4
JAVA 国际认证
SCJP
清华大学出版社
2005-02-03
46.00
55
null


                                                         
                                                            仙尘(584059034)于3月17日


本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u2/63095/showart_498032.html