Package org.postgresql.core.v3

Class CopyOperationImpl

java.lang.Object

org.postgresql.core.v3.CopyOperationImpl

All Implemented Interfaces:

CopyOperation

Direct Known Subclasses:

CopyDualImpl, CopyInImpl, CopyOutImpl

public abstract class CopyOperationImpl
extends java.lang.Object
implements CopyOperation

Constructor Summary

Constructors

Constructor	Description
CopyOperationImpl()

Method Summary

Modifier and Type	Method	Description
void	cancelCopy()	Cancels this copy operation, discarding any exchanged data.
int	getFieldCount()
int	getFieldFormat(int field)
int	getFormat()
long	getHandledRowCount()	After successful end of copy, returns the number of database records handled in that operation.
protected QueryExecutorImpl	getQueryExecutor()
void	handleCommandStatus(java.lang.String status)
protected abstract void	handleCopydata(byte[] data)	Consume received copy data.
boolean	isActive()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CopyOperationImpl

public CopyOperationImpl()

Method Detail

getQueryExecutor

protected QueryExecutorImpl getQueryExecutor()

cancelCopy

public void cancelCopy()
                throws java.sql.SQLException

Description copied from interface: CopyOperation

Cancels this copy operation, discarding any exchanged data.

Specified by:

cancelCopy in interface CopyOperation

Throws:

java.sql.SQLException - if cancelling fails

getFieldCount

public int getFieldCount()

Specified by:

getFieldCount in interface CopyOperation

Returns:

number of fields in each row for this operation

getFieldFormat

public int getFieldFormat(int field)

Specified by:

getFieldFormat in interface CopyOperation

Parameters:

field - number of field (0..fieldCount()-1)

Returns:

format of requested field: 0 = textual, 1 = binary

getFormat

public int getFormat()

Specified by:

getFormat in interface CopyOperation

Returns:

overall format of each row: 0 = textual, 1 = binary

isActive

public boolean isActive()

Specified by:

isActive in interface CopyOperation

Returns:

is connection reserved for this Copy operation?

handleCommandStatus

public void handleCommandStatus(java.lang.String status)
                         throws PSQLException

Throws:

PSQLException

handleCopydata

protected abstract void handleCopydata(byte[] data)
                                throws PSQLException

Consume received copy data.

Parameters:

data - data that was receive by copy protocol

Throws:

PSQLException - if some internal problem occurs

getHandledRowCount

public long getHandledRowCount()

Description copied from interface: CopyOperation

After successful end of copy, returns the number of database records handled in that operation. Only implemented in PostgreSQL server version 8.2 and up. Otherwise, returns -1.

Specified by:

getHandledRowCount in interface CopyOperation

Returns:

number of handled rows or -1