Package org.apache.storm.jdbc.common
Class HikariCPConnectionProvider
- java.lang.Object
-
- org.apache.storm.jdbc.common.HikariCPConnectionProvider
-
- All Implemented Interfaces:
Serializable,ConnectionProvider
public class HikariCPConnectionProvider extends Object implements ConnectionProvider
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description HikariCPConnectionProvider(Map<String,Object> configMap)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()called once when the system is shutting down, should be idempotent.ConnectiongetConnection()Get connection.voidprepare()method must be idempotent.
-
-
-
Method Detail
-
prepare
public void prepare()
Description copied from interface:ConnectionProvidermethod must be idempotent.- Specified by:
preparein interfaceConnectionProvider
-
getConnection
public Connection getConnection()
Description copied from interface:ConnectionProviderGet connection.- Specified by:
getConnectionin interfaceConnectionProvider- Returns:
- a DB connection over which the queries can be executed.
-
cleanup
public void cleanup()
Description copied from interface:ConnectionProvidercalled once when the system is shutting down, should be idempotent.- Specified by:
cleanupin interfaceConnectionProvider
-
-