數據庫連接JDBC和數據庫連接池C3P0自定義的java封裝類

使用以下的包裝類都需要自己有JDBC的驅動jar包：

如 mysql-connector-java-5.1.26-bin.jar（5.1.26代表的是版本序列號）

 

一、JDBC的封裝：（java連接MySQL）

import java.sql.*;

import utils.GlobalConstant;

public class JDBCUtil {

    private JDBCUtil() {

    }

    /**
     * 獲取JDBC的數據庫連接
     */
    public static Connection getConnection() {
        Connection conn = null;
        try {
            Class.forName(GlobalConstant.CONNECTION_DRIVER);
            conn = DriverManager.getConnection(GlobalConstant.CONNECTION_URL, GlobalConstant.CONNECTION_USER,
                    GlobalConstant.CONNECTION_PASSWORD);
        } catch (Exception e) {
            e.printStackTrace();
        }
        /*
         * try { conn = DataSourceService.getConnection(); } catch (SQLException
         * e) { e.printStackTrace(); }
         */
        return conn;
    }

    private static void close(ResultSet rs, Statement sm, Connection conn) {
        try {
            if (rs != null)
                rs.close();
            if (sm != null)
                sm.close();
            if (conn != null)
                conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 關閉數據庫的結果集
     * 
     * @param rs
     *            需要關閉的結果集
     */
    public static void close(ResultSet rs) {
        try {
            if (rs != null)
                rs.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 將一個標准的sql查詢語句在數據庫中查詢,並且返回一個對應的結果集。
     * 
     * @param sql
     *            標准的sql查詢語句
     */
    public static ResultSet doQuery(String sql) {
        Connection conn = getConnection();
        if (conn == null)
            return null;
        Statement sm = null;
        ResultSet rs = null;
        try {
            sm = conn.createStatement();
            rs = sm.executeQuery(sql);
            return rs;
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (rs == null && sm != null) {
                close(null, sm, conn);
            }
            // close(null, sm, conn);這句肯定不行
        }
        return rs;
    }

    /**
     * 將一個更新語句和對應的參數進行查詢,並返回一個整形結果
     * 
     * @param sql
     *            數據庫中的更新語句
     * @param paras
     *            sql中對應的參數
     */
    public static int doUpdate(String sql, String[] paras) {
        Connection conn = getConnection();
        if (conn == null)
            return 0;
        PreparedStatement psm = null;
        int result = 0;
        try {
            psm = conn.prepareStatement(sql);
            for (int i = 0; i < paras.length; i++) {
                psm.setString(i + 1, paras[i]);
            }
            result = psm.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            close(null, psm, conn);
        }
        return result;
    }
}

以下的C3P0的數據庫連接池除了需要以上的JDBC的驅動包，還需以下jar包：

如 c3p0-0.9.1.2.jar (0.9.1.2代表的是版本序列號)

為了方便使用，可以用其他的jar包進行輔助封裝（dbUtils的jar）

如 commons-dbutils-1.3.jar （1.3代表的是版本序列號）

二、C3P0數據庫連接池的封裝：（java連接MySQL）

----------------不需要xml的配置文件

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

import utils.GlobalConstant;

public class DataSourceUtils {
    private static DataSource ds;

    static {
        /*
         * 從配置文件讀取配置信息 <?xml version="1.0" encoding="UTF-8"?> <c3p0-config> <!--
         * 默認配置，如果沒有指定則使用這個配置 --> <default-config> <property
         * name="checkoutTimeout">30000</property> <property
         * name="idleConnectionTestPeriod">30</property> <property
         * name="initialPoolSize">3</property> <property
         * name="maxIdleTime">30</property> <property
         * name="maxPoolSize">10</property> <property
         * name="minPoolSize">3</property> <property
         * name="maxStatements">50</property> <property
         * name="acquireIncrement">3</property><!-- 如果池中數據連接不夠時一次增長多少個 -->
         * <property name="driverClass">com.mysql.jdbc.Driver</property>
         * <property name="jdbcUrl">
         * <![CDATA[jdbc:mysql://127.0.0.1:3306/project?useUnicode=true&
         * characterEncoding=UTF-8]]> </property> <property
         * name="user">root</property> <property
         * name="password">789123</property> </default-config> </c3p0-config>
         * 
         * ds = // 默認的讀取c3p0-config.xml中默認配置 new ComboPooledDataSource();
         */
        ComboPooledDataSource cpds = null;
        try {
            cpds = new ComboPooledDataSource();
            cpds.setCheckoutTimeout(30000);
            cpds.setIdleConnectionTestPeriod(30);
            cpds.setInitialPoolSize(3);
            cpds.setMaxIdleTime(30);
            cpds.setMaxPoolSize(70);
            cpds.setMaxStatementsPerConnection(100);
            cpds.setMinPoolSize(3);
            cpds.setMaxStatements(75);
            cpds.setAcquireIncrement(3);
            cpds.setDriverClass(GlobalConstant.CONNECTION_DRIVER);
            cpds.setJdbcUrl(GlobalConstant.CONNECTION_URL);
            cpds.setUser(GlobalConstant.CONNECTION_USER);
            cpds.setPassword(GlobalConstant.CONNECTION_PASSWORD);
            ds = cpds;
        } catch (PropertyVetoException e) {
            System.out.println("與MySQL數據庫連接失敗！");
        }
    }

    private DataSourceUtils() {

    }

    public static DataSource getDatasSource() {
        return ds;
    }

    public static Connection getConnection() {
        Connection con = null;
        try {
            con = ds.getConnection();// 每一次從ds中獲取一個新的連接
        } catch (Exception e) {
            e.printStackTrace();
        }
        return con;
    }
}

 

如果要驗證其可用性，你們可以修改下以上的用戶名，密碼，數據庫名

之后在自己的MySQL建立自己相應的數據庫即可測試。