Uses of Class
com.mysql.cj.protocol.x.XMessage

Packages that use XMessage

Package	Description
com.mysql.cj.protocol.x
com.mysql.cj.xdevapi	Java classes for X DevAPI support.

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

Fields in com.mysql.cj.protocol.x with type parameters of type XMessage

Modifier and Type	Field and Description
(package private) java.util.concurrent.BlockingQueue<MessageListener<XMessage>>	SyncMessageReader.messageListenerQueue Queue of MessageListeners waiting to process messages.
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
private MessageReader<XMessageHeader,XMessage>	XProtocol.reader
private MessageSender<XMessage>	XProtocol.sender

Methods in com.mysql.cj.protocol.x that return XMessage

Modifier and Type	Method and Description
XMessage	XMessage.addNotices(java.util.List<Notice> n)
XMessage	XMessageBuilder.buildCapabilitiesGet()
XMessage	XMessageBuilder.buildCapabilitiesSet(java.util.Map<java.lang.String,java.lang.Object> keyValuePair)
XMessage	XMessageBuilder.buildClose()
XMessage	XMessageBuilder.buildComQuery(XMessage sharedPacket, Session sess, PreparedQuery preparedQuery, QueryBindings bindings, java.lang.String characterEncoding)
XMessage	XMessageBuilder.buildCreateCollection(java.lang.String schemaName, java.lang.String collectionName)
XMessage	XMessageBuilder.buildCreateCollection(java.lang.String schemaName, java.lang.String collectionName, Schema.CreateCollectionOptions options)
XMessage	XMessageBuilder.buildCreateCollectionIndex(java.lang.String schemaName, java.lang.String collectionName, CreateIndexParams params)
XMessage	XMessageBuilder.buildDelete(FilterParams filterParams) Build an XMessage for a non-prepared delete operation.
XMessage	XMessageBuilder.buildDisableNotices(java.lang.String... notices)
XMessage	XMessageBuilder.buildDocInsert(java.lang.String schemaName, java.lang.String collectionName, java.util.List<java.lang.String> json, boolean upsert) Build an XMessage for a non-prepared doc insert operation.
XMessage	XMessageBuilder.buildDocUpdate(FilterParams filterParams, java.util.List<UpdateSpec> updates) Build an XMessage for a non-prepared doc update operation.
XMessage	XMessageBuilder.buildDropCollection(java.lang.String schemaName, java.lang.String collectionName)
XMessage	XMessageBuilder.buildDropCollectionIndex(java.lang.String schemaName, java.lang.String collectionName, java.lang.String indexName)
XMessage	XMessageBuilder.buildEnableNotices(java.lang.String... notices)
XMessage	XMessageBuilder.buildExpectOpen()
XMessage	XMessageBuilder.buildExternalAuthStart(java.lang.String database)
XMessage	XMessageBuilder.buildFind(FilterParams filterParams) Build an XMessage for a non-prepared find operation.
XMessage	XMessageBuilder.buildListNotices() List the notices the server allows subscribing to.
XMessage	XMessageBuilder.buildListObjects(java.lang.String schemaName, java.lang.String pattern) List the objects in the given schema.
XMessage	XMessageBuilder.buildModifyCollectionOptions(java.lang.String schemaName, java.lang.String collectionName, Schema.ModifyCollectionOptions options)
XMessage	XMessageBuilder.buildMysql41AuthContinue(java.lang.String user, java.lang.String password, byte[] salt, java.lang.String database)
XMessage	XMessageBuilder.buildMysql41AuthStart()
XMessage	XMessageBuilder.buildPlainAuthStart(java.lang.String user, java.lang.String password, java.lang.String database)
XMessage	XMessageBuilder.buildPrepareDeallocate(int preparedStatementId) Build an XMessage for deallocating a prepared statement.
XMessage	XMessageBuilder.buildPrepareDelete(int preparedStatementId, FilterParams filterParams) Build an XMessage for a prepared delete operation.
XMessage	XMessageBuilder.buildPrepareDocUpdate(int preparedStatementId, FilterParams filterParams, java.util.List<UpdateSpec> updates) Build an XMessage for a prepared doc update operation.
XMessage	XMessageBuilder.buildPrepareExecute(int preparedStatementId, FilterParams filterParams) Build an XMessage for executing a prepared statement with the given filters.
XMessage	XMessageBuilder.buildPrepareFind(int preparedStatementId, FilterParams filterParams) Build an XMessage for a prepared find operation.
XMessage	XMessageBuilder.buildPrepareRowUpdate(int preparedStatementId, FilterParams filterParams, UpdateParams updateParams) Build an XMessage for a prepared row update operation.
XMessage	XMessageBuilder.buildPrepareSqlStatement(int preparedStatementId, java.lang.String statement) Build a Prepare message for a SQL statement.
XMessage	XMessageBuilder.buildRowInsert(java.lang.String schemaName, java.lang.String tableName, InsertParams insertParams) Build an XMessage for a non-prepared row insert operation.
XMessage	XMessageBuilder.buildRowUpdate(FilterParams filterParams, UpdateParams updateParams) Build an XMessage for a non-prepared row update operation.
XMessage	XMessageBuilder.buildSessionResetAndClose()
XMessage	XMessageBuilder.buildSessionResetKeepOpen()
XMessage	XMessageBuilder.buildSha256MemoryAuthContinue(java.lang.String user, java.lang.String password, byte[] nonce, java.lang.String database)
XMessage	XMessageBuilder.buildSha256MemoryAuthStart()
XMessage	XMessageBuilder.buildSqlStatement(java.lang.String statement) Build a StmtExecute message for a SQL statement.
XMessage	XMessageBuilder.buildSqlStatement(java.lang.String statement, java.util.List<java.lang.Object> args) Build a StmtExecute message for a SQL statement.
XMessage	XProtocol.checkErrorMessage()
XMessage	SyncMessageReader.readMessage(java.util.Optional<XMessage> reuse, int expectedType)
XMessage	SyncMessageReader.readMessage(java.util.Optional<XMessage> reuse, XMessageHeader hdr)
XMessage	XProtocol.readMessage(XMessage reuse)
XMessage	XProtocol.sendCommand(Message queryPacket, boolean skipCheck, int timeoutMillis)

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

