Top Fields Constructors Methods
com.mysql.cj.xdevapi

public Class AddStatementImpl

extends Object
implements AddStatement
Class Inheritance
All Implemented Interfaces
com.mysql.cj.xdevapi.AddStatement, com.mysql.cj.xdevapi.Statement
Imports
java.io.IOException, .StringReader, java.util.ArrayList, .Arrays, .Collections, .List, java.util.concurrent.CompletableFuture, java.util.stream.Collectors, com.mysql.cj.MysqlxSession, com.mysql.cj.exceptions.AssertionFailedException, com.mysql.cj.protocol.x.StatementExecuteOk, .XMessage, .XMessageBuilder

Field Summary

Modifier and TypeField and Description
private String
collectionName

private MysqlxSession
mysqlxSession

private List<DbDoc>
newDocs

private String
schemaName

private boolean
upsert

Constructor Summary

AccessConstructor and Description
pack-priv
AddStatementImpl(MysqlxSession mysqlxSession, String schema, String collection, DbDoc newDoc)

pack-priv
AddStatementImpl(MysqlxSession mysqlxSession, String schema, String collection, DbDoc[] newDocs)

Method Summary

Modifier and TypeMethod and Description
public AddStatement
add(String
document as a JSON string
jsonString)

Implements com.mysql.cj.xdevapi.AddStatement.add.

Add a document as a JSON string.

public AddStatement
add(DbDoc...
one or more DbDoc documents
docs)

Implements com.mysql.cj.xdevapi.AddStatement.add.

Add a sequence of DbDocs.

public AddResult
execute()

Implements com.mysql.cj.xdevapi.Statement.execute.

Execute the statement synchronously.

public CompletableFuture<AddResult>
executeAsync()

Implements com.mysql.cj.xdevapi.Statement.executeAsync.

Execute the statement asynchronously.

public boolean
isUpsert()

Implements com.mysql.cj.xdevapi.AddStatement.isUpsert.

Check the upsert flag.

private List<String>
serializeDocs()

public AddStatement
setUpsert(boolean
if true then this statement will be executed as an upsert statement
upsert)

Implements com.mysql.cj.xdevapi.AddStatement.setUpsert.

Set upsert flag on this statement.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

collectionNameback to summary
private String collectionName
mysqlxSessionback to summary
private MysqlxSession mysqlxSession
newDocsback to summary
private List<DbDoc> newDocs
schemaNameback to summary
private String schemaName
upsertback to summary
private boolean upsert

Constructor Detail

AddStatementImplback to summary
pack-priv AddStatementImpl(MysqlxSession mysqlxSession, String schema, String collection, DbDoc newDoc)
AddStatementImplback to summary
pack-priv AddStatementImpl(MysqlxSession mysqlxSession, String schema, String collection, DbDoc[] newDocs)

Method Detail

addback to summary
public AddStatement add(String jsonString)

Implements com.mysql.cj.xdevapi.AddStatement.add.

Doc from com.mysql.cj.xdevapi.AddStatement.add.

Add a document as a JSON string.

Parameters
jsonString:String

document as a JSON string

Returns:AddStatement

AddStatement

Annotations
@Override
addback to summary
public AddStatement add(DbDoc... docs)

Implements com.mysql.cj.xdevapi.AddStatement.add.

Doc from com.mysql.cj.xdevapi.AddStatement.add.

Add a sequence of DbDocs.

Parameters
docs:DbDoc[]

one or more DbDoc documents

Returns:AddStatement

AddStatement

Annotations
@Override
executeback to summary
public AddResult execute()

Implements com.mysql.cj.xdevapi.Statement.execute.

Doc from com.mysql.cj.xdevapi.Statement.execute.

Execute the statement synchronously.

Returns:AddResult

result of statement execution

Annotations
@Override
executeAsyncback to summary
public CompletableFuture<AddResult> executeAsync()

Implements com.mysql.cj.xdevapi.Statement.executeAsync.

Doc from com.mysql.cj.xdevapi.Statement.executeAsync.

Execute the statement asynchronously.

Returns:CompletableFuture<AddResult>

CompletableFuture for result

Annotations
@Override
isUpsertback to summary
public boolean isUpsert()

Implements com.mysql.cj.xdevapi.AddStatement.isUpsert.

Doc from com.mysql.cj.xdevapi.AddStatement.isUpsert.

Check the upsert flag.

Returns:boolean

true if this is an upsert statement.

Annotations
@Override
serializeDocsback to summary
private List<String> serializeDocs()
setUpsertback to summary
public AddStatement setUpsert(boolean upsert)

Implements com.mysql.cj.xdevapi.AddStatement.setUpsert.

Doc from com.mysql.cj.xdevapi.AddStatement.setUpsert.

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

Parameters
upsert:boolean

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

Returns:AddStatement

AddStatement

Annotations
@Override