org.apache.drill.jdbc

Class MultiConnectionCachingFactory

java.lang.Object

org.apache.drill.jdbc.MultiConnectionCachingFactory

All Implemented Interfaces:

CachingConnectionFactory, ConnectionFactory

public class MultiConnectionCachingFactory
extends Object
implements CachingConnectionFactory

A connection factory that caches connections based on given ConnectionInfo.

Constructor Summary

Constructors

Constructor and Description
MultiConnectionCachingFactory(ConnectionFactory delegate)

Method Summary

Modifier and Type	Method and Description
void	closeConnections() Closes all active connections in the cache.
Connection	getConnection(ConnectionInfo info) Creates a connection and caches it.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiConnectionCachingFactory

public MultiConnectionCachingFactory(ConnectionFactory delegate)

Method Detail

getConnection

public Connection getConnection(ConnectionInfo info)
                         throws SQLException

Creates a connection and caches it. The returned connection does not support Connection.close(). Consumer must call {#close} to close the cached connections.

Specified by:

getConnection in interface ConnectionFactory

Parameters:

info - the connection parameters

Throws:

SQLException

closeConnections

public void closeConnections()
                      throws SQLException

Closes all active connections in the cache.

Specified by:

closeConnections in interface CachingConnectionFactory

Throws:

SQLException