D3P0实践小例子
首先導(dǎo)入包:c3p0-0.9.1.2.jar
然后實(shí)現(xiàn)代碼:
package star.july.c3p0Util;import java.sql.Connection; import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;public class C3P0Util {private static String driverClass = "com.mysql.jdbc.Driver";private static String url = "jdbc:mysql://localhost:3306/day18";private static String user = "root";private static String password = "root";//連接池對(duì)象private static ComboPooledDataSource ds = new ComboPooledDataSource();//設(shè)置連接池參數(shù)static{try{//1.連接數(shù)據(jù)庫(kù)參數(shù)ds.setDriverClass(driverClass);ds.setJdbcUrl(url);ds.setUser(user);ds.setPassword(password);//2.連接池參數(shù)//初始化連接數(shù)ds.setInitialPoolSize(5);//最大連接數(shù)ds.setMaxPoolSize(10);//最長(zhǎng)等待時(shí)間ds.setCheckoutTimeout(3000);}catch(Exception e){e.printStackTrace();}}public static Connection getConnection(){try{//從c3p0連接池程序獲取連接Connection con = ds.getConnection();return con;}catch(SQLException e){e.printStackTrace();throw new RuntimeException();}} }
主類:
package star.july.c3p0Util;import java.sql.Connection; import java.sql.SQLException;public class c3p0Dao {public static void main(String[] args) throws Exception {for(int i =1;i<=11;i++){//獲取連接Connection conn = C3P0Util.getConnection();System.out.println(conn);//如果i==3,則關(guān)閉連接if(i==3){conn.close();}}} }
總結(jié)
- 上一篇: 自定义连接池
- 下一篇: DButils的更新与查询,利用C3P0