Class AbstractReactiveCassandraQuery

java.lang.Object
org.springframework.data.cassandra.repository.query.CassandraRepositoryQuerySupport
org.springframework.data.cassandra.repository.query.AbstractReactiveCassandraQuery
All Implemented Interfaces:
org.springframework.data.repository.query.RepositoryQuery
Direct Known Subclasses:
ReactivePartTreeCassandraQuery, ReactiveStringBasedCassandraQuery

public abstract class AbstractReactiveCassandraQuery extends CassandraRepositoryQuerySupport
Base class for reactive RepositoryQuery implementations for Cassandra.
Since:
2.0
Author:
Mark Paluch, Hleb Albau
See Also:
  • Constructor Details

  • Method Details

    • getQueryMethod

      public ReactiveCassandraQueryMethod getQueryMethod()
      Specified by:
      getQueryMethod in interface org.springframework.data.repository.query.RepositoryQuery
      Overrides:
      getQueryMethod in class CassandraRepositoryQuerySupport
    • execute

      public Object execute(Object[] parameters)
    • createQuery

      protected abstract reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> createQuery(CassandraParameterAccessor accessor)
      Creates a string query using the given ParameterAccessor
      Parameters:
      accessor - must not be null.
    • getReactiveCassandraOperations

      protected ReactiveCassandraOperations getReactiveCassandraOperations()
    • isCountQuery

      protected abstract boolean isCountQuery()
      Returns whether the query should get a count projection applied.
      Returns:
      a boolean value indicating whether the query is a count projection.
      Since:
      2.1
    • isExistsQuery

      protected abstract boolean isExistsQuery()
      Returns whether the query should get an exists projection applied.
      Returns:
      a boolean value indicating whether the query is an exists projection.
      Since:
      2.1
    • isLimiting

      protected abstract boolean isLimiting()
      Return whether the query has an explicit limit set.
      Returns:
      a boolean value indicating whether the query has an explicit limit set.
      Since:
      2.0.4
    • isModifyingQuery

      protected abstract boolean isModifyingQuery()
      Returns whether the query is a modifying query.
      Returns:
      a boolean value indicating whether the query is a modifying query.
      Since:
      2.2