【javaweb】自定义连接池demonstration

爱被打了一巴掌 2022-06-02 10:28 192阅读 0赞

package jdbc.datasource;
    /**
     * 自定义一个连接池
     * 注意：创建连接池必须要实现java给出的DataSource接口,其它厂商创建连接池也是一样必须实现给定的接口
     * @author Administrator
     */
    
    import java.io.PrintWriter;
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.sql.SQLFeatureNotSupportedException;
    import java.util.LinkedList;
    import java.util.logging.Logger;
    
    import javax.sql.DataSource;
    
    import jdbc.utils.JDBCUtils_V3;
    
    public class MyDataSource implements DataSource{
    	//1.第一步创建一个LinkedList集合用于存储创建好了的连接对象
    	private static LinkedList<Connection> connPool=new LinkedList<>();
    	//2.向池子中预存5个连接对象
    	static {
    		for(int i=0;i<5;i++) {
    			connPool.add(JDBCUtils_V3.getConnection());
    		}
    	}
    	/**
    	 * 重写getConnection()方法
    	 */
    	@Override
    	public Connection getConnection() throws SQLException {
    		Connection conn=null;
    		//3.在获取连接之前，首先判断连接池中是否还有连接
    		if(connPool.size()==0) {
    			for(int i=0;i<5;i++) {
    				connPool.add(JDBCUtils_V3.getConnection());
    			}
    		}
    		//4.从连接池中删除并返回第一个连接
    		conn=connPool.remove(0);
    		return conn;
    	}
    	/**
    	 * 自己创建的一个归还连接的方法
    	 * @param conn
    	 */
    	public void givebackConnection(Connection conn) {
    		connPool.add(conn);
    	}
    
    	@Override
    	public PrintWriter getLogWriter() throws SQLException {
    		
    		return null;
    	}
    
    	@Override
    	public void setLogWriter(PrintWriter out) throws SQLException {
    	}
    
    	@Override
    	public void setLoginTimeout(int seconds) throws SQLException {
    	}
    
    	@Override
    	public int getLoginTimeout() throws SQLException {
    		
    		return 0;
    	}
    
    	@Override
    	public Logger getParentLogger() throws SQLFeatureNotSupportedException {
    		
    		return null;
    	}
    
    	@Override
    	public <T> T unwrap(Class<T> iface) throws SQLException {
    		
    		return null;
    	}
    
    	@Override
    	public boolean isWrapperFor(Class<?> iface) throws SQLException {
    		
    		return false;
    	}
    
    	
    
    	@Override
    	public Connection getConnection(String username, String password) throws SQLException {
    		
    		return null;
    	}
    
    }