尚硅谷之JDBC
方式一:
示例代碼:
步驟:
1、加入兩個jar
DBCP數(shù)據(jù)庫連接池的的jar:Commons-dbcp.jar
連接池實現(xiàn)的依賴庫:Commons-pool.jar,如果不加這個,運行報如下異常
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/commons/pool/KeyedObjectPoolFactory at com.jdbc.datasource.TestDBCP.main(TestDBCP.java:14) Caused by: java.lang.ClassNotFoundException: org.apache.commons.pool.KeyedObjectPoolFactory at java.net.URLClassLoader.findClass(Unknown Source) at java.lang.ClassLoader.loadClass(Unknown Source) at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source) at java.lang.ClassLoader.loadClass(Unknown Source) ... 1 more |
2、編寫代碼
package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP { public static void main(String[] args) throws SQLException { //1.創(chuàng)建DBCP數(shù)據(jù)源(即連接池) BasicDataSource ds = new BasicDataSource(); //2.設置數(shù)據(jù)源的必須屬性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.設置數(shù)據(jù)源的可選屬性 //(1)指定數(shù)據(jù)庫連接池中初始化連接數(shù)的個數(shù) ds.setInitialSize(10); //(2)指定最大的連接數(shù): 同一時刻可以同時向數(shù)據(jù)庫申請的連接數(shù) ds.setMaxActive(50); //(3)在數(shù)據(jù)庫連接池中保存的最少的空閑連接的數(shù)量 ds.setMinIdle(2); //(4)等待數(shù)據(jù)庫連接池分配連接的最長時間. 單位為毫秒. 超出該時間將拋出異常. ds.setMaxWait(1000*5); //4.從數(shù)據(jù)源中獲取數(shù)據(jù)庫連接 Connection conn = ds.getConnection(); System.out.println(conn); } } |
測試超過連接數(shù)
package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP2 { public static void main(String[] args) throws SQLException { //1.創(chuàng)建DBCP數(shù)據(jù)源(即連接池) BasicDataSource ds = new BasicDataSource(); //2.設置數(shù)據(jù)源的必須屬性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.設置數(shù)據(jù)源的可選屬性 //(1)指定數(shù)據(jù)庫連接池中初始化連接數(shù)的個數(shù) ds.setInitialSize(3); //(2)指定最大的連接數(shù): 同一時刻可以同時向數(shù)據(jù)庫申請的連接數(shù) ds.setMaxActive(5); //(3)指定最小活躍的連接數(shù): 在數(shù)據(jù)庫連接池中保存的最少的空閑連接的數(shù)量 ds.setMinIdle(2); //(4)等待數(shù)據(jù)庫連接池分配連接的最長時間. 單位為毫秒. 超出該時間將拋出異常. ds.setMaxWait(1000*5); //4.從數(shù)據(jù)源中獲取數(shù)據(jù)庫連接 for(int i=0;i<6;i++){ Connection conn = ds.getConnection(); System.out.println("獲取第"+(i+1)+"個"+conn); //這里沒有關閉,即沒有放回連接池 } } } |
測試如果連接重復使用
package com.jdbc.datasource; import java.sql.Connection; import java.sql.SQLException; import org.apache.commons.dbcp.BasicDataSource; public class TestDBCP3 { public static void main(String[] args) throws SQLException { //1.創(chuàng)建DBCP數(shù)據(jù)源(即連接池) BasicDataSource ds = new BasicDataSource(); //2.設置數(shù)據(jù)源的必須屬性 ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://localhost:3306/test"); ds.setUsername("root"); ds.setPassword("root"); //3.設置數(shù)據(jù)源的可選屬性 //(1)指定數(shù)據(jù)庫連接池中初始化連接數(shù)的個數(shù) ds.setInitialSize(3); //(2)指定最大的連接數(shù): 同一時刻可以同時向數(shù)據(jù)庫申請的連接數(shù) ds.setMaxActive(5); //(3)指定最小活躍的連接數(shù): 在數(shù)據(jù)庫連接池中保存的最少的空閑連接的數(shù)量 ds.setMinIdle(2); //(4)等待數(shù)據(jù)庫連接池分配連接的最長時間. 單位為毫秒. 超出該時間將拋出異常. ds.setMaxWait(1000*5); //4.從數(shù)據(jù)源中獲取數(shù)據(jù)庫連接 for(int i=0;i<10;i++){ new Thread(){ public void run(){ try { Connection conn = ds.getConnection(); System.out.println("獲取1個"+conn); Thread.sleep(3000); //隔3秒換回去 conn.close(); } catch (Exception e) { e.printStackTrace(); } } }.start(); } } } |