`
minghe_zy
  • 浏览: 123607 次
  • 性别: Icon_minigender_1
  • 来自: 北京
文章分类
社区版块
存档分类
最新评论

C3P0 JDBC连接池

 
阅读更多

文章来源：http://heisetoufa.iteye.com/blog/227790

 

C3P0是一个开放源代码的JDBC连接池，它在lib目录中与Hibernate一起发布,包括了实现jdbc3和jdbc2扩展规范说明的Connection 和Statement 池的DataSources 对象。

C3P0配置：

首先肯定是要下载个包的

c3p0-0.9.1-pre11.bin.zip

解压后把bin下的c3p0-0.9.1-pre11.jar包拷贝到项目下的lib里

接下来新建个连接文件

Java代码 复制代码 收藏代码
  1. package dbc;   
  2.   
  3. import java.beans.PropertyVetoException;   
  4. import java.sql.Connection;   
  5. import java.sql.SQLException;   
  6. import com.mchange.v2.c3p0.ComboPooledDataSource;   
  7.   
  8. public class ConnectionFactory {   
  9.   
  10.     private ConnectionFactory(){   
  11.     }       
  12.   
  13.     private static ComboPooledDataSource ds = null;   
  14.   
  15.     static {   
  16.         try {   
  17.             // Logger log = Logger.getLogger("com.mchange"); // 日志   
  18.               // log.setLevel(Level.WARNING);   
  19.             ds = new ComboPooledDataSource();   
  20.             // 设置JDBC的Driver类   
  21.               ds.setDriverClass("oracle.jdbc.driver.OracleDriver");  // 参数由 Config 类根据配置文件读取   
  22.               // 设置JDBC的URL   
  23.             ds.setJdbcUrl("jdbc:oracle:thin:@192.168.1.134:1521:zhpt");   
  24.             // 设置数据库的登录用户名   
  25.               ds.setUser("scott");   
  26.             // 设置数据库的登录用户密码   
  27.               ds.setPassword("tiger");   
  28.             // 设置连接池的最大连接数   
  29.               ds.setMaxPoolSize(200);   
  30.             // 设置连接池的最小连接数   
  31.               ds.setMinPoolSize(20);   
  32.         } catch (PropertyVetoException e) {   
  33.             e.printStackTrace();   
  34.         }   
  35.     }   
  36.      
  37.     public static synchronized Connection getConnection() {   
  38.         Connection con = null;   
  39.         try {   
  40.             con = ds.getConnection();   
  41.         } catch (SQLException e1) {   
  42.             e1.printStackTrace();   
  43.         }   
  44.         return con;   
  45.     }   
  46.     // C3P0 end   
  47. }  
package dbc;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class ConnectionFactory {

    private ConnectionFactory(){
    }    

    private static ComboPooledDataSource ds = null;

    static {
        try {
            // Logger log = Logger.getLogger("com.mchange"); // 日志
              // log.setLevel(Level.WARNING);
            ds = new ComboPooledDataSource();
            // 设置JDBC的Driver类
              ds.setDriverClass("oracle.jdbc.driver.OracleDriver");  // 参数由 Config 类根据配置文件读取
              // 设置JDBC的URL
            ds.setJdbcUrl("jdbc:oracle:thin:@192.168.1.134:1521:zhpt");
            // 设置数据库的登录用户名
              ds.setUser("scott");
            // 设置数据库的登录用户密码
              ds.setPassword("tiger");
            // 设置连接池的最大连接数
              ds.setMaxPoolSize(200);
            // 设置连接池的最小连接数
              ds.setMinPoolSize(20);
        } catch (PropertyVetoException e) {
            e.printStackTrace();
        }
    }
  
    public static synchronized Connection getConnection() {
        Connection con = null;
        try {
            con = ds.getConnection();
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        return con;
    }
    // C3P0 end
}

 再建个文件用来测试

Java代码 复制代码 收藏代码
  1. package dbc;   
  2.   
  3. import java.sql.Connection;   
  4. import java.sql.PreparedStatement;   
  5. import java.sql.ResultSet;   
  6. import java.sql.SQLException;   
  7.   
  8. public class dbctest {   
  9.   public static void main(String[] args) {   
  10.   boolean flag = false;   
  11.   // 在此处成具体的数据库验证   
  12.   
  13.   // 声明一个数据库操作对象   
  14.   PreparedStatement pstmt = null;   
  15.   // 声明一个结果集对象   
  16.   ResultSet rs = null;   
  17.   // 声明一个SQL变量，用于保存SQL语句   
  18.   String sql = null;   
  19.   // DataBaseConnection为具体的数据库连接及关闭操作类   
  20.   Connection con = null;   
  21.   // 连接数据库   
  22.   con = ConnectionFactory.getConnection();   
  23.   
  24.   // 编写SQL语句   
  25.   sql = "SELECT u_name,u_password FROM nwvideo.n_user WHERE u_name=? and u_password=?";   
  26.   try {   
  27.    // 实例化数据库操作对象   
  28.    pstmt = con.prepareStatement(sql);   
  29.   
  30.    System.out.println("操作对象已被实例化");   
  31.   
  32.    // 设置pstmt的内容，是按ID和密码验证   
  33.    pstmt.setString(1, "limeng");   
  34.    pstmt.setString(2, "limeng");   
  35.   
  36.    System.out.println("获得username,password");   
  37.   
  38.    // 查询记录   
  39.    rs = pstmt.executeQuery();   
  40.    System.out.println("执行查询完毕");   
  41.    // 判断是否有记录   
  42.    if (rs.next()) {   
  43.     // 如果有记录，则执行此段代码   
  44.     // 用户是合法的，可以登陆   
  45.     flag = true;   
  46.   
  47.     System.out.println("用户合法");   
  48.    }   
  49.    // 依次关闭   
  50.   
  51.    rs.close();   
  52.    pstmt.close();   
  53.   
  54.   } catch (Exception e) {   
  55.    System.out.println(e);   
  56.   } finally {   
  57.    // 最后一定要保证数据库已被关闭   
  58.    try {   
  59.     con.close();   
  60.    } catch (SQLException e) {   
  61.     // TODO Auto-generated catch block   
  62.     e.printStackTrace();   
  63.    }   
  64.   }   
  65.  }   
  66. }  
package dbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class dbctest {
  public static void main(String[] args) {
  boolean flag = false;
  // 在此处成具体的数据库验证

  // 声明一个数据库操作对象
  PreparedStatement pstmt = null;
  // 声明一个结果集对象
  ResultSet rs = null;
  // 声明一个SQL变量，用于保存SQL语句
  String sql = null;
  // DataBaseConnection为具体的数据库连接及关闭操作类
  Connection con = null;
  // 连接数据库
  con = ConnectionFactory.getConnection();

  // 编写SQL语句
  sql = "SELECT u_name,u_password FROM nwvideo.n_user WHERE u_name=? and u_password=?";
  try {
   // 实例化数据库操作对象
   pstmt = con.prepareStatement(sql);

   System.out.println("操作对象已被实例化");

   // 设置pstmt的内容，是按ID和密码验证
   pstmt.setString(1, "limeng");
   pstmt.setString(2, "limeng");

   System.out.println("获得username,password");

   // 查询记录
   rs = pstmt.executeQuery();
   System.out.println("执行查询完毕");
   // 判断是否有记录
   if (rs.next()) {
    // 如果有记录，则执行此段代码
    // 用户是合法的，可以登陆
    flag = true;

    System.out.println("用户合法");
   }
   // 依次关闭

   rs.close();
   pstmt.close();

  } catch (Exception e) {
   System.out.println(e);
  } finally {
   // 最后一定要保证数据库已被关闭
   try {
    con.close();
   } catch (SQLException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
 }
}

 这样就这个C3P0,开源java连接池就配置成功了

 

使用代码里的主要代码就是这句

con = ConnectionFactory.getConnection();

用完记得关闭

分享到：
| SpringMVC+JDBC:分页示例
评论
1 楼 IT_LDB 2014-07-24  
     完美地解决了我一个问题. 3q.
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics