myconnectionpool.java

来自「dao模式结合mvc,dbcp连接池 log4j日志」· Java 代码 · 共 43 行

package com.bookstore.pool;
import java.sql.SQLException;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;

public class MyConnectionPool {

	private static String strDriver = "com.mysql.jdbc.Driver";

	private static String strURL = "jdbc:mysql://localhost/bookstore";

	private static BasicDataSource ds;
	
	public static DataSource getDataSource() {
		
		ds = new BasicDataSource();
		System.out.println("Setting up data source.");
		
		ds.setDriverClassName(strDriver);
		ds.setUsername("root");
		ds.setPassword("clsjz");
		ds.setUrl(strURL);

		ds.setInitialSize(2);
		ds.setMaxActive(4);

		System.out.println("Done.");

		return ds;
	}

	public void printDataSourceStats() throws SQLException {
		System.out.println("NumActive: " + ds.getNumActive());
		System.out.println("NumIdle: " + ds.getNumIdle());
	}

	public static void shutdownDataSource(DataSource ds) throws SQLException {
		BasicDataSource bds = (BasicDataSource) ds;
		bds.close();
	}
}