Modifier and Type | Method and Description |
---|---|
static AbstractResultPacket |
ReadResultPacketFactory.createResultPacket(ReadPacketFetcher packetFetcher)
Initialize a result stream according to first stream byte.
|
Constructor and Description |
---|
ReadInitialConnectPacket(ReadPacketFetcher packetFetcher)
Read database initial stream.
|
Modifier and Type | Method and Description |
---|---|
void |
BinaryRowPacket.appendPacketIfNeeded(Reader reader,
ReadPacketFetcher packetFetcher)
Fetch stream to retrieve data.
|
void |
BinaryRowPacket.appendPacketIfNeeded(Reader reader,
ReadPacketFetcher packetFetcher,
long encLength)
Fetch stream to retrieve data.
|
ValueObject[] |
TextRowPacket.getRow(ReadPacketFetcher packetFetcher,
ByteBuffer buffer)
Read text row stream.
|
ValueObject[] |
RowPacket.getRow(ReadPacketFetcher packetFetcher,
ByteBuffer buffer) |
ValueObject[] |
BinaryRowPacket.getRow(ReadPacketFetcher packetFetcher,
ByteBuffer buffer)
Get next row data.
|
Modifier and Type | Field and Description |
---|---|
protected ReadPacketFetcher |
AbstractConnectProtocol.packetFetcher |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractConnectProtocol.close(ReadPacketFetcher fetcher,
PacketOutputStream packetOutputStream,
Socket socket) |
Modifier and Type | Method and Description |
---|---|
static MariaSelectResultSet |
MariaSelectResultSet.createResult(Statement statement,
ResultSetPacket packet,
ReadPacketFetcher packetFetcher,
Protocol protocol,
boolean binaryProtocol,
int resultSetScrollType,
int fetchSize,
boolean canBeCallableResult)
Create streaming resultset.
|
Constructor and Description |
---|
MariaSelectResultSet(ColumnInformation[] columnInformation,
Statement statement,
Protocol protocol,
ReadPacketFetcher fetcher,
boolean binaryProtocol,
int resultSetScrollType,
int fetchSize,
boolean callableResult)
Create Streaming resultset.
|
Copyright © 2016. All rights reserved.