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

      • 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