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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
close(java.sql.Connection client)
protected java.sql.Connection
newClient()
protected java.sql.Connection
reconnect(java.sql.Connection client)
-
Methods inherited from class org.apache.iceberg.ClientPoolImpl
close, isConnectionException, poolSize, run, run
-
-
-
-
Method Detail
-
newClient
protected java.sql.Connection newClient()
- Specified by:
newClient
in classClientPoolImpl<java.sql.Connection,java.sql.SQLException>
-
reconnect
protected java.sql.Connection reconnect(java.sql.Connection client)
- Specified by:
reconnect
in classClientPoolImpl<java.sql.Connection,java.sql.SQLException>
-
close
protected void close(java.sql.Connection client)
- Specified by:
close
in classClientPoolImpl<java.sql.Connection,java.sql.SQLException>
-
-