| Package | Description |
|---|---|
| com.mysql.cj | |
| com.mysql.cj.interceptors | |
| com.mysql.cj.jdbc | |
| com.mysql.cj.protocol | |
| com.mysql.cj.protocol.a | |
| com.mysql.cj.protocol.x | |
| testsuite.regression |
| Modifier and Type | Interface and Description |
|---|---|
interface |
MessageBuilder<M extends Message> |
| Modifier and Type | Field and Description |
|---|---|
protected MessageBuilder<? extends Message> |
CoreSession.messageBuilder |
protected Protocol<? extends Message> |
CoreSession.protocol |
| Modifier and Type | Method and Description |
|---|---|
<M extends Message> |
PreparedQuery.fillSendPacket(QueryBindings bindings) |
<M extends Message> |
ServerPreparedQuery.fillSendPacket(QueryBindings bindings) |
<M extends Message> |
ClientPreparedQuery.fillSendPacket(QueryBindings bindings) |
<M extends Message> |
Session.getMessageBuilder() |
<M extends Message> |
CoreSession.getMessageBuilder() |
<T extends Resultset,M extends Message> |
Query.getResultSetFactory() |
<T extends Resultset,M extends Message> |
AbstractQuery.getResultSetFactory() |
<M extends Message> |
NoSubInterceptorWrapper.postProcess(M queryPacket,
M originalResponsePacket) |
<M extends Message> |
NoSubInterceptorWrapper.preProcess(M queryPacket) |
default <M extends Message,R,RES> |
Session.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector)
Synchronously query database with applying rows filtering and mapping.
|
<M extends Message,R,RES> |
MysqlxSession.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector) |
default <M extends Message,R extends QueryResult> |
Session.query(M message,
ResultBuilder<R> resultBuilder)
Synchronously query database.
|
<M extends Message,R extends QueryResult> |
MysqlxSession.query(M message,
ResultBuilder<R> resultBuilder) |
default <M extends Message,R extends QueryResult> |
Session.queryAsync(M message,
ResultBuilder<R> resultBuilder)
Asynchronously query database.
|
<M extends Message,R extends QueryResult> |
MysqlxSession.queryAsync(M message,
ResultBuilder<R> resultBuilder) |
| Modifier and Type | Method and Description |
|---|---|
void |
BindValue.writeAsBinary(Message intoMessage) |
void |
NativeQueryBindValue.writeAsBinary(Message intoMessage) |
void |
BindValue.writeAsQueryAttribute(Message intoMessage) |
void |
NativeQueryBindValue.writeAsQueryAttribute(Message intoMessage) |
void |
BindValue.writeAsText(Message intoMessage) |
void |
NativeQueryBindValue.writeAsText(Message intoMessage) |
| Modifier and Type | Method and Description |
|---|---|
default <M extends Message> |
QueryInterceptor.postProcess(M queryPacket,
M originalResponsePacket)
Called after the given query packet has been sent to the server for processing.
|
default <M extends Message> |
QueryInterceptor.preProcess(M queryPacket)
Called before the given query packet is going to be sent to the server for processing.
|
| Modifier and Type | Method and Description |
|---|---|
protected <M extends Message> |
ClientPreparedStatement.executeInternal(int maxRowsToRetrieve,
M sendPacket,
boolean createStreamingResultSet,
boolean queryIsSelectOnly,
ColumnDefinition metadata,
boolean isBatch)
Actually execute the prepared statement.
|
protected <M extends Message> |
ServerPreparedStatement.executeInternal(int maxRowsToRetrieve,
M sendPacket,
boolean createStreamingResultSet,
boolean queryIsSelectOnly,
ColumnDefinition metadata,
boolean isBatch) |
<T extends Resultset,M extends Message> |
StatementImpl.getResultSetFactory() |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractProtocol<M extends Message> |
interface |
AuthenticationPlugin<M extends Message>
Implementors of this interface can be installed via the "authenticationPlugins" configuration property.
|
interface |
AuthenticationProvider<M extends Message> |
interface |
MessageListener<M extends Message>
Sink for messages that are read asynchonously from the socket.
|
interface |
MessageReader<H extends MessageHeader,M extends Message> |
interface |
MessageSender<M extends Message>
This interface provides a facility for sending messages to server.
|
interface |
Protocol<M extends Message>
A protocol provides the facilities to communicate with a MySQL server.
|
interface |
ProtocolEntityFactory<T,M extends Message> |
interface |
ProtocolEntityReader<T extends ProtocolEntity,M extends Message> |
| Modifier and Type | Method and Description |
|---|---|
void |
ValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
ValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
ValueEncoder.encodeAsText(Message msg,
BindValue binding) |
void |
Protocol.send(Message message,
int packetLen) |
M |
Protocol.sendCommand(Message queryPacket,
boolean skipCheck,
int timeoutMillis)
Send a command to the MySQL server.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NativePacketPayload
PacketPayload is the content of a full single packet (independent from
on-wire splitting) communicated with the server.
|
| Modifier and Type | Field and Description |
|---|---|
protected java.util.Map<java.lang.Class<? extends ProtocolEntity>,ProtocolEntityReader<? extends ProtocolEntity,? extends Message>> |
NativeProtocol.PROTOCOL_ENTITY_CLASS_TO_BINARY_READER |
protected java.util.Map<java.lang.Class<? extends ProtocolEntity>,ProtocolEntityReader<? extends ProtocolEntity,? extends Message>> |
NativeProtocol.PROTOCOL_ENTITY_CLASS_TO_TEXT_READER |
| Modifier and Type | Method and Description |
|---|---|
<M extends Message> |
NativeProtocol.invokeQueryInterceptorsPost(M queryPacket,
M originalResponsePacket,
boolean forceExecute) |
<M extends Message> |
NativeProtocol.invokeQueryInterceptorsPre(M queryPacket,
boolean forceExecute) |
| Modifier and Type | Method and Description |
|---|---|
void |
LocalDateValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
NumberValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
NullValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
SqlTimestampValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
BooleanValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
InstantValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
ByteArrayValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
DurationValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
UtilCalendarValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
OffsetTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
InputStreamValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
ReaderValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
LocalDateTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
LocalTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
SqlTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
SqlDateValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
ZonedDateTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
OffsetDateTimeValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
StringValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
UtilDateValueEncoder.encodeAsBinary(Message msg,
BindValue binding) |
void |
LocalDateValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
AbstractValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
NumberValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
SqlTimestampValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
BooleanValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
InstantValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
DurationValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
UtilCalendarValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
OffsetTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
LocalDateTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
LocalTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
SqlTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
SqlDateValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
ZonedDateTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
OffsetDateTimeValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
StringValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
UtilDateValueEncoder.encodeAsQueryAttribute(Message msg,
BindValue binding) |
void |
AbstractValueEncoder.encodeAsText(Message msg,
BindValue binding) |
void |
InputStreamValueEncoder.encodeAsText(Message msg,
BindValue binding) |
void |
BlobValueEncoder.encodeAsText(Message msg,
BindValue binding) |
void |
NativeProtocol.send(Message packet,
int packetLen) |
NativePacketPayload |
NativeProtocol.sendCommand(Message queryPacket,
boolean skipCheck,
int timeoutMillis) |
protected void |
AbstractValueEncoder.writeDate(Message msg,
InternalDate d) |
protected void |
AbstractValueEncoder.writeDateTime(Message msg,
InternalTimestamp ts) |
void |
AbstractValueEncoder.writeDateTimeWithOffset(Message msg,
InternalTimestamp timestamp) |
protected void |
AbstractValueEncoder.writeTime(Message msg,
InternalTime time) |
| Modifier and Type | Method and Description |
|---|---|
<M extends Message,R extends QueryResult> |
XProtocol.query(M message,
ResultBuilder<R> resultBuilder) |
<M extends Message,R extends QueryResult> |
XProtocol.queryAsync(M message,
ResultBuilder<R> resultBuilder) |
| Modifier and Type | Method and Description |
|---|---|
void |
XProtocol.send(Message message,
int packetLen) |
XMessage |
XProtocol.sendCommand(Message queryPacket,
boolean skipCheck,
int timeoutMillis) |
| Modifier and Type | Method and Description |
|---|---|
<M extends Message> |
CharsetRegressionTest.TestBug64205QueryInterceptor.postProcess(M queryPacket,
M originalResponsePacket) |
<M extends Message> |
CharsetRegressionTest.Bug73663QueryInterceptor.preProcess(M queryPacket) |
<M extends Message> |
CharsetRegressionTest.TestSetNamesQueryInterceptor.preProcess(M queryPacket) |
<M extends Message> |
CharsetRegressionTest.Bug71038QueryInterceptor.preProcess(M queryPacket) |
<M extends Message> |
CharsetRegressionTest.Bug95139QueryInterceptor.preProcess(M queryPacket) |
<M extends Message> |
ConnectionRegressionTest.Bug88227QueryInterceptor.preProcess(M queryPacket) |
<M extends Message> |
ConnectionRegressionTest.Bug29329326QueryInterceptor.preProcess(M queryPacket) |