public class BatchingPreparedStatementManagerImpl extends PreparedStatementManagerImpl
_conn, _dict, _exceptions, _log, _store
Constructor and Description |
---|
BatchingPreparedStatementManagerImpl(JDBCStore store,
java.sql.Connection conn,
int batchLimit)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addBatch(java.sql.PreparedStatement ps,
RowImpl row,
int count) |
protected void |
batchOrExecuteRow(RowImpl row) |
protected int[] |
executeBatch(java.sql.PreparedStatement ps) |
protected void |
flushAndUpdate(RowImpl row)
Flush the given row immediately or deferred the flush in batch.
|
protected void |
flushBatch()
flush all cached up statements to be executed as a single or batched
prepared statements.
|
java.util.List |
getBatchedRows() |
java.lang.String |
getBatchedSql() |
int |
getBatchLimit() |
boolean |
isBatchDisabled() |
void |
setBatchDisabled(boolean disableBatch) |
void |
setBatchLimit(int batchLimit) |
executeUpdate, flush, flush, flushInternal, getAutoAssignColNames, getAutoAssignColumns, getExceptions, getGeneratedKeys, getGeneratedKeys, logSQLWarnings, populateAutoAssignCols, populateAutoAssignCols, prepareStatement, prepareStatement, setObjectId, setObjectId
public BatchingPreparedStatementManagerImpl(JDBCStore store, java.sql.Connection conn, int batchLimit)
protected void flushAndUpdate(RowImpl row) throws java.sql.SQLException
flushAndUpdate
in class PreparedStatementManagerImpl
java.sql.SQLException
protected void batchOrExecuteRow(RowImpl row) throws java.sql.SQLException
java.sql.SQLException
protected void flushBatch() throws java.sql.SQLException
java.sql.SQLException
public boolean isBatchDisabled()
public void setBatchDisabled(boolean disableBatch)
public int getBatchLimit()
public void setBatchLimit(int batchLimit)
public java.util.List getBatchedRows()
public java.lang.String getBatchedSql()
protected void addBatch(java.sql.PreparedStatement ps, RowImpl row, int count) throws java.sql.SQLException
java.sql.SQLException
protected int[] executeBatch(java.sql.PreparedStatement ps) throws java.sql.SQLException
java.sql.SQLException