Module datarush.library
Class AbstractWriteToJDBC.AbstractWriteHelper
java.lang.Object
com.pervasive.datarush.operators.io.jdbc.AbstractWriteToJDBC.AbstractWriteHelper
- Enclosing class:
- AbstractWriteToJDBC
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected PreparedStatementprotected final Connectionprotected final JDBCConnectorprotected com.pervasive.datarush.operators.io.jdbc.PreparedStatementConverter[]protected intprotected final ScalarInputField[]protected final RecordInputprotected final org.apache.logging.log4j.Loggerprotected final Stringprotected final intprotected final AbstractWriteToJDBC.SqlWritePropertiesprotected longprotected int -
Constructor Summary
ConstructorsConstructorDescriptionAbstractWriteHelper(JDBCConnector connector, RecordPort input, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties properties) -
Method Summary
-
Field Details
-
connector
-
partitionID
protected final int partitionID -
input
-
fields
-
logger
protected final org.apache.logging.log4j.Logger logger -
connection
-
onEveryRecordStatement
-
properties
-
batchStatement
-
converters
protected com.pervasive.datarush.operators.io.jdbc.PreparedStatementConverter[] converters -
recordCount
protected long recordCount -
recordsInBatch
protected int recordsInBatch -
errorCount
protected int errorCount
-
-
Constructor Details
-
AbstractWriteHelper
public AbstractWriteHelper(JDBCConnector connector, RecordPort input, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties properties)
-
-
Method Details
-
run
public void run() -
doRun
- Throws:
SQLException
-
doWork
- Throws:
SQLException
-
commitBatch
- Throws:
SQLException
-
addBatch
- Throws:
SQLException
-
pushBatch
protected void pushBatch(int[] status) -
finalBatch
- Throws:
SQLException
-