org.apache.ignite.internal.processors.odbc.jdbc

Class JdbcBulkLoadBatchRequest

java.lang.Object

org.apache.ignite.internal.processors.odbc.ClientListenerRequestNoId

org.apache.ignite.internal.processors.odbc.jdbc.JdbcRequest

org.apache.ignite.internal.processors.odbc.jdbc.JdbcBulkLoadBatchRequest

All Implemented Interfaces:

ClientListenerRequest, JdbcRawBinarylizable

public class JdbcBulkLoadBatchRequest
extends JdbcRequest

A JDBC request that sends a batch of a file to the server. Used when handling SqlBulkLoadCommand command.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CMD_CONTINUE Next batch comes in this request and there are more batches.
static int	CMD_FINISHED_EOF This is the final batch of the file and everything went well on the client side.
static int	CMD_FINISHED_ERROR This is the final batch from the client and there was an error on the client side, so terminate with error on the server side as well.
static int	CMD_UNKNOWN A sentinel to indicate that cmd field was not initialized.

Fields inherited from class org.apache.ignite.internal.processors.odbc.jdbc.JdbcRequest

BATCH_EXEC, BINARY_TYPE_GET, BINARY_TYPE_NAME_GET, BINARY_TYPE_NAME_PUT, BINARY_TYPE_PUT, CACHE_PARTITIONS, META_COLUMNS, META_INDEXES, META_PARAMS, META_PRIMARY_KEYS, META_SCHEMAS, META_TABLES, QRY_EXEC, QRY_META

Fields inherited from interface org.apache.ignite.internal.processors.odbc.ClientListenerRequest

HANDSHAKE

Constructor Summary

Constructors

Constructor and Description
JdbcBulkLoadBatchRequest() Creates the request with uninitialized parameters.
JdbcBulkLoadBatchRequest(long cursorId, int batchIdx, int cmd) Creates the request with specified parameters and zero-length data.
JdbcBulkLoadBatchRequest(long cursorId, int batchIdx, int cmd, @NotNull byte[] data) Creates the request with the specified parameters.

Method Summary

Modifier and Type	Method and Description
long	batchIdx() Returns the batch index.
int	cmd() Returns the command (see CMD_xxx constants for details).
long	cursorId() Returns the original cursor ID.
@NotNull byte[]	data() Returns the data.
void	readBinary(BinaryReaderExImpl reader, JdbcProtocolContext protoCtx) Reads fields from provided reader.
String	toString()
void	writeBinary(BinaryWriterExImpl writer, JdbcProtocolContext protoCtx) Writes fields to provided writer.

Methods inherited from class org.apache.ignite.internal.processors.odbc.jdbc.JdbcRequest

readRequest, readRequestId, readType, requestId, type

Methods inherited from class java.lang.Object

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

Field Detail

CMD_UNKNOWN

public static final int CMD_UNKNOWN

A sentinel to indicate that cmd field was not initialized.

See Also:

Constant Field Values

CMD_CONTINUE

public static final int CMD_CONTINUE

Next batch comes in this request and there are more batches.

See Also:

Constant Field Values

CMD_FINISHED_ERROR

public static final int CMD_FINISHED_ERROR

This is the final batch from the client and there was an error on the client side, so terminate with error on the server side as well.

See Also:

Constant Field Values

CMD_FINISHED_EOF

public static final int CMD_FINISHED_EOF

This is the final batch of the file and everything went well on the client side. Server may complete the request.

See Also:

Constant Field Values

Constructor Detail

JdbcBulkLoadBatchRequest

public JdbcBulkLoadBatchRequest()

Creates the request with uninitialized parameters.

JdbcBulkLoadBatchRequest

public JdbcBulkLoadBatchRequest(long cursorId,
                                int batchIdx,
                                int cmd)

Creates the request with specified parameters and zero-length data. Typically used with CMD_FINISHED_ERROR and CMD_FINISHED_EOF.

Parameters:

cursorId - The cursor ID from the JdbcBulkLoadAckResult.

batchIdx - Index of the current batch starting with 0.

cmd - The command (CMD_CONTINUE, CMD_FINISHED_EOF, or CMD_FINISHED_ERROR).

JdbcBulkLoadBatchRequest

public JdbcBulkLoadBatchRequest(long cursorId,
                                int batchIdx,
                                int cmd,
                                @NotNull
                                @NotNull byte[] data)

Creates the request with the specified parameters.

Parameters:

cursorId - The cursor ID from the JdbcBulkLoadAckResult.

batchIdx - Index of the current batch starting with 0.

cmd - The command (CMD_CONTINUE, CMD_FINISHED_EOF, or CMD_FINISHED_ERROR).

data - The data block (zero length is acceptable).

Method Detail

cursorId

public long cursorId()

Returns the original cursor ID.

Returns:

The original cursor ID.

batchIdx

public long batchIdx()

Returns the batch index.

Returns:

The batch index.

cmd

public int cmd()

Returns the command (see CMD_xxx constants for details).

Returns:

The command.

data

@NotNull
public @NotNull byte[] data()

Returns the data.

Returns:

data if data was not supplied

writeBinary

public void writeBinary(BinaryWriterExImpl writer,
                        JdbcProtocolContext protoCtx)
                 throws BinaryObjectException

Writes fields to provided writer.

Specified by:

writeBinary in interface JdbcRawBinarylizable

Overrides:

writeBinary in class JdbcRequest

Parameters:

writer - Binary object writer.

protoCtx - JDBC protocol context.

Throws:

BinaryObjectException - In case of error.

readBinary

public void readBinary(BinaryReaderExImpl reader,
                       JdbcProtocolContext protoCtx)
                throws BinaryObjectException

Reads fields from provided reader.

Specified by:

readBinary in interface JdbcRawBinarylizable

Overrides:

readBinary in class JdbcRequest

Parameters:

reader - Binary object reader.

protoCtx - JDBC protocol context.

Throws:

BinaryObjectException - In case of error.

toString

public String toString()

Overrides:

toString in class JdbcRequest