void |
QueryExecutorImpl.cancelCopy(CopyOperationImpl op) |
Finishes a copy operation and unlocks connection discarding any exchanged data.
|
long |
QueryExecutorImpl.endCopy(CopyOperationImpl op) |
Finishes writing to copy and unlocks connection.
|
void |
QueryExecutorImpl.flushCopy(CopyOperationImpl op) |
|
private void |
QueryExecutorImpl.initCopy(CopyOperationImpl op) |
Locks connection and calls initializer for a new CopyOperation Called via startCopy ->
processCopyResults.
|
(package private) CopyOperationImpl |
QueryExecutorImpl.processCopyResults(CopyOperationImpl op,
boolean block) |
Handles copy sub protocol responses from server.
|
(package private) void |
QueryExecutorImpl.readFromCopy(CopyOperationImpl op,
boolean block) |
Wait for a row of data to be received from server on an active copy operation
Connection gets unlocked by processCopyResults() at end of operation.
|
void |
QueryExecutorImpl.writeToCopy(CopyOperationImpl op,
byte[] data,
int off,
int siz) |
Sends data during a live COPY IN operation.
|
void |
QueryExecutorImpl.writeToCopy(CopyOperationImpl op,
ByteStreamWriter from) |
Sends data during a live COPY IN operation.
|