Package | Description |
---|---|
org.springframework.data.cassandra |
Spring Data's Cassandra abstraction.
|
org.springframework.data.cassandra.core.cql |
CQL core support.
|
org.springframework.data.cassandra.core.cql.session |
Provides utility classes for simple
CqlSession access and various session
implementations. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveSession.execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement)
Executes the provided query.
|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveSession.execute(String query)
Executes the provided query.
|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveSession.execute(String query,
Map<String,Object> values)
Executes the provided query using the provided named values.
|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveSession.execute(String query,
Object... values)
Executes the provided query using the provided values.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlTemplate.queryForResultSet(com.datastax.oss.driver.api.core.cql.Statement<?> statement) |
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlOperations.queryForResultSet(com.datastax.oss.driver.api.core.cql.Statement<?> statement)
Execute a query for a ResultSet, given static CQL.
|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlTemplate.queryForResultSet(String cql) |
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlOperations.queryForResultSet(String cql)
Execute a query for a ResultSet, given static CQL.
|
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlTemplate.queryForResultSet(String cql,
Object... args) |
reactor.core.publisher.Mono<ReactiveResultSet> |
ReactiveCqlOperations.queryForResultSet(String cql,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, expecting a
ResultSet.
|
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<T> |
ReactiveResultSetExtractor.extractData(ReactiveResultSet resultSet)
Implementations must implement this method to process the entire
ReactiveResultSet . |
org.reactivestreams.Publisher<T> |
ReactiveRowMapperResultSetExtractor.extractData(ReactiveResultSet resultSet) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<ReactiveResultSet> |
DefaultBridgedReactiveSession.execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement) |
reactor.core.publisher.Mono<ReactiveResultSet> |
DefaultBridgedReactiveSession.execute(String query) |
reactor.core.publisher.Mono<ReactiveResultSet> |
DefaultBridgedReactiveSession.execute(String query,
Map<String,Object> values) |
reactor.core.publisher.Mono<ReactiveResultSet> |
DefaultBridgedReactiveSession.execute(String query,
Object... values) |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.