Package org.jgroups.protocols

Class JDBC_PING2

  • All Implemented Interfaces:
    Lifecycle
    public class JDBC_PING2
extends FILE_PING
    New version of JDBC_PING. Has a new, better legible schema. plus some refactoring
    Since:
    5.4, 5.3.7
    Author:
    Bela Ban

    • Field Detail

      • lock

        protected final java.util.concurrent.locks.Lock lock

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

        protected java.lang.String insert_sp

      • call_insert_sp

        protected java.lang.String call_insert_sp

      • 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

      • datasource_jndi_name

        protected java.lang.String datasource_jndi_name

      • datasource_injecter_class

        protected java.lang.String datasource_injecter_class

      • dataSource

        protected javax.sql.DataSource dataSource

    • Constructor Detail

      • JDBC_PING2

        public JDBC_PING2()

    • Method Detail

      • setDataSource

        public JDBC_PING2 setDataSource​(javax.sql.DataSource ds)

      • getDataSource

        public javax.sql.DataSource getDataSource()

      • getConnectionUrl

        public java.lang.String getConnectionUrl()

      • setConnectionUrl

        public JDBC_PING2 setConnectionUrl​(java.lang.String c)

      • getConnectionUsername

        public java.lang.String getConnectionUsername()

      • setConnectionUsername

        public JDBC_PING2 setConnectionUsername​(java.lang.String c)

      • getConnectionPassword

        public java.lang.String getConnectionPassword()

      • setConnectionPassword

        public JDBC_PING2 setConnectionPassword​(java.lang.String c)

      • getConnectionDriver

        public java.lang.String getConnectionDriver()

      • setConnectionDriver

        public JDBC_PING2 setConnectionDriver​(java.lang.String c)

      • getInitializeSql

        public java.lang.String getInitializeSql()

      • setInitializeSql

        public JDBC_PING2 setInitializeSql​(java.lang.String i)

      • getInsertSingleSql

        public java.lang.String getInsertSingleSql()

      • setInsertSingleSql

        public JDBC_PING2 setInsertSingleSql​(java.lang.String i)

      • getInsertSp

        public java.lang.String getInsertSp()

      • setInsertSp

        public JDBC_PING2 setInsertSp​(java.lang.String sp)

      • getCallInsertSp

        public java.lang.String getCallInsertSp()

      • setCallInsertSp

        public JDBC_PING2 setCallInsertSp​(java.lang.String sp)

      • getDeleteSingleSql

        public java.lang.String getDeleteSingleSql()

      • setDeleteSingleSql

        public JDBC_PING2 setDeleteSingleSql​(java.lang.String d)

      • getClearSql

        public java.lang.String getClearSql()

      • setClearSql

        public JDBC_PING2 setClearSql​(java.lang.String c)

      • getSelectAllPingdataSql

        public java.lang.String getSelectAllPingdataSql()

      • setSelectAllPingdataSql

        public JDBC_PING2 setSelectAllPingdataSql​(java.lang.String s)

      • getDatasourceJndiName

        public java.lang.String getDatasourceJndiName()

      • setDatasourceJndiName

        public JDBC_PING2 setDatasourceJndiName​(java.lang.String d)

      • getDatasourceInjecterClass

        public java.lang.String getDatasourceInjecterClass()

      • setDatasourceInjecterClass

        public JDBC_PING2 setDatasourceInjecterClass​(java.lang.String d)

      • init

        public void init()
          throws java.lang.Exception
        Description copied from class: Protocol
        Called after a protocol has been created and before the protocol is started. Attributes are already set. Other protocols are not yet connected and events cannot yet be sent.
        Specified by:
        init in interface Lifecycle
        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 the channel constructor will throw an exception

      • dump

        public java.lang.String dump​(java.lang.String cluster)
                      throws java.lang.Exception
        Throws:
        java.lang.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)
                  throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • 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

      • readFromDB

        protected java.util.List<PingData> readFromDB​(java.lang.String cluster)
                                       throws java.lang.Exception
        Throws:
        java.lang.Exception

      • prepare

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

      • createSchema

        protected void createSchema()

      • createInsertStoredProcedure

        protected void createInsertStoredProcedure()
                                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • loadDriver

        protected void loadDriver()

      • injectDataSource

        protected javax.sql.DataSource injectDataSource​(java.lang.String ds_class)
                                         throws java.lang.Exception
        Throws:
        java.lang.Exception

      • getConnection

        protected java.sql.Connection getConnection()
                                     throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • insert

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

      • callInsertStoredProcedure

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

      • delete

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

      • delete

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

      • clearTable

        protected void clearTable​(java.lang.String clustername)
                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getDataSourceFromJNDI

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

      • assertNonNull

        protected static void assertNonNull​(java.lang.String... strings)

      • main

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