org.apache.storm.jdbc.common

Interface ConnectionProvider

All Superinterfaces:

Serializable

All Known Implementing Classes:

HikariCPConnectionProvider

public interface ConnectionProvider
extends Serializable

Provides a database connection.

Method Summary

Modifier and Type	Method and Description
void	cleanup() called once when the system is shutting down, should be idempotent.
Connection	getConnection() Get connection.
void	prepare() method must be idempotent.

Method Detail

prepare

void prepare()

method must be idempotent.

getConnection

Connection getConnection()

Get connection.

Returns:

a DB connection over which the queries can be executed.

cleanup

void cleanup()

called once when the system is shutting down, should be idempotent.