java使用dbcp操做數據庫

這裏用一個java代碼來演示使用dbcp鏈接管理數據庫及進行查詢操做

public class DbcpConnTest {
    //create datasource
    public static DataSource setupDataSource() {
        String connectURL = "jdbc:mysql://XXXX:3306/zz_test";
        BasicDataSource ds = new BasicDataSource();
        ds.setDriverClassName("org.gjt.mm.mysql.Driver");
        ds.setUrl(connectURL);
        ds.setUsername("XXXX");
        ds.setPassword("XXXX");
        return ds;
    }
    // close datasource
    public static void shutdownDataSource(DataSource ds) throws SQLException {
        BasicDataSource bds = (BasicDataSource) ds;
        bds.close();
    }

    //main function
    public static void main(String[] args) {
        //  DataSource datasource = setupDataSource(args[0]);
        DataSource datasource = setupDataSource();
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        String sql = null;
        try {
            System.out.println("test");
            conn = datasource.getConnection();
            System.out.println("test2");
            stmt = conn.createStatement();
            sql = "select * from book";
            rs = stmt.executeQuery(sql);
            System.out.println("Results:");
            int numcols = rs.getMetaData().getColumnCount();
            System.out.println("numcols " + numcols);
            while (rs.next()) {
                // for(int i=1;i<=numcols;i++){
                System.out.println(" " + rs.getInt(1));
                System.out.println(" " + rs.getString(2));
                System.out.println(" " + rs.getString(3));
                //}
            }
        } catch (SQLException e) {
            System.out.println("connect wrong!");
            e.printStackTrace();
        } finally {
            try {
                rs.close();
            } catch (SQLException e) {
                System.out.println("rs close error");
                e.printStackTrace();
            }
            try {
                stmt.close();
            } catch (SQLException e) {
                System.out.println("stmt close error");
                e.printStackTrace();
            }
            try {
                conn.close();
            } catch (SQLException e) {
                System.out.println("conn close error");
                e.printStackTrace();
            }
        }
    }
}

能夠看到獲取數據源的部分使用的類是不同的。

那麼web項目中如何配置dbpc數據源呢？

能夠參考以下配置：

<data-source type="org.apache.commons.dbcp.BasicDataSource">
<set-property property="driverClassName" value="com.mysql.jdbc.Driver" />
<set-property property="url" value="jdbc:mysql://localhost:3306/XXX" />
<set-property property="username" value="XXX" />
<set-property property="password" value="XXX" />
<set-property property="maxActive" value="40" />
<set-property property="maxWait" value="5000" />
<set-property property="defaultAutoCommit" value="true" />
<set-property property="defaultReadOnly" value="false" />
<set-property property="removeAbandoned" value="true" />
<set-property property="removeAbandonedTimeout" value="120" />
<set-property property="encoding" value="false" />
</data-source>

總結一下，這裏主要就是介紹如何使用dbcp數據源獲取鏈接而且操做數據庫，以及web項目中經常使用的配置方法。