Package org.apache.iceberg.jdbc

Class JdbcClientPool

java.lang.Object

org.apache.iceberg.ClientPoolImpl<Connection,SQLException>

org.apache.iceberg.jdbc.JdbcClientPool

All Implemented Interfaces:

Closeable, AutoCloseable, ClientPool<Connection,SQLException>

public class JdbcClientPool
extends ClientPoolImpl<Connection,SQLException>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.iceberg.ClientPool

ClientPool.Action<R,C,E extends Exception>

Constructor Summary

Constructors

Constructor	Description
JdbcClientPool(int poolSize, String dbUrl, Map<String,String> props)
JdbcClientPool(String dbUrl, Map<String,String> props)

Method Summary

Modifier and Type	Method	Description
protected void	close(Connection client)
protected boolean	isConnectionException(Exception e)
protected Connection	newClient()
protected Connection	reconnect(Connection client)

Methods inherited from class org.apache.iceberg.ClientPoolImpl

close, isClosed, poolSize, run, run

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcClientPool

public JdbcClientPool(String dbUrl,
 Map<String,String> props)

JdbcClientPool

public JdbcClientPool(int poolSize,
 String dbUrl,
 Map<String,String> props)

Method Details

newClient

protected Connection newClient()

Specified by:

newClient in class ClientPoolImpl<Connection,SQLException>

reconnect

protected Connection reconnect(Connection client)

Specified by:

reconnect in class ClientPoolImpl<Connection,SQLException>

close

protected void close(Connection client)

Specified by:

close in class ClientPoolImpl<Connection,SQLException>

isConnectionException

protected boolean isConnectionException(Exception e)

Overrides:

isConnectionException in class ClientPoolImpl<Connection,SQLException>