public class BatchResultHandler extends ResultHandlerBase
Modifier and Type | Field and Description |
---|---|
private java.util.List<java.util.List<Tuple>> |
allGeneratedRows |
private int |
committedRows |
private boolean |
expectGeneratedKeys |
private PgResultSet |
generatedKeys |
private PgResultSet |
latestGeneratedKeysRs |
private java.util.List<Tuple> |
latestGeneratedRows |
private long[] |
longUpdateCounts |
private ParameterList[] |
parameterLists |
private PgStatement |
pgStatement |
private Query[] |
queries |
private int |
resultIndex |
Constructor and Description |
---|
BatchResultHandler(PgStatement pgStatement,
Query[] queries,
ParameterList[] parameterLists,
boolean expectGeneratedKeys) |
Modifier and Type | Method and Description |
---|---|
java.sql.ResultSet |
getGeneratedKeys() |
long[] |
getLargeUpdateCount() |
int[] |
getUpdateCount() |
void |
handleCommandStatus(java.lang.String status,
long updateCount,
long insertOID)
Called when a query that did not return a resultset completes.
|
void |
handleCompletion()
Called before a QueryExecutor method returns.
|
void |
handleError(java.sql.SQLException newError)
Called when an error occurs.
|
void |
handleResultRows(Query fromQuery,
Field[] fields,
java.util.List<Tuple> tuples,
ResultCursor cursor)
Called when result rows are received from a query.
|
void |
handleWarning(java.sql.SQLWarning warning)
Called when a warning is emitted.
|
private boolean |
isAutoCommit() |
void |
secureProgress()
Callback for batch statements.
|
private long[] |
uncompressLongUpdateCount() |
private int[] |
uncompressUpdateCount() |
private void |
updateGeneratedKeys() |
getException, getWarning
private final PgStatement pgStatement
private int resultIndex
private final Query[] queries
private final long[] longUpdateCounts
private final ParameterList[] parameterLists
private final boolean expectGeneratedKeys
private PgResultSet generatedKeys
private int committedRows
private final java.util.List<java.util.List<Tuple>> allGeneratedRows
private java.util.List<Tuple> latestGeneratedRows
private PgResultSet latestGeneratedKeysRs
BatchResultHandler(PgStatement pgStatement, Query[] queries, ParameterList[] parameterLists, boolean expectGeneratedKeys)
public void handleResultRows(Query fromQuery, Field[] fields, java.util.List<Tuple> tuples, ResultCursor cursor)
ResultHandler
handleResultRows
in interface ResultHandler
handleResultRows
in class ResultHandlerBase
fromQuery
- the underlying query that generated these results; this may not be very
specific (e.g. it may be a query that includes multiple statements).fields
- column metadata for the resultset; might be null
if
Query.QUERY_NO_METADATA was specified.tuples
- the actual datacursor
- a cursor to use to fetch additional data; null
if no further results
are present.public void handleCommandStatus(java.lang.String status, long updateCount, long insertOID)
ResultHandler
handleCommandStatus
in interface ResultHandler
handleCommandStatus
in class ResultHandlerBase
status
- the command status string (e.g. "SELECT") returned by the backendupdateCount
- the number of rows affected by an INSERT, UPDATE, DELETE, FETCH, or MOVE
command; -1 if not available.insertOID
- for a single-row INSERT query, the OID of the newly inserted row; 0 if not
available.private boolean isAutoCommit()
public void secureProgress()
ResultHandler
secureProgress
in interface ResultHandler
secureProgress
in class ResultHandlerBase
private void updateGeneratedKeys()
public void handleWarning(java.sql.SQLWarning warning)
ResultHandler
handleWarning
in interface ResultHandler
handleWarning
in class ResultHandlerBase
warning
- the warning that occurred.public void handleError(java.sql.SQLException newError)
ResultHandler
handleError
in interface ResultHandler
handleError
in class ResultHandlerBase
newError
- the error that occurredpublic void handleCompletion() throws java.sql.SQLException
ResultHandler
handleCompletion
in interface ResultHandler
handleCompletion
in class ResultHandlerBase
java.sql.SQLException
- if the handler wishes the original method to throw an exception.public java.sql.ResultSet getGeneratedKeys()
private int[] uncompressUpdateCount()
public int[] getUpdateCount()
private long[] uncompressLongUpdateCount()
public long[] getLargeUpdateCount()