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

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int[]	fieldFormats
(package private) long	handledRowCount
(package private) QueryExecutorImpl	queryExecutor
(package private) int	rowFormat

Constructor Summary

Constructors

Constructor and Description
CopyOperationImpl()

Method Summary

Modifier and Type	Method and 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.
void	handleCommandStatus(java.lang.String status)
protected abstract void	handleCopydata(byte[] data) Consume received copy data.
(package private) void	init(QueryExecutorImpl q, int fmt, int[] fmts)
boolean	isActive()

Methods inherited from class java.lang.Object

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

Field Detail

queryExecutor

QueryExecutorImpl queryExecutor

rowFormat

int rowFormat

fieldFormats

int[] fieldFormats

handledRowCount

long handledRowCount

Constructor Detail

CopyOperationImpl

public CopyOperationImpl()

Method Detail

init

void init(QueryExecutorImpl q,
          int fmt,
          int[] fmts)

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