Package org.apache.iceberg.jdbc

Class JdbcClientPool

java.lang.Object

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

org.apache.iceberg.jdbc.JdbcClientPool

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ClientPool<java.sql.Connection,java.sql.SQLException>

public class JdbcClientPool
extends ClientPoolImpl<java.sql.Connection,java.sql.SQLException>

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor	Description
JdbcClientPool(int poolSize, java.lang.String dbUrl, java.util.Map<java.lang.String,java.lang.String> props)
JdbcClientPool(java.lang.String dbUrl, java.util.Map<java.lang.String,java.lang.String> props)

Method Summary

Modifier and Type	Method	Description
protected void	close(java.sql.Connection client)
protected boolean	isConnectionException(java.lang.Exception e)
protected java.sql.Connection	newClient()
protected java.sql.Connection	reconnect(java.sql.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 Detail

JdbcClientPool

public JdbcClientPool(java.lang.String dbUrl,
                      java.util.Map<java.lang.String,java.lang.String> props)

JdbcClientPool

public JdbcClientPool(int poolSize,
                      java.lang.String dbUrl,
                      java.util.Map<java.lang.String,java.lang.String> props)

Method Detail

newClient

protected java.sql.Connection newClient()

Specified by:

newClient in class ClientPoolImpl<java.sql.Connection,java.sql.SQLException>

reconnect

protected java.sql.Connection reconnect(java.sql.Connection client)

Specified by:

reconnect in class ClientPoolImpl<java.sql.Connection,java.sql.SQLException>

close

protected void close(java.sql.Connection client)

Specified by:

close in class ClientPoolImpl<java.sql.Connection,java.sql.SQLException>

isConnectionException

protected boolean isConnectionException(java.lang.Exception e)

Overrides:

isConnectionException in class ClientPoolImpl<java.sql.Connection,java.sql.SQLException>