Signed-off-by: chenhaoxiang <[email protected]>

Author: chenhaoxiang

myDbPoolUse/.classpath

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/jdk1.7.0_04"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.junit.JUNIT_CONTAINER/4"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/commons-dbcp2-2.1.1.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/commons-logging-1.2.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/commons-pool2-2.4.2.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/mysql-connector-java-5.1.39-bin.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/c3p0-0.9.1.2.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/c3p0-sources-0.9.1.2.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/commons-dbutils-1.6.jar"/>
+	<classpathentry kind="lib" path="src/cn/hncu/bin/commons-dbutils-ext.jar"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

myDbPoolUse/.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>myDbPoolUse</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

myDbPoolUse/.settings/org.eclipse.jdt.core.prefs

@@ -0,0 +1,12 @@
+#Mon Aug 15 15:13:10 CST 2016
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.6
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.source=1.6

myDbPoolUse/README.md

@@ -0,0 +1,3 @@
+BasicDataSource创建DataSource(DBCP连接池配置)
+ComboPooledDataSource(C3P0连接池配置)
+Apache的DBUtils框架使用

myDbPoolUse/bin/c3p0-config.xml

@@ -0,0 +1,34 @@
+<c3p0-config>
+	<!-- 默认配置，如果没有指定则使用这个配置 -->
+	<default-config>
+		<property name="driverClass">com.mysql.jdbc.Driver</property>
+		<property name="jdbcUrl">
+			<![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]>
+		</property>
+		<property name="user">root</property>
+		<property name="password">1234</property>
+		<!-- 初始化池大小 -->
+		<property name="initialPoolSize">2</property>
+		<!-- 最大空闲时间 -->
+		<property name="maxIdleTime">30</property>
+		<!-- 最多有多少个连接 -->
+		<property name="maxPoolSize">10</property>
+		<!-- 最少几个连接 -->
+		<property name="minPoolSize">2</property>
+		<!-- 每次最多可以执行多少个批处理语句 -->
+		<property name="maxStatements">50</property>
+	</default-config> 
+	<!-- 命名的配置 -->
+	<named-config name="demo">
+		<property name="driverClass">com.mysql.jdbc.Driver</property>
+		<property name="jdbcUrl"><![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]></property>
+		<property name="user">root</property>
+		<property name="password">1234</property>
+		<property name="acquireIncrement">5</property><!-- 如果池中数据连接不够时一次增长多少个 -->
+		<property name="initialPoolSize">100</property>
+		<property name="minPoolSize">50</property>
+		<property name="maxPoolSize">1000</property>
+		<property name="maxStatements">0</property>
+		<property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
+	</named-config>
+</c3p0-config> 

myDbPoolUse/bin/cn/hncu/C3p0/C3p0Demo.class

@@ -0,0 +1,11 @@
+##MySQL
+driver=com.mysql.jdbc.Driver
+url=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8
+username=root
+password=1234
+
+##Oracle
+#driver=oracle.jdbc.driver.OracleDriver
+#url=jdbc:oracle:thin:@localhost:1521:orcl
+#username=scott
+#password=tiger

myDbPoolUse/bin/cn/hncu/C3p0/C3p0Pool.class

@@ -0,0 +1,34 @@
+<c3p0-config>
+	<!-- 默认配置，如果没有指定则使用这个配置 -->
+	<default-config>
+		<property name="driverClass">com.mysql.jdbc.Driver</property>
+		<property name="jdbcUrl">
+			<![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]>
+		</property>
+		<property name="user">root</property>
+		<property name="password">1234</property>
+		<!-- 初始化池大小 -->
+		<property name="initialPoolSize">2</property>
+		<!-- 最大空闲时间 -->
+		<property name="maxIdleTime">30</property>
+		<!-- 最多有多少个连接 -->
+		<property name="maxPoolSize">10</property>
+		<!-- 最少几个连接 -->
+		<property name="minPoolSize">2</property>
+		<!-- 每次最多可以执行多少个批处理语句 -->
+		<property name="maxStatements">50</property>
+	</default-config> 
+	<!-- 命名的配置 -->
+	<named-config name="demo">
+		<property name="driverClass">com.mysql.jdbc.Driver</property>
+		<property name="jdbcUrl"><![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]></property>
+		<property name="user">root</property>
+		<property name="password">1234</property>
+		<property name="acquireIncrement">5</property><!-- 如果池中数据连接不够时一次增长多少个 -->
+		<property name="initialPoolSize">100</property>
+		<property name="minPoolSize">50</property>
+		<property name="maxPoolSize">1000</property>
+		<property name="maxStatements">0</property>
+		<property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
+	</named-config>
+</c3p0-config> 

myDbPoolUse/bin/cn/hncu/bin/c3p0-0.9.1.2.jar

@@ -0,0 +1,45 @@
+package cn.hncu.C3p0;
+
+import java.beans.PropertyVetoException;
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import org.junit.Test;
+
+import com.mchange.v2.c3p0.ComboPooledDataSource;
+
+public class C3p0Demo {
+
+	@Test
+	// 纯Java方法使用c3p0
+	public void C3p0Demo() throws PropertyVetoException, SQLException {
+		ComboPooledDataSource pool = new ComboPooledDataSource();
+		pool.setUser("root");// 用户姓名
+		pool.setPassword("1234");// 用户密码
+		pool.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8");// MySQL数据库连接url
+		pool.setDriverClass("com.mysql.jdbc.Driver");
+
+		// pool可以调用set方法进行Connection池的配置
+
+		// 连接关闭之后，内存会被释放，下次取时会重新开(内存地址不共用)
+		for (int i = 0; i < 20; i++) {
+			Connection con = pool.getConnection();
+			System.out.println(i + ":" + con);
+			if (i % 2 == 0) {
+				con.close();
+			}
+		}
+	}
+
+	@Test
+	// 演示采用配置文件的方式使用c3p0
+	public void C3p0PropertyDemo() throws SQLException {
+		ComboPooledDataSource pool = new ComboPooledDataSource();//空参，自动到classpath目录下面加载“c3p0-config.xml”配置文件---配置文件的存储位置和名称必须是这样，且使用“默认配置”
+		//ComboPooledDataSource pool = new ComboPooledDataSource("demo");//加载“c3p0-config.xml”文件中定义的“demo”这个配置元素
+		 for(int i=0;i<25;i++){
+			   Connection con = pool.getConnection();
+			   System.out.println(i+":"+ con.hashCode());
+		   }
+	}
+
+}

