Package org.jgroups.protocols

Class JDBC_PING

  • public class JDBC_PING
extends FILE_PING

    Discovery protocol using a JDBC connection to a shared database. Connection options can be defined as configuration properties, or the JNDI name of a DataSource can be provided (avoid providing both).

    Both the schema and the used SQL statements can be customized; make sure the order of parameters of such customized SQL statements is maintained and that compatible types are used for the columns. The recommended schema uses a single table, with two String columns being used primary key (local address, cluster name) and a third column to store the serialized form of the objects needed by JGroups.

    A default table will be created at first connection, errors during this operation are not considered critical. Set the initialize_sql to an empty value to prevent this initial table creation, or change it to create a customized table.

    Since:
    2.12
    Author:
    Sanne Grinovero, Bela Ban

    • Field Detail

      • connection_url

        protected java.lang.String connection_url

      • connection_username

        protected java.lang.String connection_username

      • connection_password

        protected java.lang.String connection_password

      • connection_driver

        protected java.lang.String connection_driver

      • initialize_sql

        protected java.lang.String initialize_sql

      • insert_single_sql

        protected java.lang.String insert_single_sql

      • delete_single_sql

        protected java.lang.String delete_single_sql

      • clear_sql

        protected java.lang.String clear_sql

      • select_all_pingdata_sql

        protected java.lang.String select_all_pingdata_sql

      • contains_sql

        protected java.lang.String contains_sql

      • datasource_jndi_name

        protected java.lang.String datasource_jndi_name

      • dataSource

        protected javax.sql.DataSource dataSource

    • Constructor Detail

      • JDBC_PING

        public JDBC_PING()

    • Method Detail

      • setDataSource

        public void setDataSource​(javax.sql.DataSource dataSource)

      • init

        public void init()
          throws java.lang.Exception
        Description copied from class: Protocol
        Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.
        Overrides:
        init in class FILE_PING
        Throws:
        java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

      • write

        protected void write​(java.util.List<PingData> list,
                     java.lang.String clustername)
        Overrides:
        write in class FILE_PING

      • writeToDB

        protected void writeToDB​(PingData data,
                         java.lang.String clustername,
                         boolean overwrite)

      • contains

        protected boolean contains​(java.lang.String cluster_name,
                           Address addr)

      • remove

        protected void remove​(java.lang.String clustername,
                      Address addr)
        Overrides:
        remove in class FILE_PING

      • removeAll

        protected void removeAll​(java.lang.String clustername)
        Description copied from class: FILE_PING
        Removes all files for the given cluster name
        Overrides:
        removeAll in class FILE_PING

      • readAll

        protected void readAll​(java.util.List<Address> members,
                       java.lang.String clustername,
                       Responses responses)
        Overrides:
        readAll in class FILE_PING

      • prepareStatement

        protected static final java.sql.PreparedStatement prepareStatement​(java.sql.Connection connection,
                                                                   java.lang.String sql,
                                                                   int resultSetType,
                                                                   int resultSetConcurrency)
                                                            throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • readAll

        protected void readAll​(java.sql.Connection connection,
                       java.util.List<Address> members,
                       java.lang.String clustername,
                       Responses rsps)
                throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • attemptSchemaInitialization

        protected void attemptSchemaInitialization()

      • loadDriver

        protected void loadDriver()

      • getConnection

        protected java.sql.Connection getConnection()

      • insert

        protected void insert​(java.sql.Connection connection,
                      PingData data,
                      java.lang.String clustername,
                      java.lang.String address)
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • delete

        protected void delete​(java.sql.Connection connection,
                      java.lang.String clustername,
                      java.lang.String addressToDelete)
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • delete

        protected void delete​(java.lang.String clustername,
                      java.lang.String addressToDelete)
               throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • clearTable

        protected void clearTable​(java.lang.String clustername)

      • closeConnection

        protected void closeConnection​(java.sql.Connection connection)

      • getDataSourceFromJNDI

        protected javax.sql.DataSource getDataSourceFromJNDI​(java.lang.String name)

      • verifyConfigurationParameters

        protected void verifyConfigurationParameters()

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.ClassNotFoundException
        Throws:
        java.lang.ClassNotFoundException