热门关键字:  ubuntu  分区  Fedora  linux系统进程  函数

JDBC数据源和连接池

来源: 作者: 时间:2008-03-17 Tag: 点击:

    ,  建立数据库连接的两种方式:

    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,<Context>元素的内容中使用<Resource>元素配置JDBC数据源

 

    ,  使用JDBC数据源连接数据库

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

                                     ch08.xml

 

<Context reloadable="true">

    <Resource name="jdbc/bookstore" auth="Container" type="javax.sql.DataSource"

           maxActive="50" maxIdle="30" maxWait="10000"

           username="pl" password="123"

           driverClassName="com.mysql.jdbc.Driver"

           url="jdbc:mysql://localhost:3306/bookstore?autoReconnect=true" />

</Context>

 

 

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("<html><head>");

           out.println("<title>数据库表的信息</title>");

           out.println("</head><body>");

          

           //调用请求对象的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("<form action=\"getdbinfo\" method=\"get\">");

             

              //表单中有一个列表框

              out.println("<select size=1 name=tableName>");

              while(rs.next())

              {

                  //调用getString("TABLE_NAME")得到表的名字

                  out.println("<option value="+rs.getString("TABLE_NAME")+">");

                  out.println(rs.getString("TABLE_NAME"));

                  out.println("</option>");

              }

              out.println("</select><p>");

             

              out.println("<input type=\"submit\" value=\"提交\">");

              out.println("</form>");

           }

          

           //如果用户提交了表名参数,则执行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("<table border=1>");

              out.println("<caption>表的结构</caption>");

              out.println("<tr><td>字段名</td><td>字段类型</td><td>最大字符宽度</td></tr>");

             

              //构造一个ArrayList集合对象,用于存储表中字段的名字

              ArrayList<String> al = new ArrayList<String>();

             

              for(int i=1; i<=columnCount; i++)

              {

                  out.println("<tr>");

                 

                  //调用ResultSetMetaData对象的getColumnName()方法得到列的名字,"字段名"

                  String columnName = rsMeta.getColumnName(i);

                 

                  out.println("<td>"+columnName+"</td>");

                 

                  //将列的名字保存到ArrayList集合中

                  al.add(columnName);

                 

                  /*

                   *调用ResultSetMetaData对象的getColumnTypeName()方法得到列的

                   *数据库特定的类型名("字段类型") 和 列的最大字符宽度("最大字符宽度")

                   */

                  out.println("<td>"+rsMeta.getColumnTypeName(i)+"</td>");

                  out.println("<td>"+rsMeta.getColumnDisplaySize(i)+"</td>");

              }

             

              out.println("</table><p>");

             

              //以表格形式输出表中的数据

              out.println("<table border=1>");

              out.println("<caption>表中的数据</caption>");

              out.println("<tr>");

             

              //通过for循环取出存储在ArrayList集合中的列名,作为表格的表头

              for(int i=0; i<columnCount; i++)

              {

                  out.println("<th>"+al.get(i)+"</th>");

              }

             

              while(rs.next())

              {

                  out.println("<tr>");

                  for(int i=1; i<=columnCount; i++)

                  {

                     //一律采用getString()方法得到String类型的数据

                     out.println("<td>"+rs.getString(i)+"</td>");

                  }

                  out.println("</tr>");

              }

              out.println("</table>");

           }

           out.println("</body></html>");

           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;

           }

       }

    }

}

 

 




相关文章:
SQLite3 C/C++ 开发接口简介(API函数) 二
SQLite3 使用教学
Scaling out MySQL - Hardware today and tomorro
SQLite适用的范围
sybase cursor declare
SQL语句大全精要
用户配额
decode函数
Oracle 数据库创建表空间、创建用户指定表空间
MySQL教会我使用GnuPG验证软件包
MySQL中MyISAM引擎与InnoDB引擎性能简单测试
initdb
mysqladmin在线帮助文档
CentOS 4.7 安装Oracle 9.2.0.4的一些问题
文本如何导入oracle(sqlldr 的用法)
ORA-00600: 内部错误代码,自变量: [16201], [],
分布式Oracle的database link
install a MySQL source distribution
Mysql备份脚本(未验证)
oracle 9.2.0.1 update 9.2.0.5
每小时Dump所有mysql数据库到NAS存储设备上
Oracle SCN机制解析
Account LOCKED(TIMED)
MySQL数据库5.0的my.cnf配置选项
oracle存储过程中调用其他用户的表
修改sqlplus提示符
MYSQL建表实例
一些对Mysql DBA有用的脚本
Oracle DBA 强悍挑战OS 64位 Solaris 10-真正休
[Bugzilla]由Mysql迁移到Oracle的方法