JAVA数据库连接两大工具类DBCP和C3P0

清疚 2022-05-15 03:42 157阅读 0赞

### 两大常用的数据库连接工具类 ###

> 1、DBCP工具类  
> 2、C3P0工具类

#### jar包准备 ####

> 1、commons-dbcp-1.4.jar  
> 2、c3p0-0.9.1.2.jar  
> 3、mysql-connector-java-5.0.8-bin.jar  
> 4、commons-pool-1.5.6.jar

#### DBCPUtils ####

*  dbconfig.properties文件

#连接设置
    driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/java_test
    username=root
    password=root
    
    #
    initialSize=10
    #最大连接数量
    maxActive=50
    #
    maxIdle=20
    #
    minIdle=5
    #
    maxWait=60000
    
    #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
    #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
    connectionProperties=useUnicode=true;characterEncoding=utf8
    
    #指定由连接池所创建的连接的自动提交（auto-commit）状态。
    defaultAutoCommit=true
    
    #driver default 指定由连接池所创建的连接的只读（read-only）状态。
    #如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
    defaultReadOnly=
    
    #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
    #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
    defaultTransactionIsolation=REPEATABLE_READ

*  实现工具类

import java.io.IOException;
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import org.apache.commons.dbcp.BasicDataSourceFactory;
    
    public class DBCPUtils { 
        // 数据库连接池对象
        private static DataSource ds = null;
    
        static {
    
            Properties p = new Properties();
            try {
                p.load(DBCPUtils.class.getClassLoader().getResourceAsStream("dbconfig.properties"));
                try {
                    //DBCP实现类 
                    ds = BasicDataSourceFactory.createDataSource(p);
                } catch (Exception e) {
                    e.printStackTrace();
                }
    
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        // 获取数据库连接
        public static Connection getConnection() throws Exception {
            return ds.getConnection();
        }
        // 关闭资源
        public static void closeAll(ResultSet rs, Statement st, Connection conn) {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

#### C3P0Utils ####

*  准备c3p0-config.xml文件

<?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
      <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/java_test</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">30</property>
        <property name="maxPoolSize">100</property>
        <property name="minPoolSize">10</property>
      </default-config>
    </c3p0-config>

*  实现工具类

import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    import javax.sql.DataSource;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class C3P0Utils { 
    
        // C3P0连接池
        private static DataSource ds = new ComboPooledDataSource();
        // 获取连接
        public static Connection getConnection() throws Exception {
            return ds.getConnection();
        }
        // 关闭资源
        public static void closeAll(ResultSet rs, Statement st, Connection conn) {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if (st != null) {
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

##### 注意C3P0连接XML必须是c3p0-config.xml这个名字，是固定的。 #####

### 具体实现 ###

*  dao层实现

public User findUser(String username, String password) {
        User user = null;
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
    
        try {
            // 使用DBCP连接池
            // conn = DBCPUtils.getConnection();
            // 使用C3P0连接池
            conn = C3P0Utils.getConnection();
            ps = conn.prepareStatement("SELECT * FROM t_user WHERE username=? AND password=?");
    
            ps.setString(1, username);
            ps.setString(2, password);
    
            rs = ps.executeQuery();
    
            while (rs.next()) {
                user = new User();
                user.setId(rs.getInt("id"));
                user.setUsername(rs.getString("username"));
                user.setPassword(rs.getString("password"));
                user.setEmail(rs.getString("email"));
                user.setBirthday(rs.getDate("birthday"));
            }
    
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            C3P0Utils.closeAll(rs, null, conn);
        }
    
        return user;
    }

##### 适合初学者入门，需要jar包的请在评论区留言。 #####