Top Fields Constructors Methods
com.mysql.cj.protocol.x

public Class XMessageBuilder

extends Object
implements MessageBuilder<XMessage>
Class Inheritance
All Implemented Interfaces
com.mysql.cj.MessageBuilder
Imports
java.security.DigestException, java.util.Arrays, .List, .Map, java.util.function.Consumer, java.util.stream.Collectors, javax.security.auth.callback.Callback, .CallbackHandler, .NameCallback, .PasswordCallback, .UnsupportedCallbackException, javax.security.sasl.Sasl, .SaslClient, .SaslException, com.google.protobuf.ByteString, com.mysql.cj.MessageBuilder, .Messages, .PreparedQuery, .Query, .QueryBindings, .Session, com.mysql.cj.exceptions.CJOperationNotSupportedException, .ExceptionFactory, com.mysql.cj.protocol.Security, com.mysql.cj.util.StringUtils, com.mysql.cj.x.protobuf.MysqlxConnection.Capabilities, .MysqlxConnection.CapabilitiesGet, .MysqlxConnection.CapabilitiesSet, .MysqlxConnection.Capability, .MysqlxCrud.Collection, .MysqlxCrud.Column, .MysqlxCrud.DataModel, .MysqlxCrud.Delete, .MysqlxCrud.Find, .MysqlxCrud.Find.RowLock, .MysqlxCrud.Find.RowLockOptions, .MysqlxCrud.Insert, .MysqlxCrud.Insert.TypedRow, .MysqlxCrud.Limit, .MysqlxCrud.LimitExpr, .MysqlxCrud.Order, .MysqlxCrud.Projection, .MysqlxCrud.Update, .MysqlxCrud.UpdateOperation, .MysqlxCrud.UpdateOperation.UpdateType, .MysqlxDatatypes, .MysqlxDatatypes.Any, .MysqlxDatatypes.Object.Builder, .MysqlxDatatypes.Object.ObjectField, .MysqlxDatatypes.Scalar, .MysqlxExpect, .MysqlxExpr.ColumnIdentifier, .MysqlxExpr.Expr, .MysqlxPrepare.Deallocate, .MysqlxPrepare.Execute, .MysqlxPrepare.Prepare, .MysqlxPrepare.Prepare.OneOfMessage, .MysqlxSession.AuthenticateContinue, .MysqlxSession.AuthenticateStart, .MysqlxSession.Close, .MysqlxSession.Reset, .MysqlxSql.StmtExecute, com.mysql.cj.xdevapi.CreateIndexParams, .CreateIndexParams.IndexField, .ExprUtil, .FilterParams, .InsertParams, .Schema.CreateCollectionOptions, .Schema.ModifyCollectionOptions, .UpdateParams, .UpdateSpec

Field Summary

Modifier and TypeField and Description
private static final String

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
private static void
applyFilterParams(FilterParams
the filter params to apply
filterParams
,
Consumer<List<MysqlxCrud.Order>>
the "builder.addAllOrder()" method reference
setOrder
,
Consumer<MysqlxCrud.Limit>
the "builder.setLimit()" method reference
setLimit
,
Consumer<MysqlxExpr.Expr>
the "builder.setCriteria()" method reference
setCriteria
,
Consumer<List<MysqlxDatatypes.Scalar>>
the "builder.addAllArgs()" method reference
setArgs
)

Apply the given filter params to the builder object (represented by the setter methods).

private static void
applyFilterParams(FilterParams
the filter params to apply
filterParams
,
Consumer<List<MysqlxCrud.Order>>
the "builder.addAllOrder()" method reference
setOrder
,
Consumer<MysqlxCrud.LimitExpr>
the "builder.setLimitExp()" method reference
setLimit
,
Consumer<MysqlxExpr.Expr>
the "builder.setCriteria()" method reference
setCriteria
)

Apply the given filter params to the builder object (represented by the setter methods) using the variant that takes a LimitExpr and no Args.

public XMessage
public XMessage
public XMessage
public XMessage
buildComQuery(XMessage sharedPacket, Session sess, String query, Query callingQuery, String characterEncoding)