Modifier and Type	Method and Description
XMessage	XMessageBuilder.buildComQuery(XMessage sharedPacket, Session sess, PreparedQuery preparedQuery, QueryBindings bindings, java.lang.String characterEncoding)
FetchDoneEntity	FetchDoneEntityFactory.createFromMessage(XMessage message)
XProtocolRow	XProtocolRowFactory.createFromMessage(XMessage message)
FetchDoneMoreResults	FetchDoneMoreResultsFactory.createFromMessage(XMessage message)
Field	FieldFactory.createFromMessage(XMessage message)
Notice	NoticeFactory.createFromMessage(XMessage message)
Ok	OkFactory.createFromMessage(XMessage message)
StatementExecuteOk	StatementExecuteOkFactory.createFromMessage(XMessage message)
static Notice	Notice.getInstance(XMessage message)
boolean	ResultMessageListener.processMessage(XMessage message)
<T extends ProtocolEntity> T	XProtocol.read(java.lang.Class<Resultset> requiredClass, int maxRows, boolean streamResults, XMessage resultPacket, boolean isBinaryEncoded, ColumnDefinition metadata, ProtocolEntityFactory<T,XMessage> protocolEntityFactory)
XMessage	XProtocol.readMessage(XMessage reuse)
void	SyncMessageSender.send(XMessage message)
java.util.concurrent.CompletableFuture<?>	SyncMessageSender.send(XMessage message, java.util.concurrent.CompletableFuture<?> future, java.lang.Runnable callback)

Method parameters in com.mysql.cj.protocol.x with type arguments of type XMessage

Modifier and Type	Method and Description
void	XAuthenticationProvider.init(Protocol<XMessage> prot, PropertySet propertySet, ExceptionInterceptor exceptionInterceptor)
void	SyncMessageReader.pushMessageListener(MessageListener<XMessage> listener)
<T extends ProtocolEntity> T	XProtocol.read(java.lang.Class<Resultset> requiredClass, int maxRows, boolean streamResults, XMessage resultPacket, boolean isBinaryEncoded, ColumnDefinition metadata, ProtocolEntityFactory<T,XMessage> protocolEntityFactory)
<T extends ProtocolEntity> T	XProtocol.read(java.lang.Class<T> requiredClass, ProtocolEntityFactory<T,XMessage> protocolEntityFactory)
XMessage	SyncMessageReader.readMessage(java.util.Optional<XMessage> reuse, int expectedType)
XMessage	SyncMessageReader.readMessage(java.util.Optional<XMessage> reuse, XMessageHeader hdr)

Constructor parameters in com.mysql.cj.protocol.x with type arguments of type XMessage

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)

Uses of XMessage in com.mysql.cj.xdevapi

Fields in com.mysql.cj.xdevapi with type parameters of type XMessage

Modifier and Type	Field and Description
protected ProtocolEntityFactory<T,XMessage>	AbstractDataResult.rowToData

Methods in com.mysql.cj.xdevapi that return XMessage

Modifier and Type	Method and Description
protected abstract XMessage	PreparableStatement.getPrepareStatementXMessage() Returns the XMessage needed to prepare this statement.
protected XMessage	FindStatementImpl.getPrepareStatementXMessage()
protected XMessage	DeleteStatementImpl.getPrepareStatementXMessage()
protected XMessage	UpdateStatementImpl.getPrepareStatementXMessage()
protected XMessage	ModifyStatementImpl.getPrepareStatementXMessage()
protected XMessage	SelectStatementImpl.getPrepareStatementXMessage()
protected XMessage	RemoveStatementImpl.getPrepareStatementXMessage()

Constructor parameters in com.mysql.cj.xdevapi with type arguments of type XMessage

Constructor and Description
AbstractDataResult(RowList rows, java.util.function.Supplier<ProtocolEntity> completer, ProtocolEntityFactory<T,XMessage> rowToData) Constructor.