protected abstract static class AbstractWriteToJDBC.AbstractWriteHelper extends Object
Modifier and Type | Field and Description |
---|---|
protected PreparedStatement |
batchStatement |
protected Connection |
connection |
protected JDBCConnector |
connector |
protected com.pervasive.datarush.operators.io.jdbc.PreparedStatementConverter[] |
converters |
protected int |
errorCount |
protected ScalarInputField[] |
fields |
protected RecordInput |
input |
protected org.apache.commons.logging.Log |
logger |
protected String |
onEveryRecordStatement |
protected int |
partitionID |
protected AbstractWriteToJDBC.SqlWriteProperties |
properties |
protected long |
recordCount |
protected int |
recordsInBatch |
Constructor and Description |
---|
AbstractWriteToJDBC.AbstractWriteHelper(JDBCConnector connector,
RecordPort input,
ExecutionContext ctx,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties properties) |
Modifier and Type | Method and Description |
---|---|
protected void |
addBatch() |
protected int[] |
commitBatch() |
protected void |
doRun() |
protected void |
doWork() |
protected void |
finalBatch() |
protected void |
pushBatch(int[] status) |
void |
run() |
protected final JDBCConnector connector
protected final int partitionID
protected final RecordInput input
protected final ScalarInputField[] fields
protected final org.apache.commons.logging.Log logger
protected final Connection connection
protected final String onEveryRecordStatement
protected final AbstractWriteToJDBC.SqlWriteProperties properties
protected PreparedStatement batchStatement
protected com.pervasive.datarush.operators.io.jdbc.PreparedStatementConverter[] converters
protected long recordCount
protected int recordsInBatch
protected int errorCount
public AbstractWriteToJDBC.AbstractWriteHelper(JDBCConnector connector, RecordPort input, ExecutionContext ctx, String onEveryRecordStatement, AbstractWriteToJDBC.SqlWriteProperties properties)
public void run()
protected void doRun() throws SQLException
SQLException
protected void doWork() throws SQLException
SQLException
protected int[] commitBatch() throws SQLException
SQLException
protected void addBatch() throws SQLException
SQLException
protected void pushBatch(int[] status)
protected void finalBatch() throws SQLException
SQLException
Copyright © 2016 Actian Corporation. All Rights Reserved.