Implements com.mysql.cj.MessageBuilder.buildComQuery.

public XMessage
buildComQuery(XMessage sharedPacket, Session sess, PreparedQuery preparedQuery, QueryBindings bindings, String characterEncoding)

Implements com.mysql.cj.MessageBuilder.buildComQuery.

public XMessage
buildCreateCollection(String schemaName, String collectionName, Schema.CreateCollectionOptions options)

public XMessage
buildCreateCollection(String schemaName, String collectionName)

public XMessage
buildCreateCollectionIndex(String schemaName, String collectionName, CreateIndexParams params)

public XMessage

Returns:

an XMessage instance
buildDelete
(FilterParams
the filter parameters
filterParams
)

Build an XMessage for a non-prepared delete operation.

public XMessage
public XMessage

Returns:

an XMessage instance
buildDocInsert
(String
the schema name
schemaName
,
String
the collection name
collectionName
,
List<String>
the documents to insert
json
,
boolean
Whether this is an upsert operation or not
upsert
)

Build an XMessage for a non-prepared doc insert operation.

public XMessage

Returns:

an XMessage instance
buildDocUpdate
(FilterParams
the filter parameters
filterParams
,
List<UpdateSpec>
the updates specifications to perform
updates
)

Build an XMessage for a non-prepared doc update operation.

public XMessage
buildDropCollection(String schemaName, String collectionName)

public XMessage
buildDropCollectionIndex(String schemaName, String collectionName, String indexName)

public XMessage
public XMessage
public XMessage
public XMessage

Returns:

an XMessage instance
buildFind
(FilterParams
the filter parameters
filterParams
)

Build an XMessage for a non-prepared find operation.

public XMessage

Returns:

XMessage
buildListNotices
()

List the notices the server allows subscribing to.

public XMessage

Returns:

XMessage
buildListObjects
(String
schema name
schemaName
,
String
object name pattern
pattern
)

List the objects in the given schema.

public XMessage
public XMessage
buildMysql41AuthContinue(String user, String password, byte[] salt, String database)

public XMessage
public XMessage
buildPlainAuthStart(String user, String password, String database)

public XMessage

Returns:

an XMessage instance
buildPrepareDeallocate
(int
the prepared statement id
preparedStatementId
)

Build an XMessage for deallocating a prepared statement.

public XMessage

Returns:

an XMessage instance
buildPrepareDelete
(int
the prepared statement id
preparedStatementId
,
FilterParams
the filter parameters
filterParams
)

Build an XMessage for a prepared delete operation.

public XMessage

Returns:

an XMessage instance
buildPrepareDocUpdate
(int
the prepared statement id
preparedStatementId
,
FilterParams
the filter parameters
filterParams
,
List<UpdateSpec>
the updates specifications to perform
updates
)

Build an XMessage for a prepared doc update operation.

public XMessage

Returns:

an XMessage instance
buildPrepareExecute
(int
the prepared statement id
preparedStatementId
,
FilterParams
the filter parameter values
filterParams
)

Build an XMessage for executing a prepared statement with the given filters.

public XMessage

Returns:

an XMessage instance
buildPrepareFind
(int
the prepared statement id
preparedStatementId
,
FilterParams
the filter parameters
filterParams
)

Build an XMessage for a prepared find operation.

public XMessage

Returns:

an XMessage instance
buildPrepareRowUpdate
(int
the prepared statement id
preparedStatementId
,
FilterParams
the filter parameters
filterParams
,
UpdateParams
the update parameters
updateParams
)

Build an XMessage for a prepared row update operation.

public XMessage

Returns:

XMessage wrapping StmtExecute
buildPrepareSqlStatement
(int
the prepared statement id
preparedStatementId
,
String
SQL statement string
statement
)

Build a Prepare message for a SQL statement.

public XMessage

Returns:

an XMessage instance
buildRowInsert
(String
the schema name
schemaName
,
String
the table name
tableName
,
InsertParams
the parameters to insert
insertParams
)

Build an XMessage for a non-prepared row insert operation.

public XMessage

Returns:

