Module datarush.library
Package com.pervasive.datarush.operators.io.jdbc

Class WriteToJDBC

  • All Implemented Interfaces:
    ConnectionSettings, LogicalOperator
    public final class WriteToJDBC
extends AbstractWriteToJDBC
    In its simplest form, writes records from an input port to a JDBC target table using insert statements. Initial and final SQL statements can be provided. The initial statement is run before any input data is handled. The final statement is executed after all input data has been processed. The initial statement must be provided when this operator is used in OVERWRITETABLE mode.

    Note that the WriteToJDBC operator is parallelized. Each parallel instance will open a separate connection to the target database. To limit the number of database connections used by this operator, tune down the operator parallelism level. To set the parallelism level create an OperatorSettings instance with maximum parallelism set to the wanted level. The operator settings can then be passed as a parameter to the LogicalGraph#add(com.pervasive.datarush.operators.LogicalOperator, OperatorSettings) method.

    • Constructor Detail

      • WriteToJDBC

        public WriteToJDBC()
        Default constructor.

      • WriteToJDBC

        public WriteToJDBC​(WriteToJDBC other)
        Copy constructor.
        Parameters:
        other - the other instance of WriteToJDBC

    • Method Detail

      • compose

        protected void compose​(CompositionContext ctx)
        Description copied from class: CompositeOperator
        Compose the body of this operator. Implementations should do the following:
        1. Perform any validation of configuration, input types, etc
        2. Instantiate and configure sub-operators, adding them to the provided context via the method OperatorComposable.add(O)
        3. Create necessary connections via the method OperatorComposable.connect(P, P). This includes connections from the composite's input ports to sub-operators, connections between sub-operators, and connections from sub-operators output ports to the composite's output ports
        Specified by:
        compose in class CompositeOperator
        Parameters:
        ctx - the context