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 |
---|
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 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.