an XMessage instance
buildRowUpdate
(FilterParams
the filter parameters
filterParams
,
UpdateParams
the update parameters
updateParams
)

Build an XMessage for a non-prepared row update operation.

public XMessage
public XMessage
public XMessage
buildSha256MemoryAuthContinue(String user, String password, byte[] nonce, String database)

public XMessage
public XMessage

Returns:

XMessage wrapping StmtExecute
buildSqlStatement
(String
SQL statement string
statement
)

Implements com.mysql.cj.MessageBuilder.buildSqlStatement.

Build a StmtExecute message for a SQL statement.

public XMessage

Returns:

XMessage wrapping StmtExecute
buildSqlStatement
(String
SQL statement string
statement
,
List<Object>
list of Object arguments
args
)

Implements com.mysql.cj.MessageBuilder.buildSqlStatement.

Build a StmtExecute message for a SQL statement.

private MysqlxSql.StmtExecute

Returns:

StmtExecute
buildXpluginCommand
(XpluginStatementCommand
the xplugin command to send
command
,
MysqlxDatatypes.Any...
the arguments to the command
args
)

Build a StmtExecute message for an xplugin command.

private MysqlxCrud.Delete.Builder

Returns:

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Delete.Builder instance
commonDeleteBuilder
(FilterParams
the filter parameters
filterParams
)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Delete.Builder with common data for prepared and non-prepared executions.

private MysqlxCrud.Update.Builder

Returns:

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder instance
commonDocUpdateBuilder
(FilterParams
the filter parameters
filterParams
,
List<UpdateSpec>
the updates specifications to perform
updates
)

Initialize an com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder for collection data model with common data for prepared and non-prepared executions.

private MysqlxCrud.Find.Builder

Returns:

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Find.Builder instance
commonFindBuilder
(FilterParams
the filter parameters
filterParams
)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Find.Builder for collection data model with common data for prepared and non-prepared executions.

private MysqlxCrud.Insert.Builder

Returns:

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Insert.Builder instance
commonRowInsertBuilder
(String
the schema name
schemaName
,
String
the table name
tableName
,
InsertParams
the parameters to insert
insertParams
)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Insert.Builder for table data model with common data for prepared and non-prepared executions.

private MysqlxCrud.Update.Builder

Returns:

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder instance
commonRowUpdateBuilder
(FilterParams
the filter parameters
filterParams
,
UpdateParams
the update parameters
updateParams
)

Initialize an com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder for table data model with common data for prepared and non-prepared executions.

private MysqlxSql.StmtExecute.Builder
commonSqlStatementBuilder(String
the SQL statement
statement
)

Initialize a com.mysql.cj.x.protobuf.MysqlxSql.StmtExecute.Builder with common data for prepared and non-prepared executions.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

XPLUGIN_NAMESPACEback to summary
private static final String XPLUGIN_NAMESPACE

Constructor Detail

XMessageBuilderback to summary
public XMessageBuilder()

Method Detail

applyFilterParamsback to summary
private static void applyFilterParams(FilterParams filterParams, Consumer<List<MysqlxCrud.Order>> setOrder, Consumer<MysqlxCrud.Limit> setLimit, Consumer<MysqlxExpr.Expr> setCriteria, Consumer<List<MysqlxDatatypes.Scalar>> setArgs)

Apply the given filter params to the builder object (represented by the setter methods). Abstract the process of setting the filter params on the operation message builder.

Parameters
filterParams:FilterParams

the filter params to apply

setOrder:Consumer<List<MysqlxCrud.Order>>

the "builder.addAllOrder()" method reference

setLimit:Consumer<MysqlxCrud.Limit>

the "builder.setLimit()" method reference

setCriteria:Consumer<MysqlxExpr.Expr>

the "builder.setCriteria()" method reference

setArgs:Consumer<List<MysqlxDatatypes.Scalar>>

the "builder.addAllArgs()" method reference

Annotations
@SuppressWarnings:unchecked
applyFilterParamsback to summary
private static void applyFilterParams(FilterParams filterParams, Consumer<List<MysqlxCrud.Order>> setOrder, Consumer<MysqlxCrud.LimitExpr> setLimit, Consumer<MysqlxExpr.Expr> setCriteria)

