使用dbutils获取tomcat数据库连接池

saundy

使用dbutils获取tomcat数据库连接池

j2se 2009-06-26 23:51:50 阅读225 评论1
字号：大中小



1、首先要将mysql的驱动包放在tomcat/lib目录下

2、在myeclipse工程目录下的webroot/META-INF下新建一个context.xml文件，内容如下：

<Context>

<!--这里是mysql的连接池设置-->
   <Resource
    name="jdbc/mysqlds"
    auth="Container"
    type="javax.sql.DataSource"
    driverClassName="com.mysql.jdbc.Driver"
    url="jdbc:mysql://127.0.0.1/blog"
    username="root"
    password="root"
    maxActive="100"
    maxIdle="30"
    maxWait="10000" />   

<!--这里是oracle的连接池设置-->

<Resource name="jdbc/oracleds"
   auth="Container"
   type="javax.sql.DataSource"
   maxActive="100"
   maxIdle="30"
   maxWait="10000"
   username="scott"
   password="tiger"
    driverClassName="oracle.jdbc.driver.OracleDriver"
   url="jdbc:oracle:thin:@127.0.0.1:1521:orcl"/>
   </Context>

3、在需要用连接池的地方使用如下：

mysql下使用连接池：   

Context ctx = new InitialContext();
   DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/mysqlds");
   Connection conn = ds.getConnection();

oracle下使用连接池：   

Context ctx = new InitialContext();
   DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/oracleds");
   Connection conn = ds.getConnection();



dbutils是一个开源的对JDBC进行封装的组件，简化了对JDBC的操作。

首先当然是到官方网站上把源码下载下来，http://commons.apache.org/dbutils/

然后解压后，把commons-dbutils.jar放在工程名称/WebRoot/WEB-INF/lib目录下，就可直接使用了。

以下是使用dbutils获取QueryRnner的代码DbHelper.java：

package com.xie.dbutils;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

import org.apache.commons.dbutils.QueryRunner;

public class DbHelper {
public static QueryRunner getQueryRunner() {
  DataSource ds = null;
  try {
   Context context = new InitialContext();
   ds = (DataSource) context.lookup("java:/comp/env/jdbc/oracleds");
   //System.out.println("oracle连接池成功");
  } catch (Exception e) {
   System.out.println("oracle连接池失败");
  }
QueryRunner qr = new QueryRunner(ds);
  return qr;
}
}
查询就直接使用QueryRunner里的query();方法就可以了，其它的增删改就直接用QueryRunner里的update();方法就行了。

如下是查询的示例：

String sql = "select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
   QueryRunner qr = DbHelper.getQueryRunner();
   List list = (List) qr.query(sql, new BeanListHandler(Emp.class));

如下是删除的示例：

String id = request.getParameter("id");
  String sql = "delete from comment where id=" + id;
  QueryRunner qr = DbHelper.getQueryRunner();
   qr.update(sql);

如下是修改的示例：

String id = request.getParameter("id");
  String username = request.getParameter("name");
  String content = request.getParameter("content");
  String sql = "update comment set username=?,content=? where id=?";
  String params[] = { username, content, id };
  QueryRunner qr = DbHelper.getQueryRunner();
   qr.update(sql, params);

如下是增加的示例

String name = request.getParameter("name");
  String content = request.getParameter("content");
  String blog_id = request.getParameter("blog_id");

  if (name == null || name.equals("")) {
   name = "匿名";
  }

  String sql = "insert into comment (username,content,blog_id,createdtime) values (?,?,?,now())";
  String params[] = { name, content, blog_id };

  QueryRunner qr = DbHelper.getQueryRunner();
   qr.update(sql, params);