myDbPoolUse/bin/cn/hncu/bin/c3p0-sources-0.9.1.2.jar

@@ -0,0 +1,31 @@
+package cn.hncu.C3p0;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import javax.sql.DataSource;
+
+import com.mchange.v2.c3p0.ComboPooledDataSource;
+
+public class C3p0Pool {
+	//我们的这个包装，只是为了把c3p0池做成让每个线程(客户端)获得的是同一个连接，方便做b/s框架下的事务
+	private static DataSource pool;
+	private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
+	static{
+		pool = new ComboPooledDataSource("demo");
+		//这里的参数视你的配置文件而定，也可以不写，用默认的配置
+	}
+	
+	public static DataSource getDataSource(){
+		return pool;
+	}
+	
+	public static Connection getConnection() throws SQLException{
+		Connection con = t.get();
+		if(con==null){
+			con=pool.getConnection();
+			t.set(con);
+		}
+		return con;
+	}
+}

myDbPoolUse/bin/cn/hncu/bin/commons-dbcp2-2.1.1.jar

@@ -0,0 +1,61 @@
+package cn.hncu.dbcp;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.Properties;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.dbcp2.BasicDataSource;
+import org.apache.commons.dbcp2.BasicDataSourceFactory;
+import org.junit.Test;
+
+public class DbcpPoolDemo {
+
+	// 纯Java方式设置参数，使用dbcp池
+	@Test
+	public void testDbcp() {
+		BasicDataSource pool = new BasicDataSource();// 连接池
+		pool.setUsername("root");
+		pool.setPassword("1234");
+		pool.setDriverClassName("com.mysql.jdbc.Driver");
+		pool.setUrl("jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8");
+
+		System.out.println(pool.getMaxIdle());// 最大空闲时间。如果一个用户获取一个连接，不用，多长时间会被强行收回
+		System.out.println(pool.getMaxWaitMillis());// 在抛出异常之前,池等待连接被回收的最长时间（当没有可用连接时）。设置为-1表示无限等待。
+		System.out.println(pool.getInitialSize());// 初始化时有几个Connection
+		System.out.println(pool.getMaxTotal());// 最多能有多少个Connection
+		
+		System.out.println("----------------");
+		// pool.setMaxTotal(20);//可以我们自己设置池的相关参数，如最大连接数
+
+		// 从它的池中获取连接
+		for (int i = 0; i < 20; i++) {
+			Connection con = null;
+			try {
+				con = pool.getConnection();
+			} catch (SQLException e) {
+				e.printStackTrace();
+			}
+			System.out.println(i + ":" + con.hashCode());
+		}
+	}
+
+	// 通过配置文件方式设置参数，使用dbcp池
+	@Test
+	public void testPropertyFile() throws Exception {
+		Properties p = new Properties();
+		p.load(DbcpPoolDemo.class.getResourceAsStream("dbcp.properties"));// 配置文件和当前类的class放在一起
+		// p.load(DbcpPoolDemo.class.getClassLoader().getResourceAsStream("dbcp.properties"));//配置文件要放在src(bin)的根目录---classpath的根
+		DataSource pool = BasicDataSourceFactory.createDataSource(p);
+		// 从它的池中获取连接
+		for (int i = 0; i < 20; i++) {
+			Connection con = pool.getConnection();
+			System.out.println(con.hashCode());
+			if (i % 2 == 0) {
+				con.close();
+			}
+		}
+	}
+
+}

myDbPoolUse/bin/cn/hncu/bin/commons-dbutils-1.6.jar

@@ -0,0 +1,45 @@
+package cn.hncu.dbcp;
+
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.Properties;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.dbcp2.BasicDataSourceFactory;
+
+public class DbcpUtil {
+	private static DataSource pool;
+	private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
+	static{
+		
+		try {
+			//读取配置文件
+			Properties p = new Properties();
+			p.load(DbcpUtil.class.getResourceAsStream("dbcp.properties"));// 配置文件和当前类的class放在一起
+			pool = BasicDataSourceFactory.createDataSource(p);
+		} catch (IOException e) {
+			e.printStackTrace();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+	
+	//返回DataSource--池
+	public static DataSource getDataSource(){
+		return pool;
+	}
+	
+	public static Connection getConnection() throws SQLException{
+		//从本地线程管理对象t中拿
+		Connection con = t.get();
+		if(con==null){
+			con=pool.getConnection();
+			//放入t中
+			t.set(con);
+		}
+		return con;
+	}
+	
+}

myDbPoolUse/bin/cn/hncu/bin/commons-dbutils-ext.jar

@@ -0,0 +1,11 @@
+##MySQL
+driver=com.mysql.jdbc.Driver
+url=jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=utf-8
+username=root
+password=1234
+
+##Oracle
+#driver=oracle.jdbc.driver.OracleDriver
+#url=jdbc:oracle:thin:@localhost:1521:orcl
+#username=scott
+#password=tiger