Apply the given filter params to the builder object (represented by the setter methods) using the variant that takes a LimitExpr and no Args. This variant is suitable for building prepared statements prepare messages. Abstract the process of setting the filter params on the operation message builder.

Parameters
filterParams:FilterParams

the filter params to apply

setOrder:Consumer<List<MysqlxCrud.Order>>

the "builder.addAllOrder()" method reference

setLimit:Consumer<MysqlxCrud.LimitExpr>

the "builder.setLimitExp()" method reference

setCriteria:Consumer<MysqlxExpr.Expr>

the "builder.setCriteria()" method reference

Annotations
@SuppressWarnings:unchecked
buildCapabilitiesGetback to summary
public XMessage buildCapabilitiesGet()
buildCapabilitiesSetback to summary
public XMessage buildCapabilitiesSet(Map<String, Object> keyValuePair)
Annotations
@SuppressWarnings:unchecked
buildCloseback to summary
public XMessage buildClose()

Implements com.mysql.cj.MessageBuilder.buildClose.

Annotations
@Override
buildComQueryback to summary
public XMessage buildComQuery(XMessage sharedPacket, Session sess, String query, Query callingQuery, String characterEncoding)

Implements com.mysql.cj.MessageBuilder.buildComQuery.

Annotations
@Override
buildComQueryback to summary
public XMessage buildComQuery(XMessage sharedPacket, Session sess, PreparedQuery preparedQuery, QueryBindings bindings, String characterEncoding)

Implements com.mysql.cj.MessageBuilder.buildComQuery.

Annotations
@Override
buildCreateCollectionback to summary
public XMessage buildCreateCollection(String schemaName, String collectionName, Schema.CreateCollectionOptions options)
buildCreateCollectionback to summary
public XMessage buildCreateCollection(String schemaName, String collectionName)
buildCreateCollectionIndexback to summary
public XMessage buildCreateCollectionIndex(String schemaName, String collectionName, CreateIndexParams params)
buildDeleteback to summary
public XMessage buildDelete(FilterParams filterParams)

Build an XMessage for a non-prepared delete operation.

Parameters
filterParams:FilterParams

the filter parameters

Returns:XMessage

an XMessage instance

buildDisableNoticesback to summary
public XMessage buildDisableNotices(String... notices)
buildDocInsertback to summary
public XMessage buildDocInsert(String schemaName, String collectionName, List<String> json, boolean upsert)

Build an XMessage for a non-prepared doc insert operation.

Parameters
schemaName:String

the schema name

collectionName:String

the collection name

json:List<String>

the documents to insert

upsert:boolean

Whether this is an upsert operation or not

Returns:XMessage

an XMessage instance

buildDocUpdateback to summary
public XMessage buildDocUpdate(FilterParams filterParams, List<UpdateSpec> updates)

Build an XMessage for a non-prepared doc update operation.

Parameters
filterParams:FilterParams

the filter parameters

updates:List<UpdateSpec>

the updates specifications to perform

Returns:XMessage

an XMessage instance

buildDropCollectionback to summary
public XMessage buildDropCollection(String schemaName, String collectionName)
buildDropCollectionIndexback to summary
public XMessage buildDropCollectionIndex(String schemaName, String collectionName, String indexName)
buildEnableNoticesback to summary
public XMessage buildEnableNotices(String... notices)
buildExpectOpenback to summary
public XMessage buildExpectOpen()
buildExternalAuthStartback to summary
public XMessage buildExternalAuthStart(String database)
buildFindback to summary
public XMessage buildFind(FilterParams filterParams)

Build an XMessage for a non-prepared find operation.

Parameters
filterParams:FilterParams

the filter parameters

Returns:XMessage

an XMessage instance

buildListNoticesback to summary
public XMessage buildListNotices()

List the notices the server allows subscribing to. Returns a table as so:

| notice (string)     | enabled (int) |
|---------------------+---------------|
| warnings            | 1             |
Returns:XMessage

XMessage

