public final class TableSimpleStatementExecutor extends Object implements JdbcBatchStatementExecutor<RowData>
JdbcBatchStatementExecutor
that simply adds the records into batches of PreparedStatement
and doesn't buffer records in memory. Only used in Table/SQL API.Constructor and Description |
---|
TableSimpleStatementExecutor(StatementFactory stmtFactory,
JdbcRowConverter converter)
Keep in mind object reuse: if it's on then key extractor may be required to return new
object.
|
Modifier and Type | Method and Description |
---|---|
void |
addToBatch(RowData record) |
void |
closeStatements()
Close JDBC related statements.
|
void |
executeBatch()
Submits a batch of commands to the database for execution.
|
void |
prepareStatements(Connection connection)
Create statements from connection.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
keyed, simple
public TableSimpleStatementExecutor(StatementFactory stmtFactory, JdbcRowConverter converter)
public void prepareStatements(Connection connection) throws SQLException
JdbcBatchStatementExecutor
prepareStatements
in interface JdbcBatchStatementExecutor<RowData>
SQLException
public void addToBatch(RowData record) throws SQLException
addToBatch
in interface JdbcBatchStatementExecutor<RowData>
SQLException
public void executeBatch() throws SQLException
JdbcBatchStatementExecutor
executeBatch
in interface JdbcBatchStatementExecutor<RowData>
SQLException
public void closeStatements() throws SQLException
JdbcBatchStatementExecutor
closeStatements
in interface JdbcBatchStatementExecutor<RowData>
SQLException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.