Top Description Fields Constructors Methods
com.mysql.cj.xdevapi

public Class SelectStatementImpl

extends FilterableStatement<SelectStatement, RowResult>
implements SelectStatement
Class Inheritance
All Implemented Interfaces
com.mysql.cj.xdevapi.SelectStatement, com.mysql.cj.xdevapi.Statement
Imports
java.util.concurrent.CompletableFuture, com.mysql.cj.MysqlxSession, com.mysql.cj.protocol.x.XMessage, com.mysql.cj.xdevapi.FilterParams.RowLock, .FilterParams.RowLockOptions
SelectStatement implementation.

Field Summary

Inherited from com.mysql.cj.xdevapi.FilterableStatement:
filterParams

Constructor Summary

AccessConstructor and Description
pack-priv
SelectStatementImpl(MysqlxSession mysqlxSession, String schema, String table, String... projection)

Method Summary

Modifier and TypeMethod and Description
public CompletableFuture<RowResult>
executeAsync()

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

Execute the statement asynchronously.

protected RowResult
executePreparedStatement()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.executePreparedStatement.

Executes a previously server-prepared statement.

protected RowResult
executeStatement()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.executeStatement.

Executes the statement directly (non-prepared).

public FilterParams
getFilterParams()

Implements com.mysql.cj.xdevapi.SelectStatement.getFilterParams.

Return FilterParams defined for this statement.

protected XMessage
getPrepareStatementXMessage()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.getPrepareStatementXMessage.

Returns the XMessage needed to prepare this statement.

public SelectStatement
groupBy(String...
groupBy expression
groupBy)

Implements com.mysql.cj.xdevapi.SelectStatement.groupBy.

Add/replace the aggregation fields for this query.

public SelectStatement
having(String
having expression
having)

Implements com.mysql.cj.xdevapi.SelectStatement.having.

Add/replace the aggregate criteria for this query.

public SelectStatement
lockExclusive()

Implements com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Locks matching rows exclusively so no other transactions can read or write to them.

public SelectStatement
lockExclusive(Statement.LockContention
The com.mysql.cj.xdevapi.Statement.LockContention value to set.
lockContention)

Implements com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Locks matching rows exclusively so no other transactions can read or write to them, using the provided lock contention option.

public SelectStatement
lockShared()

Implements com.mysql.cj.xdevapi.SelectStatement.lockShared.

Locks matching rows against updates.

public SelectStatement
lockShared(Statement.LockContention
The com.mysql.cj.xdevapi.Statement.LockContention value to set.
lockContention)

Implements com.mysql.cj.xdevapi.SelectStatement.lockShared.

Locks matching rows against updates using the provided lock contention option.

Inherited from com.mysql.cj.xdevapi.FilterableStatement:
bindclearBindingsisRelationallimitoffsetorderBysortwhere

Constructor Detail

SelectStatementImplback to summary
pack-priv SelectStatementImpl(MysqlxSession mysqlxSession, String schema, String table, String... projection)

Method Detail

executeAsyncback to summary
public CompletableFuture<RowResult> executeAsync()

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

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

Execute the statement asynchronously.

Returns:CompletableFuture<RowResult>

CompletableFuture for result

Annotations
@Override
executePreparedStatementback to summary
protected RowResult executePreparedStatement()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.executePreparedStatement.

Doc from com.mysql.cj.xdevapi.PreparableStatement.executePreparedStatement.

Executes a previously server-prepared statement. Implementation is dependent on the statement type.

Returns:RowResult

the object returned from the lower level statement execution

Annotations
@Override
executeStatementback to summary
protected RowResult executeStatement()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.executeStatement.

Doc from com.mysql.cj.xdevapi.PreparableStatement.executeStatement.

Executes the statement directly (non-prepared). Implementation is dependent on the statement type.

Returns:RowResult

the object returned from the lower level statement execution

Annotations
@Override
getFilterParamsback to summary
public FilterParams getFilterParams()

Implements com.mysql.cj.xdevapi.SelectStatement.getFilterParams.

Doc from com.mysql.cj.xdevapi.SelectStatement.getFilterParams.

Return FilterParams defined for this statement.

Returns:FilterParams

FilterParams

Annotations
@Override
getPrepareStatementXMessageback to summary
protected XMessage getPrepareStatementXMessage()

Implements abstract com.mysql.cj.xdevapi.PreparableStatement.getPrepareStatementXMessage.

Doc from com.mysql.cj.xdevapi.PreparableStatement.getPrepareStatementXMessage.

Returns the XMessage needed to prepare this statement. Implementation is dependent on the statement type.

Returns:XMessage

the XMessage that prepares this statement

Annotations
@Override
groupByback to summary
public SelectStatement groupBy(String... groupBy)

Implements com.mysql.cj.xdevapi.SelectStatement.groupBy.

Doc from com.mysql.cj.xdevapi.SelectStatement.groupBy.

Add/replace the aggregation fields for this query.

Parameters
groupBy:String[]

groupBy expression

Returns:SelectStatement

SelectStatement

Annotations
@Override
havingback to summary
public SelectStatement having(String having)

Implements com.mysql.cj.xdevapi.SelectStatement.having.

Doc from com.mysql.cj.xdevapi.SelectStatement.having.

Add/replace the aggregate criteria for this query.

Parameters
having:String

having expression

Returns:SelectStatement

SelectStatement

Annotations
@Override
lockExclusiveback to summary
public SelectStatement lockExclusive()

Implements com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Doc from com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Locks matching rows exclusively so no other transactions can read or write to them.

Returns:SelectStatement

SelectStatement

Annotations
@Override
lockExclusiveback to summary
public SelectStatement lockExclusive(Statement.LockContention lockContention)

Implements com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Doc from com.mysql.cj.xdevapi.SelectStatement.lockExclusive.

Locks matching rows exclusively so no other transactions can read or write to them, using the provided lock contention option.

Parameters
lockContention:Statement.LockContention

The com.mysql.cj.xdevapi.Statement.LockContention value to set.

Returns:SelectStatement

SelectStatement

Annotations
@Override
lockSharedback to summary
public SelectStatement lockShared()

Implements com.mysql.cj.xdevapi.SelectStatement.lockShared.

Doc from com.mysql.cj.xdevapi.SelectStatement.lockShared.

Locks matching rows against updates.

Returns:SelectStatement

SelectStatement

Annotations
@Override
lockSharedback to summary
public SelectStatement lockShared(Statement.LockContention lockContention)

Implements com.mysql.cj.xdevapi.SelectStatement.lockShared.

Doc from com.mysql.cj.xdevapi.SelectStatement.lockShared.

Locks matching rows against updates using the provided lock contention option.

Parameters
lockContention:Statement.LockContention

The com.mysql.cj.xdevapi.Statement.LockContention value to set.

Returns:SelectStatement

SelectStatement

Annotations
@Override