buildListObjectsback to summary
public XMessage buildListObjects(String schemaName, String pattern)

List the objects in the given schema. Returns a table as so:

| name                | type       |
|---------------------+------------|
| CollectionTest      | COLLECTION |
| some_view           | VIEW       |
| xprotocol_test_test | TABLE      |
.
Parameters
schemaName:String

schema name

pattern:String

object name pattern

Returns:XMessage

XMessage

buildModifyCollectionOptionsback to summary
public XMessage buildModifyCollectionOptions(String schemaName, String collectionName, Schema.ModifyCollectionOptions options)
buildMysql41AuthContinueback to summary
public XMessage buildMysql41AuthContinue(String user, String password, byte[] salt, String database)
buildMysql41AuthStartback to summary
public XMessage buildMysql41AuthStart()
buildPlainAuthStartback to summary
public XMessage buildPlainAuthStart(String user, String password, String database)
buildPrepareDeallocateback to summary
public XMessage buildPrepareDeallocate(int preparedStatementId)

Build an XMessage for deallocating a prepared statement.

Parameters
preparedStatementId:int

the prepared statement id

Returns:XMessage

an XMessage instance

buildPrepareDeleteback to summary
public XMessage buildPrepareDelete(int preparedStatementId, FilterParams filterParams)

Build an XMessage for a prepared delete operation.

Parameters
preparedStatementId:int

the prepared statement id

filterParams:FilterParams

the filter parameters

Returns:XMessage

an XMessage instance

buildPrepareDocUpdateback to summary
public XMessage buildPrepareDocUpdate(int preparedStatementId, FilterParams filterParams, List<UpdateSpec> updates)

Build an XMessage for a prepared doc update operation.

Parameters
preparedStatementId:int

the prepared statement id

filterParams:FilterParams

the filter parameters

updates:List<UpdateSpec>

the updates specifications to perform

Returns:XMessage

an XMessage instance

buildPrepareExecuteback to summary
public XMessage buildPrepareExecute(int preparedStatementId, FilterParams filterParams)

Build an XMessage for executing a prepared statement with the given filters.

Parameters
preparedStatementId:int

the prepared statement id

filterParams:FilterParams

the filter parameter values

Returns:XMessage

an XMessage instance

Annotations
@SuppressWarnings:unchecked
buildPrepareFindback to summary
public XMessage buildPrepareFind(int preparedStatementId, FilterParams filterParams)

Build an XMessage for a prepared find operation.

Parameters
preparedStatementId:int

the prepared statement id

filterParams:FilterParams

the filter parameters

Returns:XMessage

an XMessage instance

buildPrepareRowUpdateback to summary
public XMessage buildPrepareRowUpdate(int preparedStatementId, FilterParams filterParams, UpdateParams updateParams)

Build an XMessage for a prepared row update operation.

Parameters
preparedStatementId:int

the prepared statement id

filterParams:FilterParams

the filter parameters

updateParams:UpdateParams

the update parameters

Returns:XMessage

an XMessage instance

buildPrepareSqlStatementback to summary
public XMessage buildPrepareSqlStatement(int preparedStatementId, String statement)

Build a Prepare message for a SQL statement.

Parameters
preparedStatementId:int

the prepared statement id

statement:String

SQL statement string

Returns:XMessage

XMessage wrapping StmtExecute

buildRowInsertback to summary
public XMessage buildRowInsert(String schemaName, String tableName, InsertParams insertParams)

Build an XMessage for a non-prepared row insert operation.

Parameters
schemaName:String

the schema name

tableName:String

the table name

insertParams:InsertParams

the parameters to insert

Returns:XMessage

an XMessage instance

Annotations
@SuppressWarnings:unchecked
buildRowUpdateback to summary
public XMessage buildRowUpdate(FilterParams filterParams, UpdateParams updateParams)

Build an XMessage for a non-prepared row update operation.

Parameters
filterParams:FilterParams

the filter parameters

updateParams:UpdateParams

the update parameters

Returns:XMessage

an XMessage instance

