zoukankan      html  css  js  c++  java
  • 连接池c3p0

    连接池c3p0

    C3P0:hibernate和spring使用,有自动回收空闲连接的功能.

    使用步骤:
      1.导入jar包(c3p0-0.9.1.2.jar)
      2.使用api


    a.硬编码(不推荐)
      new ComboPooledDataSource()

    步骤:

      1.创建一个DataSourse项目

      2.新建一个包com.c3p0.hjh

      3.编写一个类C3p0Test01.java

      4.导包,lib下放入c3p0-0.9.2.1.jar和mchange-commons-java-0.2.3.4.jar;导完jar记得buildpath一下

     代码执行前数据库数据:

     代码执行后数据库数据:

     JDBCUtil.java工具类源码:

    package com.util.hjh;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class JDBCUtil {
        final static String driver = "com.mysql.jdbc.Driver";
        final static String url = "jdbc:mysql://localhost/hejh?useUnicode=true&characterEncoding=UTF-8";
        final static String user  = "root";
        final static String password = "root";
        
        Connection conn = null;
        PreparedStatement ps = null;
        Statement st = null;
        ResultSet rs = null;
            
        /**获取连接*/
        public static Connection getConnection() throws SQLException  {
            Connection    conn = null;
            try {
                //注册驱动
                Class.forName(driver);
                //获取连接
                conn = DriverManager.getConnection(url, user, password);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }                    
            return conn;    
        }
        
        /**关闭资源closeResourse(conn,st)*/
        public static void closeResourse(Connection conn,Statement st) {
            try {
                if(st!=null) {
                    st.close();
                }else {
                    st = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if(conn!=null) {
                    conn.close();
                }else {
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        /**关闭资源closeResourse(conn,ps)*/
        public static void closeResourse(Connection conn,PreparedStatement ps) {
            try {
                if(ps!=null) {
                    ps.close();
                }else {
                    ps = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if(conn!=null) {
                    conn.close();
                }else {
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        /**关闭资源closeResourse(rs)*/
        public static void closeResourse(ResultSet rs) {
            try {
                if(rs!=null) {
                    rs.close();
                }else {
                    rs = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

     C3p0Test01.java源码:

    package com.c3p0.hjh;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import org.junit.Test;
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    import com.util.hjh.JDBCUtil;
    
    /*
     * a.硬编码(不推荐)
            new ComboPooledDataSource()
     * */
    public class C3p0Test01 {
        @Test
        public void test() throws Exception {
            //建立连接池
            ComboPooledDataSource ds = new ComboPooledDataSource();
            
            //设置基本参数
            ds.setDriverClass("com.mysql.jdbc.Driver");
            ds.setJdbcUrl("jdbc:mysql://localhost/jdbc");
            ds.setUser("root");
            ds.setPassword("root");
            
            //操作数据库数据
            Connection conn = ds.getConnection();
            String sql = "update student set id =? where id=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setInt(1, 06);
            ps.setInt(2, 10);
            int i = ps.executeUpdate();
            System.out.println("更新了"+i+"行数据");
            
            //关闭资源
            JDBCUtil.closeResourse(conn, ps);     
        }   
    }


    b.配置文件
      配置文件的名称:c3p0.properties 或者 c3p0-config.xml
      配置文件的路径:src下

      编码只需要一句话
      new ComboPooledDataSource()//使用默认的配置
      new ComboPooledDataSource(String configName)//使用命名的配置 若配置的名字找不到,使用默认的配置

    步骤:

      1.创建一个DataSourse项目

      2.新建一个包com.c3p0.hjh

      3.编写一个类C3p0Test2.java

      4.导包,lib下放入c3p0-0.9.2.1.jar和mchange-commons-java-0.2.3.4.jar;导完jar记得buildpath一下

      5.编写配置文件c3p0.properties

     c3p0.properties文件内容:

    c3p0.driverClass=com.mysql.jdbc.Driver
    c3p0.jdbcUrl=jdbc:mysql://localhost/jdbc
    c3p0.user=root
    c3p0.password=root

     代码运行前数据库数据显示如下:

     代码运行后数据库数据显示如下:

      JDBCUtil.java工具类源码同上,略

    C3p0Test2.java源码如下:

    package com.c3p0.hjh;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import org.junit.Test;
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    import com.util.hjh.JDBCUtil;
    
    public class C3p0Test2 {
        @Test
        public void test() throws Exception {
            //建立连接池
            ComboPooledDataSource ds = new ComboPooledDataSource();
            
            //操作数据库数据
            Connection conn = ds.getConnection();
            String sql = "update student set name =? where id=?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1,"haha");
            ps.setInt(2, 3);
            int i = ps.executeUpdate();
            System.out.println("更新了"+i+"行数据");
            
            //关闭资源
            JDBCUtil.closeResourse(conn, ps);
        }
    }

     使用c3p0-config.xml配置文件

     代码执行之前的数据库数据:

     代码执行之后数据库中的数据:

     

    c3p0-config.xml配置文件内容:

    <c3p0-config>
        <!-- 默认配置,如果没有指定则使用这个配置 -->
        <default-config>
            <!-- 基本配置 -->
            <property name="driverClass">com.mysql.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://localhost/jdbc</property>
            <property name="user">root</property>
            <property name="password">root</property>
        
            <!--扩展配置-->
            <property name="checkoutTimeout">30000</property>
            <property name="idleConnectionTestPeriod">30</property>
            <property name="initialPoolSize">10</property>
            <property name="maxIdleTime">30</property>
            <property name="maxPoolSize">100</property>
            <property name="minPoolSize">10</property>
            <property name="maxStatements">200</property>
        </default-config> 
        
        
        <!-- 命名的配置 -->
        <named-config name="XXX">
            <property name="driverClass">com.mysql.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/xxxx</property>
            <property name="user">root</property>
            <property name="password">1234</property>
            
            
            <!-- 如果池中数据连接不够时一次增长多少个 -->
            <property name="acquireIncrement">5</property>
            <property name="initialPoolSize">20</property>
            <property name="minPoolSize">10</property>
            <property name="maxPoolSize">40</property>
            <property name="maxStatements">20</property>
            <property name="maxStatementsPerConnection">5</property>
        </named-config>
    </c3p0-config> 

     C3p0Test03.java源码:

    package com.c3p0.hjh;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import org.junit.Test;
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    import com.util.hjh.JDBCUtil;
    
    public class C3p0Test03 {
        @Test
        public void test() throws Exception {
            //建立连接池
            ComboPooledDataSource ds = new ComboPooledDataSource();
            
            //操作数据库数据
            Connection conn = ds.getConnection();
            String sql = "insert into student values(?,?,?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setInt(1, 22);
            ps.setString(2,"erya");
            ps.setInt(3, 103);
            int i = ps.executeUpdate();
            System.out.println("插入了"+i+"行数据");
            
            //关闭资源
            JDBCUtil.closeResourse(conn, ps);
        }   
    }
  • 相关阅读:
    spring获取webapplicationcontext,applicationcontext几种方法详解
    Spring工具类:WebApplicationContextUtils
    eclipse maven tomcat7 热部署
    检验深度优先和广度优先的程序(邻接矩阵存储结构)
    无向图的邻接多重表存储结构
    有向图的十字链表存储结构
    图的邻接表存储结构
    图的数组(邻接矩阵)存储结构
    最优二叉树(赫夫曼树、赫夫曼树和赫夫曼编码的存储结构)
    树的存储结构(树的二叉链表(孩子—兄弟))
  • 原文地址:https://www.cnblogs.com/hejh/p/10870100.html
Copyright © 2011-2022 走看看