| Package | Description |
|---|---|
| com.mysql.cj | |
| com.mysql.cj.jdbc | |
| com.mysql.cj.jdbc.result | |
| com.mysql.cj.protocol | |
| com.mysql.cj.protocol.a | |
| com.mysql.cj.protocol.a.result | |
| com.mysql.cj.protocol.x | |
| com.mysql.cj.xdevapi |
Java classes for X DevAPI support.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset,M extends Message> |
Query.getResultSetFactory() |
<T extends Resultset,M extends Message> |
AbstractQuery.getResultSetFactory() |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset> |
NativeSession.execSQL(Query callingQuery,
java.lang.String query,
int maxRows,
NativePacketPayload packet,
boolean streamResults,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
ColumnDefinition cachedMetadata,
boolean isBatch)
Send a query to the server.
|
<T extends Resultset> |
ServerPreparedQuery.readExecuteResult(NativePacketPayload resultPacket,
int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory,
java.lang.String queryAsString) |
<T extends Resultset> |
ServerPreparedQuery.serverExecute(int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
<T extends Resultset> |
ServerPreparedQueryTestcaseGenerator.serverExecute(int maxRowsToRetrieve,
boolean createStreamingResultSet,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
| Modifier and Type | Method and Description |
|---|---|
<T extends Resultset,M extends Message> |
StatementImpl.getResultSetFactory() |
| Modifier and Type | Class and Description |
|---|---|
class |
ResultSetFactory |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
Protocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
M resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,M> protocolEntityFactory)
Read protocol entity.
|
<T extends ProtocolEntity> |
Protocol.read(java.lang.Class<T> requiredClass,
ProtocolEntityFactory<T,M> protocolEntityFactory) |
default T |
ProtocolEntityReader.read(int maxRows,
boolean streamResults,
M resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<T,M> protocolEntityFactory)
Reads one result set off of the wire, if the result is actually an
update count, creates an update-count only result set.
|
default T |
ProtocolEntityReader.read(ProtocolEntityFactory<T,M> sf) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractRowFactory |
class |
BinaryRowFactory
Handle binary-encoded data for server-side PreparedStatements
|
class |
ColumnDefinitionFactory |
class |
MergingColumnDefinitionFactory |
class |
ResultsetFactory |
class |
TextRowFactory |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
NativeProtocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> protocolEntityFactory) |
<T extends ProtocolEntity> |
NativeProtocol.read(java.lang.Class<T> requiredClass,
ProtocolEntityFactory<T,NativePacketPayload> protocolEntityFactory) |
Resultset |
BinaryResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
Resultset |
TextResultsetReader.read(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
ColumnDefinition metadata,
ProtocolEntityFactory<Resultset,NativePacketPayload> resultSetFactory) |
ColumnDefinition |
ColumnDefinitionReader.read(ProtocolEntityFactory<ColumnDefinition,NativePacketPayload> sf) |
ResultsetRow |
ResultsetRowReader.read(ProtocolEntityFactory<ResultsetRow,NativePacketPayload> sf)
Retrieve one row from the MySQL server.
|
<T extends Resultset> |
NativeProtocol.readAllResults(int maxRows,
boolean streamResults,
NativePacketPayload resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory) |
<T extends ProtocolEntity> |
NativeProtocol.readNextResultset(T currentProtocolEntity,
int maxRows,
boolean streamResults,
boolean isBinaryEncoded,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Read next result set from multi-result chain.
|
<T extends Resultset> |
NativeProtocol.sendQueryPacket(Query callingQuery,
NativePacketPayload queryPacket,
int maxRows,
boolean streamResults,
ColumnDefinition cachedMetadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Send a query stored in a packet to the server.
|
<T extends Resultset> |
NativeProtocol.sendQueryString(Query callingQuery,
java.lang.String query,
java.lang.String characterEncoding,
int maxRows,
boolean streamResults,
ColumnDefinition cachedMetadata,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Build a query packet from the given string and send it to the server.
|
| Modifier and Type | Field and Description |
|---|---|
private ProtocolEntityFactory<T,NativePacketPayload> |
ResultsetRowsStreaming.resultSetFactory |
protected ProtocolEntityFactory<ResultsetRow,NativePacketPayload> |
AbstractResultsetRows.rowFactory |
| Constructor and Description |
|---|
ResultsetRowsStreaming(NativeProtocol io,
ColumnDefinition columnDefinition,
boolean isBinaryEncoded,
ProtocolEntityFactory<T,NativePacketPayload> resultSetFactory)
Creates a new RowDataDynamic object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FetchDoneEntityFactory
Factory producing
FetchDoneEntity from protocol message. |
class |
FetchDoneMoreResultsFactory
Factory producing
FetchDoneMoreResults from protocol message. |
class |
FieldFactory
Factory producing
Field from protocol message. |
class |
NoticeFactory
Factory producing
Notice from protocol message. |
class |
OkFactory
Factory producing
Ok from protocol message. |
class |
StatementExecuteOkFactory
Factory producing
StatementExecuteOk from protocol message. |
class |
XProtocolRowFactory
Factory producing an
XProtocolRow from protocol message. |
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<java.lang.Class<? extends com.google.protobuf.GeneratedMessageV3>,ProtocolEntityFactory<? extends ProtocolEntity,XMessage>> |
XProtocol.messageToProtocolEntityFactory |
private java.util.Map<java.lang.Class<? extends com.google.protobuf.GeneratedMessageV3>,ProtocolEntityFactory<? extends ProtocolEntity,XMessage>> |
ResultMessageListener.messageToProtocolEntityFactory |
| Modifier and Type | Method and Description |
|---|---|
<T extends ProtocolEntity> |
XProtocol.read(java.lang.Class<Resultset> requiredClass,
int maxRows,
boolean streamResults,
XMessage resultPacket,
boolean isBinaryEncoded,
ColumnDefinition metadata,
ProtocolEntityFactory<T,XMessage> protocolEntityFactory) |
<T extends ProtocolEntity> |
XProtocol.read(java.lang.Class<T> requiredClass,
ProtocolEntityFactory<T,XMessage> protocolEntityFactory) |
| Constructor and Description |
|---|
ResultMessageListener(java.util.Map<java.lang.Class<? extends com.google.protobuf.GeneratedMessageV3>,ProtocolEntityFactory<? extends ProtocolEntity,XMessage>> messageToProtocolEntityFactory,
ResultBuilder<R> resultBuilder,
java.util.concurrent.CompletableFuture<R> future) |
| Modifier and Type | Class and Description |
|---|---|
class |
DbDocFactory
Create
DbDoc objects from internal row representation. |
class |
RowFactory
Create
Row objects from internal row representation. |
| Modifier and Type | Field and Description |
|---|---|
protected ProtocolEntityFactory<T,XMessage> |
AbstractDataResult.rowToData |
| Constructor and Description |
|---|
AbstractDataResult(RowList rows,
java.util.function.Supplier<ProtocolEntity> completer,
ProtocolEntityFactory<T,XMessage> rowToData)
Constructor.
|