buildSessionResetAndCloseback to summary
public XMessage buildSessionResetAndClose()
buildSessionResetKeepOpenback to summary
public XMessage buildSessionResetKeepOpen()
buildSha256MemoryAuthContinueback to summary
public XMessage buildSha256MemoryAuthContinue(String user, String password, byte[] nonce, String database)
buildSha256MemoryAuthStartback to summary
public XMessage buildSha256MemoryAuthStart()
buildSqlStatementback to summary
public XMessage buildSqlStatement(String statement)

Implements com.mysql.cj.MessageBuilder.buildSqlStatement.

Build a StmtExecute message for a SQL statement.

Parameters
statement:String

SQL statement string

Returns:XMessage

XMessage wrapping StmtExecute

Annotations
@Override
buildSqlStatementback to summary
public XMessage buildSqlStatement(String statement, List<Object> args)

Implements com.mysql.cj.MessageBuilder.buildSqlStatement.

Build a StmtExecute message for a SQL statement.

Parameters
statement:String

SQL statement string

args:List<Object>

list of Object arguments

Returns:XMessage

XMessage wrapping StmtExecute

Annotations
@Override
buildXpluginCommandback to summary
private MysqlxSql.StmtExecute buildXpluginCommand(XpluginStatementCommand command, MysqlxDatatypes.Any... args)

Build a StmtExecute message for an xplugin command.

Parameters
command:XpluginStatementCommand

the xplugin command to send

args:MysqlxDatatypes.Any[]

the arguments to the command

Returns:MysqlxSql.StmtExecute

StmtExecute

commonDeleteBuilderback to summary
private MysqlxCrud.Delete.Builder commonDeleteBuilder(FilterParams filterParams)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Delete.Builder with common data for prepared and non-prepared executions.

Parameters
filterParams:FilterParams

the filter parameters

Returns:MysqlxCrud.Delete.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Delete.Builder instance

commonDocUpdateBuilderback to summary
private MysqlxCrud.Update.Builder commonDocUpdateBuilder(FilterParams filterParams, List<UpdateSpec> updates)

Initialize an com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder for collection data model with common data for prepared and non-prepared executions.

Parameters
filterParams:FilterParams

the filter parameters

updates:List<UpdateSpec>

the updates specifications to perform

Returns:MysqlxCrud.Update.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder instance

commonFindBuilderback to summary
private MysqlxCrud.Find.Builder commonFindBuilder(FilterParams filterParams)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Find.Builder for collection data model with common data for prepared and non-prepared executions.

Parameters
filterParams:FilterParams

the filter parameters

Returns:MysqlxCrud.Find.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Find.Builder instance

Annotations
@SuppressWarnings:unchecked
commonRowInsertBuilderback to summary
private MysqlxCrud.Insert.Builder commonRowInsertBuilder(String schemaName, String tableName, InsertParams insertParams)

Initialize a com.mysql.cj.x.protobuf.MysqlxCrud.Insert.Builder for table data model with common data for prepared and non-prepared executions.

Parameters
schemaName:String

the schema name

tableName:String

the table name

insertParams:InsertParams

the parameters to insert

Returns:MysqlxCrud.Insert.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Insert.Builder instance

Annotations
@SuppressWarnings:unchecked
commonRowUpdateBuilderback to summary
private MysqlxCrud.Update.Builder commonRowUpdateBuilder(FilterParams filterParams, UpdateParams updateParams)

Initialize an com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder for table data model with common data for prepared and non-prepared executions.

Parameters
filterParams:FilterParams

the filter parameters

updateParams:UpdateParams

the update parameters

Returns:MysqlxCrud.Update.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxCrud.Update.Builder instance

Annotations
@SuppressWarnings:unchecked
commonSqlStatementBuilderback to summary
private MysqlxSql.StmtExecute.Builder commonSqlStatementBuilder(String statement)

Initialize a com.mysql.cj.x.protobuf.MysqlxSql.StmtExecute.Builder with common data for prepared and non-prepared executions.

Parameters
statement:String

the SQL statement

Returns:MysqlxSql.StmtExecute.Builder

an initialized com.mysql.cj.x.protobuf.MysqlxSql.StmtExecute.Builder instance