Class JDBCStatementBuilderService

  • All Implemented Interfaces:
    AdaptrisComponent, ComponentLifecycle, ComponentLifecycleExtension, ConnectedService, MessageEventGenerator, Service, StateManagedComponent
    Direct Known Subclasses:
    JDBCDataCaptureStatementBuilderService, JDBCDataQueryStatementBuilderService

    public abstract class JDBCStatementBuilderService
    extends JdbcService
    Build a JDBC data query service using the given statement to create the necessary parameter list. Turn: INSERT INTO hits (reference, message_id, id, entity_id, blocking) VALUES (%sql_metadata{string:reference, %sql_metadata{string:%uniqueId}, %sql_metadata{string:id}, %sql_metadata{string:entity_id}, %sql_metadata{string:blocking}); into: <jdbc-string-statement-parameter> <query-string>reference</query-string> <query-type>metadata</query-type> </jdbc-string-statement-parameter> <jdbc-string-statement-parameter> <query-string>message_id</query-string> <query-type>id</query-type> </jdbc-string-statement-parameter> <jdbc-string-statement-parameter> <query-string>id>/query-string> <query-type>metadata</query-type> </jdbc-string-statement-parameter> <jdbc-string-statement-parameter> <query-string>entity_id</query-string> <query-type>metadata</query-type> </jdbc-string-statement-parameter> <jdbc-string-statement-parameter> <query-string>blocking</query-string> <query-type>metadata</query-type> </jdbc-string-statement-parameter> <statement>INSERT INTO hits (reference, message_id, id, entity_id, blocking) VALUES (?, ?, ? ,? ,?);</statement>
    Since:
    4.1.0
    • Constructor Detail

      • JDBCStatementBuilderService

        public JDBCStatementBuilderService()
    • Method Detail

      • buildService

        protected JdbcServiceWithParameters buildService​(java.lang.String statement)
                                                  throws CoreException
        Build a JDBC data query service using the given statement to create the necessary parameter list.
        Parameters:
        statement - The SQL statement.
        Returns:
        The constructed JDBC query service.
        Throws:
        CoreException
      • getStatement

        @NonNull
        public @NonNull java.lang.String getStatement()
        The SQL statement.
      • setStatement

        public void setStatement​(@NonNull
                                 @NonNull java.lang.String statement)
        The SQL statement.