com.mysql.cj.protocol.a

Class BinaryRowFactory

java.lang.Object

com.mysql.cj.protocol.a.AbstractRowFactory

com.mysql.cj.protocol.a.BinaryRowFactory

All Implemented Interfaces:

ProtocolEntityFactory<ResultsetRow,NativePacketPayload>

public class BinaryRowFactory
extends AbstractRowFactory
implements ProtocolEntityFactory<ResultsetRow,NativePacketPayload>

Handle binary-encoded data for server-side PreparedStatements

Field Summary

Fields inherited from class com.mysql.cj.protocol.a.AbstractRowFactory

canReuseRowPacketForBufferRow, columnDefinition, exceptionInterceptor, resultSetConcurrency, useBufferRowSizeThreshold, valueDecoder

Constructor Summary

Constructors

Constructor and Description
BinaryRowFactory(NativeProtocol protocol, ColumnDefinition columnDefinition, Resultset.Concurrency resultSetConcurrency, boolean canReuseRowPacketForBufferRow)

Method Summary

Modifier and Type	Method and Description
boolean	canReuseRowPacketForBufferRow()
ResultsetRow	createFromMessage(NativePacketPayload rowPacket) Create ProtocolEntity of type T from protocol message.
private void	extractNativeEncodedColumn(NativePacketPayload binaryData, Field[] fields, int columnIndex, byte[][] unpackedRowData) Copy the raw result bytes from the
private ResultsetRow	unpackBinaryResultSetRow(Field[] fields, NativePacketPayload binaryData) Un-packs binary-encoded result set data for one row

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mysql.cj.protocol.ProtocolEntityFactory

createFromProtocolEntity, getFetchSize, getResultSetConcurrency, getResultSetType

Constructor Detail

BinaryRowFactory

public BinaryRowFactory(NativeProtocol protocol,
                        ColumnDefinition columnDefinition,
                        Resultset.Concurrency resultSetConcurrency,
                        boolean canReuseRowPacketForBufferRow)

Method Detail

createFromMessage

public ResultsetRow createFromMessage(NativePacketPayload rowPacket)

Description copied from interface: ProtocolEntityFactory

Create ProtocolEntity of type T from protocol message.

Specified by:

createFromMessage in interface ProtocolEntityFactory<ResultsetRow,NativePacketPayload>

Parameters:

rowPacket - Message instance

Returns:

T

canReuseRowPacketForBufferRow

public boolean canReuseRowPacketForBufferRow()

Overrides:

canReuseRowPacketForBufferRow in class AbstractRowFactory

unpackBinaryResultSetRow

private final ResultsetRow unpackBinaryResultSetRow(Field[] fields,
                                                    NativePacketPayload binaryData)

Un-packs binary-encoded result set data for one row

Parameters:

fields - Fields array

binaryData - data

Returns:

byte[][]

extractNativeEncodedColumn

private final void extractNativeEncodedColumn(NativePacketPayload binaryData,
                                              Field[] fields,
                                              int columnIndex,
                                              byte[][] unpackedRowData)

Copy the raw result bytes from the

Parameters:

binaryData - packet to the

fields - Fields array

columnIndex - column index

unpackedRowData - byte array.