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

Class UpdateInJDBC

  • All Implemented Interfaces:
    ConnectionSettings, LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator
    public final class UpdateInJDBC
extends AbstractWriteToJDBC
implements RecordPipelineOperator
    This operator updates the target table in a database by applying SQL update statements. This operator will additionally copy the used input to an output port that will contain an additional status field indicating whether the update succeeded for that row and how many rows in the target table were updated by it. The operator will use the input data rows to create database update statements. Values provided in the input data source will be used to update the target table values. Key fields must be specified in the operator properties. Key field values will be used within generated database update statements. The updated fields may also be optionally set using setUpdateFields(String[]). If unset will use all fields not already used as key fields. 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. Note that the UpdateInJDBC 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

      • UpdateInJDBC

        public UpdateInJDBC()
        Default constructor.

      • UpdateInJDBC

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

    • Method Detail

      • setStatusField

        public void setStatusField​(String statusField)
        Set the name of the field that will contain the update status. Defaults to Updated.
        Parameters:
        statusField - name of the status field in the output

      • getStatusField

        public String getStatusField()
        Get the name of the field that will contain the update status.
        Returns:
        name of the status field in the output

      • setUpdateFields

        public void setUpdateFields​(String[] updateFields)
        Set the names of the fields that will be updated. Includes all non key fields by default.
        Parameters:
        updateFields - names of the fields that will be updated

      • getUpdateFields

        public String[] getUpdateFields()
        Get the names of the fields that will be updated.
        Returns:
        names of the fields that will be updated

      • 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