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

Class WriteToJDBC

java.lang.Object
com.pervasive.datarush.operators.AbstractLogicalOperator
com.pervasive.datarush.operators.CompositeOperator
com.pervasive.datarush.operators.io.jdbc.JDBCOperator
com.pervasive.datarush.operators.io.jdbc.AbstractWriteToJDBC
com.pervasive.datarush.operators.io.jdbc.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 Details

    • WriteToJDBC

      public WriteToJDBC()
      Default constructor.

    • WriteToJDBC

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

  • Method Details

    • 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