Interface ReactiveSelectOperation

All Known Subinterfaces:

ReactiveCassandraOperations, ReactiveFluentCassandraOperations

All Known Implementing Classes:

ReactiveCassandraTemplate

public interface ReactiveSelectOperation

The ReactiveSelectOperation interface allows creation and execution of Cassandra SELECT operations in a fluent API style.

The starting domainType is used for mapping the Query provided via matching int the Cassandra specific representation. By default, the originating domainType is also used for mapping back the result from the Row. However, it is possible to define an different returnType via as to mapping the result.

By default, the table to operate on is derived from the initial domainType and can be defined there via the Table annotation. Using inTable allows a developer to override the table name for the execution.

    
        query(Human.class)
            .inTable("star_wars")
            .as(Jedi.class)
            .matching(query(where("firstname").is("luke")))
            .all();
    

Since:

2.1

Author:

Mark Paluch, John Blum

See Also:

• Query

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ReactiveSelectOperation.ReactiveSelect<T>	The ReactiveSelectOperation.ReactiveSelect interface provides methods for constructing SELECT operations in a fluent way.
static interface	ReactiveSelectOperation.SelectWithProjection<T>	Result type override (optional).
static interface	ReactiveSelectOperation.SelectWithQuery<T>	Define a Query used as the filter for the SELECT.
static interface	ReactiveSelectOperation.SelectWithTable<T>	Table override (optional).
static interface	ReactiveSelectOperation.TerminatingProjections	Trigger SELECT query execution by calling one of the terminating methods returning result projections for count and exists projections.
static interface	ReactiveSelectOperation.TerminatingResults<T>	Trigger SELECT execution by calling one of the terminating methods.
static interface	ReactiveSelectOperation.TerminatingSelect<T>	Trigger SELECT query execution by calling one of the terminating methods.
static interface	ReactiveSelectOperation.UntypedSelect	Select query that is not yet associated with a result type.

Method Summary

Modifier and Type	Method	Description
ReactiveSelectOperation.UntypedSelect	query(com.datastax.oss.driver.api.core.cql.Statement<?> statement)	Begin creating a Cassandra SELECT query operation for the given Statement.
<T> ReactiveSelectOperation.ReactiveSelect<T>	query(Class<T> domainType)	Begin creating a SELECT operation for the given domainType.
ReactiveSelectOperation.UntypedSelect	query(String cql)	Begin creating a Cassandra SELECT query operation for the given cql.

Method Details

query

<T> ReactiveSelectOperation.ReactiveSelect<T> query(Class<T> domainType)

Begin creating a SELECT operation for the given domainType.

Type Parameters:

T - type of the application domain object.

Parameters:

domainType - type of the domain object to query; must not be null.

Returns:

new instance of ReactiveSelectOperation.ReactiveSelect.

Throws:

IllegalArgumentException - if domainType is null.

See Also:

• ReactiveSelectOperation.ReactiveSelect

query

ReactiveSelectOperation.UntypedSelect query(String cql)

Begin creating a Cassandra SELECT query operation for the given cql. The given cql must be a SELECT query.

Parameters:

cql - SELECT statement, must not be null.

Returns:

new instance of ReactiveSelectOperation.UntypedSelect.

Throws:

IllegalArgumentException - if cql is null.

Since:

5.0

See Also:

• ReactiveSelectOperation.ReactiveSelect

query

ReactiveSelectOperation.UntypedSelect query(com.datastax.oss.driver.api.core.cql.Statement<?> statement)

Begin creating a Cassandra SELECT query operation for the given Statement. The given Statement must be a SELECT query.

Parameters:

statement - SELECT statement, must not be null.

Returns:

new instance of ReactiveSelectOperation.UntypedSelect.

Throws:

IllegalArgumentException - if statement is null.

Since:

5.0

See Also:

• ReactiveSelectOperation.ReactiveSelect