クラス CopyOutImpl
- すべての実装されたインタフェース:
CopyOperation
,CopyOut
Anticipated flow of a COPY TO STDOUT operation:
CopyManager.copyOut() ->QueryExecutor.startCopy() - sends given query to server ->processCopyResults(): - receives CopyOutResponse from Server - creates new CopyOutImpl ->initCopy(): - receives copy metadata from server ->CopyOutImpl.init() ->lock() connection for this operation - if query fails an exception is thrown - if query returns wrong CopyOperation, copyOut() cancels it before throwing exception <-returned: new CopyOutImpl holding lock on connection repeat CopyOut.readFromCopy() until null ->CopyOutImpl.readFromCopy() ->QueryExecutorImpl.readFromCopy() ->processCopyResults() - on copydata row from server ->CopyOutImpl.handleCopydata() stores reference to byte array - on CopyDone, CommandComplete, ReadyForQuery ->unlock() connection for use by other operations <-returned: byte array of data received from server or null at end.
-
コンストラクタの概要
コンストラクタ -
メソッドの概要
修飾子とタイプメソッド説明protected void
handleCopydata
(byte[] data) Consume received copy data.byte @Nullable []
Blocks wait for a row of data to be received from server on an active copy operation.byte @Nullable []
readFromCopy
(boolean block) Wait for a row of data to be received from server on an active copy operation.クラスから継承されたメソッド org.postgresql.core.v3.CopyOperationImpl
cancelCopy, getFieldCount, getFieldFormat, getFormat, getHandledRowCount, getQueryExecutor, handleCommandStatus, isActive
クラスから継承されたメソッド java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
インタフェースから継承されたメソッド org.postgresql.copy.CopyOperation
cancelCopy, getFieldCount, getFieldFormat, getFormat, getHandledRowCount, isActive
-
コンストラクタの詳細
-
CopyOutImpl
public CopyOutImpl()
-
-
メソッドの詳細
-
readFromCopy
インタフェースからコピーされた説明:CopyOut
Blocks wait for a row of data to be received from server on an active copy operation.- 定義:
readFromCopy
インタフェース内CopyOut
- 戻り値:
- byte array received from server, null if server complete copy operation
- 例外:
SQLException
- if something goes wrong for example socket timeout
-
readFromCopy
インタフェースからコピーされた説明:CopyOut
Wait for a row of data to be received from server on an active copy operation.- 定義:
readFromCopy
インタフェース内CopyOut
- パラメータ:
block
-true
if need wait data from server otherwisefalse
and will read pending message from server- 戻り値:
- byte array received from server, if pending message from server absent and use no blocking mode return null
- 例外:
SQLException
- if something goes wrong for example socket timeout
-
handleCopydata
protected void handleCopydata(byte[] data) クラスからコピーされた説明:CopyOperationImpl
Consume received copy data.- 定義:
handleCopydata
クラス内CopyOperationImpl
- パラメータ:
data
- data that was receive by copy protocol
-