import org.apache.tomcat.jdbc.pool.ProxyConnection; //导入依赖的package包/类
private String lookupUrl() {
    if (url == null) {
        JdbcInterceptor interceptor = getNext();
        while (interceptor != null) {
            if (interceptor instanceof ProxyConnection) {
                url = getUrlFromConnectionPool(((ProxyConnection) interceptor).getPool());
                break;
            }
            interceptor = getNext();
        }
        if (url == null) {
            throw new IllegalStateException("url must not be null after looking up the chain");
        }
    }
    return url;
}
 

import org.apache.tomcat.jdbc.pool.ProxyConnection; //导入依赖的package包/类
public boolean resetTimer() {
    boolean result = false;
    JdbcInterceptor interceptor = this.getNext();
    while (interceptor!=null && result==false) {
        if (interceptor instanceof ProxyConnection) {
            PooledConnection con = ((ProxyConnection)interceptor).getConnection();
            if (con!=null) {
                con.setTimestamp(System.currentTimeMillis());
                result = true;
            } else {
                break;
            }
        }
        interceptor = interceptor.getNext();
    }
    return result;
}
 

import org.apache.tomcat.jdbc.pool.ProxyConnection; //导入依赖的package包/类
/**
 * @see com.eclecticlogic.pedal.connection.ConnectionAccessor#getRawConnection(java.sql.Connection)
 */
@Override
public Connection getRawConnection(Connection providerConnection) {
    if (Proxy.isProxyClass(providerConnection.getClass())) {
        DisposableConnectionFacade facade = (DisposableConnectionFacade) Proxy
                .getInvocationHandler(providerConnection);
        ProxyConnection pc = (ProxyConnection) facade.getNext();
        return pc.getConnection().getConnection();
    } else {
        throw new UnsupportedOperationException("This path has not been implemented yet.");
    }
}
 

import org.apache.tomcat.jdbc.pool.ProxyConnection; //导入依赖的package包/类
/**
 * Creates a mocked SQL connection, that looks like a tomcat-jdbc pooled connection.
 * @param username the username to use
 * @param password the password to use
 * @return the connection
 * @throws SQLException
 */
public static Connection create(String username, String password) throws SQLException {
    PoolProperties poolProps = new PoolProperties();
    poolProps.setUsername(username);
    poolProps.setPassword(password);
    poolProps.setDataSource(new MockDataSource());
    ConnectionPool pool = new ConnectionPool(poolProps);
    PooledConnection pooledConnection = new PooledConnection(poolProps, pool);
    pooledConnection.connect();
    ProxyConnection proxyConnection = new ProxyConnection(null, pooledConnection, true) {};
    DisposableConnectionFacade invocationHandler = new DisposableConnectionFacade(proxyConnection) {};
    Connection connection = (Connection) Proxy.newProxyInstance(DisposableConnectionFacade.class.getClassLoader(), new Class[] {Connection.class}, invocationHandler);
    return connection;
}