Package 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
    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 Details

    • 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.