Class CopyToStatement (0.6.1)

Version 0.6.1

• 0.27.1 (latest)
• 0.27.0
• 0.26.0
• 0.25.0
• 0.24.0
• 0.23.1
• 0.22.1
• 0.21.0
• 0.20.0
• 0.19.1
• 0.18.4
• 0.17.0
• 0.16.0
• 0.15.0
• 0.14.1
• 0.9.0
• 0.8.0
• 0.7.0
• 0.6.1
• 0.5.1

public class CopyToStatement extends IntermediatePortalStatement

CopyStatement models a COPY table TO STDOUT statement. The same class is used both as an IntermediatePreparedStatement and IntermediatePortalStatement, as COPY does not support any statement parameters, which means that there is no difference between the two.

Inheritance

java.lang.Object > IntermediateStatement > IntermediatePreparedStatement > IntermediatePortalStatement > CopyToStatement

Inherited Members

IntermediatePortalStatement.describeAsync(BackendConnection)

IntermediatePortalStatement.getParameterFormatCode(int)

IntermediatePortalStatement.getResultFormatCode(int)

IntermediatePortalStatement.setParameterFormatCodes(List<Short>)

IntermediatePortalStatement.setResultFormatCodes(List<Short>)

IntermediatePreparedStatement.bind(String,byte[][],List<Short>,List<Short>)

IntermediatePreparedStatement.describe()

IntermediatePreparedStatement.executeAsync(BackendConnection)

IntermediatePreparedStatement.getParameterDataTypes()

IntermediatePreparedStatement.setParameterDataTypes(int[])

IntermediateStatement.close()

IntermediateStatement.containsResultSet()

IntermediateStatement.createDataRowResponse(ResultSet,ConnectionHandler.QueryMode)

IntermediateStatement.createResultPrefix(ResultSet)

IntermediateStatement.createResultSuffix()

IntermediateStatement.getCommand()

IntermediateStatement.getCommandTag()

IntermediateStatement.getConnection()

IntermediateStatement.getException()

IntermediateStatement.getSql()

IntermediateStatement.getStatement()

IntermediateStatement.getStatementResult()

IntermediateStatement.getStatementType()

IntermediateStatement.getUpdateCount()

IntermediateStatement.getUpdateCount(IntermediateStatement.ResultNotReadyBehavior)

IntermediateStatement.handleExecutionException(SpannerException)

IntermediateStatement.hasException()

IntermediateStatement.hasException(IntermediateStatement.ResultNotReadyBehavior)

IntermediateStatement.isBound()

IntermediateStatement.isExecuted()

IntermediateStatement.isHasMoreData()

IntermediateStatement.setFutureStatementResult(Future<StatementResult>)

IntermediateStatement.setHasMoreData(boolean)

IntermediateStatement.setStatementResult(StatementResult)

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Fields

COPY_BINARY_HEADER

public static final byte[] COPY_BINARY_HEADER

Field Value

Type	Description
byte[]

Constructors

CopyToStatement(ConnectionHandler connectionHandler, OptionsMetadata options, String name, CopyTreeParser.CopyOptions copyOptions)

public CopyToStatement(ConnectionHandler connectionHandler, OptionsMetadata options, String name, CopyTreeParser.CopyOptions copyOptions)

Parameters

Name	Description
connectionHandler	ConnectionHandler
options	OptionsMetadata
name	String
copyOptions	CopyTreeParser.CopyOptions

Methods

bind(String name, byte[][] parameters, List<Short> parameterFormatCodes, List<Short> resultFormatCodes)

public IntermediatePortalStatement bind(String name, byte[][] parameters, List<Short> parameterFormatCodes, List<Short> resultFormatCodes)

Bind this statement (that is to say, transform it into a portal by giving it the data items to complete the statement.

Parameters

Name	Description
name	String
parameters	byte[][]
parameterFormatCodes	List<Short>
resultFormatCodes	List<Short>

Returns

Type	Description
IntermediatePortalStatement

Overrides

IntermediatePreparedStatement.bind(String name, byte[][] parameters, List<Short> parameterFormatCodes, List<Short> resultFormatCodes)

containsResultSet()

public boolean containsResultSet()

Returns

Type	Description
boolean

Overrides

IntermediateStatement.containsResultSet()

createDataRowResponse(ResultSet resultSet, ConnectionHandler.QueryMode mode)

public CopyDataResponse createDataRowResponse(ResultSet resultSet, ConnectionHandler.QueryMode mode)

Parameters

Name	Description
resultSet	com.google.cloud.spanner.ResultSet
mode	ConnectionHandler.QueryMode

Returns

Type	Description
CopyDataResponse

Overrides

IntermediateStatement.createDataRowResponse(ResultSet resultSet, ConnectionHandler.QueryMode mode)

createResultPrefix(ResultSet resultSet)

public WireOutput[] createResultPrefix(ResultSet resultSet)

Parameter

Name	Description
resultSet	com.google.cloud.spanner.ResultSet

Returns

Type	Description
WireOutput[]

Overrides

IntermediateStatement.createResultPrefix(ResultSet resultSet)

createResultSuffix()

public WireOutput[] createResultSuffix()

Returns

Type	Description
WireOutput[]

Overrides

IntermediateStatement.createResultSuffix()

describeAsync(BackendConnection backendConnection)

public Future<DescribePortalMetadata> describeAsync(BackendConnection backendConnection)

Parameter

Name	Description
backendConnection	BackendConnection

Returns

Type	Description
Future<DescribePortalMetadata>

Overrides

IntermediatePortalStatement.describeAsync(BackendConnection backendConnection)

executeAsync(BackendConnection backendConnection)

public void executeAsync(BackendConnection backendConnection)

Parameter

Name	Description
backendConnection	BackendConnection

Overrides

IntermediatePreparedStatement.executeAsync(BackendConnection backendConnection)

getCommandTag()

public String getCommandTag()

Returns

Type	Description
String

Overrides

IntermediateStatement.getCommandTag()

getStatementType()

public AbstractStatementParser.StatementType getStatementType()

Returns

Type	Description
StatementType

Overrides

IntermediateStatement.getStatementType()