testmypool.java

一个Eclipse环境下的数据库连接池算法实现。

package scut.ailab.connectionpool;

import java.sql.*;

public class testmypool {
	/*public void test1(){
		String user = "mobile";
		String password = "mobile";
		String driver = "jdbc:microsoft:sqlserver";
		String url ="192.168.3.100";
		ConnectionParam param = new ConnectionParam(driver,url,user,password);
		ConnectionFactory cf = null;
		try{
			cf = new ConnectionFactory(param,new FactoryParam());
			Connection  conn1 = cf.getFreeConnection();
			Connection  conn2 = cf.getFreeConnection();
			Connection  conn3 = cf.getFreeConnection();
			Statement   stmt = conn1.createStatement();
			String sql = "select * from msm_re";
			ResultSet   rs   = stmt.executeQuery(sql);
			if(rs.next()){
				System.out.println("conn1 y");
			}
			else{
				System.out.println("conn1 n");
			}
			stmt.close();
			conn1.close();
			Connection conn4 = cf.getFreeConnection();
			Connection conn5 = cf.getFreeConnection();
			stmt = conn5.createStatement();
			rs = stmt.executeQuery(sql);
			if(rs.next()){
				System.out.println("conn5 y");
			}
			else{
				System.out.println("conn5 n");
			}
			conn2.close();
			conn3.close();
			conn4.close();
			conn5.close();
		}catch(Exception e){
			e.printStackTrace();
		}
		finally{
			try{
				cf.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
	}*/
	
	public static void main(String args[]){
		String user = "mobile";
		String password = "mobile";
		String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
		String url ="jdbc:microsoft:sqlserver://192.168.3.55:1433;DatabaseName=mobile";
		ConnectionParam param = new ConnectionParam(driver,url,user,password);
		ConnectionFactory cf = null;
		try{
			cf = new ConnectionFactory(param,new FactoryParam());
			Connection  conn1= null;
			long time = System.currentTimeMillis();
			for(int i = 0; i < 10; i++){
				conn1 = cf.getFreeConnection();
				Statement stmt1 = conn1.createStatement();
				ResultSet rs = stmt1.executeQuery("select * from SMS_SEND");
				if(rs.next()){
					System.out.println("conn1 y");
				}
				else{
					System.out.println("conn1 n");
				}
				conn1.close();
			}
			 System.out.println("pool:" + (System.currentTimeMillis()-time));
			 time = System.currentTimeMillis();
			 Class.forName(param.getDriver()).newInstance();
			 for (int i=0; i <10;i++){
				 conn1 = DriverManager.getConnection(param.getUrl(),param.getUser(), param.getPassword());   
				 Statement stmt = conn1.createStatement();
				 ResultSet rs = stmt.executeQuery("select * from SMS_SEND");
				 if (rs.next()){
					 System.out.println("conn1 y");  
				 }
				 else{
					 System.out.println("conn1 n");  
				 }
				 System.out.println("no pool:" + (System.currentTimeMillis()-time));
			 }
		}catch(Exception e){
			e.printStackTrace();
		}
		finally{
			try{
				cf.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
	}

}