com.mysql.cj.xdevapi

Class AddStatementImpl

java.lang.Object

com.mysql.cj.xdevapi.AddStatementImpl

All Implemented Interfaces:

AddStatement, Statement<AddStatement,AddResult>

public class AddStatementImpl
extends java.lang.Object
implements AddStatement

Nested Class Summary

Nested classes/interfaces inherited from interface com.mysql.cj.xdevapi.Statement

Statement.LockContention

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	collectionName
private MysqlxSession	mysqlxSession
private java.util.List<DbDoc>	newDocs
private java.lang.String	schemaName
private boolean	upsert

Constructor Summary

Constructors

Constructor and Description
AddStatementImpl(MysqlxSession mysqlxSession, java.lang.String schema, java.lang.String collection, DbDoc newDoc)
AddStatementImpl(MysqlxSession mysqlxSession, java.lang.String schema, java.lang.String collection, DbDoc[] newDocs)

Method Summary

Modifier and Type	Method and Description
AddStatement	add(DbDoc... docs) Add a sequence of DbDocs.
AddStatement	add(java.lang.String jsonString) Add a document as a JSON string.
AddResult	execute() Execute the statement synchronously.
java.util.concurrent.CompletableFuture<AddResult>	executeAsync() Execute the statement asynchronously.
boolean	isUpsert() Check the upsert flag.
private java.util.List<java.lang.String>	serializeDocs()
AddStatement	setUpsert(boolean upsert) Set upsert flag on this statement.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.mysql.cj.xdevapi.Statement

bind, bind, bind, bind, clearBindings

Field Detail

mysqlxSession

private MysqlxSession mysqlxSession

schemaName

private java.lang.String schemaName

collectionName

private java.lang.String collectionName

newDocs

private java.util.List<DbDoc> newDocs

upsert

private boolean upsert

Constructor Detail

AddStatementImpl

AddStatementImpl(MysqlxSession mysqlxSession,
                 java.lang.String schema,
                 java.lang.String collection,
                 DbDoc newDoc)

AddStatementImpl

AddStatementImpl(MysqlxSession mysqlxSession,
                 java.lang.String schema,
                 java.lang.String collection,
                 DbDoc[] newDocs)

Method Detail

add

public AddStatement add(java.lang.String jsonString)

Description copied from interface: AddStatement

Add a document as a JSON string.

Specified by:

add in interface AddStatement

Parameters:

jsonString - document as a JSON string

Returns:

AddStatement

add

public AddStatement add(DbDoc... docs)

Description copied from interface: AddStatement

Add a sequence of DbDocs.

Specified by:

add in interface AddStatement

Parameters:

docs - one or more DbDoc documents

Returns:

AddStatement

serializeDocs

private java.util.List<java.lang.String> serializeDocs()

execute

public AddResult execute()

Description copied from interface: Statement

Execute the statement synchronously.

Specified by:

execute in interface Statement<AddStatement,AddResult>

Returns:

result of statement execution

executeAsync

public java.util.concurrent.CompletableFuture<AddResult> executeAsync()

Description copied from interface: Statement

Execute the statement asynchronously.

Specified by:

executeAsync in interface Statement<AddStatement,AddResult>

Returns:

CompletableFuture for result

isUpsert

public boolean isUpsert()

Description copied from interface: AddStatement

Check the upsert flag.

Specified by:

isUpsert in interface AddStatement

Returns:

true if this is an upsert statement.

setUpsert

public AddStatement setUpsert(boolean upsert)

Description copied from interface: AddStatement

Set upsert flag on this statement. Used internally by the Collection.addOrReplaceOne(String, DbDoc) method.

Specified by:

setUpsert in interface AddStatement

Parameters:

upsert - if true then this statement will be executed as an upsert statement

Returns:

AddStatement