Package org.apache.arrow.driver.jdbc

Class ArrowFlightJdbcConnectionPoolDataSource

java.lang.Object

org.apache.arrow.driver.jdbc.ArrowFlightJdbcDataSource

org.apache.arrow.driver.jdbc.ArrowFlightJdbcConnectionPoolDataSource

All Implemented Interfaces:

AutoCloseable, Wrapper, EventListener, CommonDataSource, ConnectionEventListener, ConnectionPoolDataSource, DataSource

public class ArrowFlightJdbcConnectionPoolDataSource
extends ArrowFlightJdbcDataSource
implements ConnectionPoolDataSource, ConnectionEventListener, AutoCloseable

ConnectionPoolDataSource implementation for Arrow Flight JDBC Driver.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ArrowFlightJdbcConnectionPoolDataSource(Properties properties, ArrowFlightConnectionConfigImpl config)	Instantiates a new DataSource.

Method Summary

Modifier and Type	Method	Description
void	close()
void	connectionClosed(ConnectionEvent connectionEvent)
void	connectionErrorOccurred(ConnectionEvent connectionEvent)
static ArrowFlightJdbcConnectionPoolDataSource	createNewDataSource(Properties properties)	Creates a new ArrowFlightJdbcConnectionPoolDataSource.
PooledConnection	getPooledConnection()
PooledConnection	getPooledConnection(String username, String password)

Methods inherited from class org.apache.arrow.driver.jdbc.ArrowFlightJdbcDataSource

getConfig, getConnection, getConnection, getLoginTimeout, getLogWriter, getParentLogger, getProperties, isWrapperFor, setLoginTimeout, setLogWriter, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

createShardingKeyBuilder, getParentLogger

Methods inherited from interface javax.sql.ConnectionPoolDataSource

createPooledConnectionBuilder, getLoginTimeout, getLogWriter, setLoginTimeout, setLogWriter

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder

Constructor Details

ArrowFlightJdbcConnectionPoolDataSource

protected ArrowFlightJdbcConnectionPoolDataSource(Properties properties,
 ArrowFlightConnectionConfigImpl config)

Instantiates a new DataSource.

Parameters:

properties - the properties

config - the config.

Method Details

createNewDataSource

public static ArrowFlightJdbcConnectionPoolDataSource createNewDataSource(Properties properties)

Creates a new ArrowFlightJdbcConnectionPoolDataSource.

Parameters:

properties - the properties.

Returns:

a new data source.

getPooledConnection

public PooledConnection getPooledConnection()
                                     throws SQLException

Specified by:

getPooledConnection in interface ConnectionPoolDataSource

Throws:

SQLException

getPooledConnection

public PooledConnection getPooledConnection(String username,
 String password)
                                     throws SQLException

Specified by:

getPooledConnection in interface ConnectionPoolDataSource

Throws:

SQLException

connectionClosed

public void connectionClosed(ConnectionEvent connectionEvent)

Specified by:

connectionClosed in interface ConnectionEventListener

connectionErrorOccurred

public void connectionErrorOccurred(ConnectionEvent connectionEvent)

Specified by:

connectionErrorOccurred in interface ConnectionEventListener

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception