Uses of Interface
com.mysql.cj.protocol.Message

Packages that use Message

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

Uses of Message in com.mysql.cj

Classes in com.mysql.cj with type parameters of type Message

Modifier and Type	Interface and Description
interface	MessageBuilder<M extends Message>

Fields in com.mysql.cj with type parameters of type Message

Modifier and Type	Field and Description
protected MessageBuilder<? extends Message>	CoreSession.messageBuilder
protected Protocol<? extends Message>	CoreSession.protocol

Methods in com.mysql.cj with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message> M	PreparedQuery.fillSendPacket(QueryBindings bindings)
<M extends Message> M	ServerPreparedQuery.fillSendPacket(QueryBindings bindings)
<M extends Message> M	ClientPreparedQuery.fillSendPacket(QueryBindings bindings)
<M extends Message> MessageBuilder<M>	Session.getMessageBuilder()
<M extends Message> MessageBuilder<M>	CoreSession.getMessageBuilder()
<T extends Resultset,M extends Message> ProtocolEntityFactory<T,M>	Query.getResultSetFactory()
<T extends Resultset,M extends Message> ProtocolEntityFactory<T,M>	AbstractQuery.getResultSetFactory()
<M extends Message> M	NoSubInterceptorWrapper.postProcess(M queryPacket, M originalResponsePacket)
<M extends Message> M	NoSubInterceptorWrapper.preProcess(M queryPacket)
default <M extends Message,R,RES> 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> 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> R	Session.query(M message, ResultBuilder<R> resultBuilder) Synchronously query database.
<M extends Message,R extends QueryResult> R	MysqlxSession.query(M message, ResultBuilder<R> resultBuilder)
default <M extends Message,R extends QueryResult> java.util.concurrent.CompletableFuture<R>	Session.queryAsync(M message, ResultBuilder<R> resultBuilder) Asynchronously query database.
<M extends Message,R extends QueryResult> java.util.concurrent.CompletableFuture<R>	MysqlxSession.queryAsync(M message, ResultBuilder<R> resultBuilder)

Methods in com.mysql.cj with parameters of type Message

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)

Uses of Message in com.mysql.cj.interceptors

Methods in com.mysql.cj.interceptors with type parameters of type Message

Modifier and Type	Method and Description
default <M extends Message> M	QueryInterceptor.postProcess(M queryPacket, M originalResponsePacket) Called after the given query packet has been sent to the server for processing.
default <M extends Message> M	QueryInterceptor.preProcess(M queryPacket) Called before the given query packet is going to be sent to the server for processing.

Uses of Message in com.mysql.cj.jdbc

Methods in com.mysql.cj.jdbc with type parameters of type Message

Modifier and Type	Method and Description
protected <M extends Message> ResultSetInternalMethods	ClientPreparedStatement.executeInternal(int maxRowsToRetrieve, M sendPacket, boolean createStreamingResultSet, boolean queryIsSelectOnly, ColumnDefinition metadata, boolean isBatch) Actually execute the prepared statement.
protected <M extends Message> ResultSetInternalMethods	ServerPreparedStatement.executeInternal(int maxRowsToRetrieve, M sendPacket, boolean createStreamingResultSet, boolean queryIsSelectOnly, ColumnDefinition metadata, boolean isBatch)
<T extends Resultset,M extends Message> ProtocolEntityFactory<T,M>	StatementImpl.getResultSetFactory()

Uses of Message in com.mysql.cj.protocol

Classes in com.mysql.cj.protocol with type parameters of type Message

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>

Methods in com.mysql.cj.protocol with parameters of type 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.

Uses of Message in com.mysql.cj.protocol.a

Classes in com.mysql.cj.protocol.a that implement Message

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.

Fields in com.mysql.cj.protocol.a with type parameters of type Message

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

Methods in com.mysql.cj.protocol.a with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message> M	NativeProtocol.invokeQueryInterceptorsPost(M queryPacket, M originalResponsePacket, boolean forceExecute)
<M extends Message> M	NativeProtocol.invokeQueryInterceptorsPre(M queryPacket, boolean forceExecute)

Methods in com.mysql.cj.protocol.a with parameters of type Message

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)

Uses of Message in com.mysql.cj.protocol.x

Methods in com.mysql.cj.protocol.x with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message,R extends QueryResult> R	XProtocol.query(M message, ResultBuilder<R> resultBuilder)
<M extends Message,R extends QueryResult> java.util.concurrent.CompletableFuture<R>	XProtocol.queryAsync(M message, ResultBuilder<R> resultBuilder)

Methods in com.mysql.cj.protocol.x with parameters of type Message

Modifier and Type	Method and Description
void	XProtocol.send(Message message, int packetLen)
XMessage	XProtocol.sendCommand(Message queryPacket, boolean skipCheck, int timeoutMillis)

Uses of Message in testsuite.regression

Methods in testsuite.regression with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message> M	CharsetRegressionTest.TestBug64205QueryInterceptor.postProcess(M queryPacket, M originalResponsePacket)
<M extends Message> M	CharsetRegressionTest.Bug73663QueryInterceptor.preProcess(M queryPacket)
<M extends Message> M	CharsetRegressionTest.TestSetNamesQueryInterceptor.preProcess(M queryPacket)
<M extends Message> M	CharsetRegressionTest.Bug71038QueryInterceptor.preProcess(M queryPacket)
<M extends Message> M	CharsetRegressionTest.Bug95139QueryInterceptor.preProcess(M queryPacket)
<M extends Message> M	ConnectionRegressionTest.Bug88227QueryInterceptor.preProcess(M queryPacket)
<M extends Message> M	ConnectionRegressionTest.Bug29329326QueryInterceptor.preProcess(M queryPacket)