org.apache.paimon.jdbc

Class JdbcClientPool

java.lang.Object

org.apache.paimon.client.ClientPool.ClientPoolImpl<Connection,SQLException>

org.apache.paimon.jdbc.JdbcClientPool

All Implemented Interfaces:

Closeable, AutoCloseable, ClientPool<Connection,SQLException>

public class JdbcClientPool
extends ClientPool.ClientPoolImpl<Connection,SQLException>

Client pool for jdbc.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.client.ClientPool

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	close(Connection client)
String	getProtocol()
protected Connection	newClient()
protected Connection	reconnect(Connection client)

Methods inherited from class org.apache.paimon.client.ClientPool.ClientPoolImpl

close, execute, execute, isClosed, isConnectionException, 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(int poolSize,
                      String dbUrl,
                      Map<String,String> props)

Method Detail

newClient

protected Connection newClient()

Specified by:

newClient in class ClientPool.ClientPoolImpl<Connection,SQLException>

reconnect

protected Connection reconnect(Connection client)

Specified by:

reconnect in class ClientPool.ClientPoolImpl<Connection,SQLException>

getProtocol

public String getProtocol()

close

protected void close(Connection client)

Specified by:

close in class ClientPool.ClientPoolImpl<Connection,SQLException>