Package | Description |
---|---|
org.springframework.data.cassandra.core.cql |
CQL core support.
|
Modifier and Type | Method and Description |
---|---|
protected ReactivePreparedStatementCreator |
ReactiveCqlTemplate.newReactivePreparedStatementCreator(String cql)
Create a new CQL-based
ReactivePreparedStatementCreator using the CQL passed in. |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Boolean> |
ReactiveCqlTemplate.execute(ReactivePreparedStatementCreator psc) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCqlOperations.execute(ReactivePreparedStatementCreator psc)
Issue a single CQL execute operation (such as an insert, update or delete statement) using a
ReactivePreparedStatementCreator to provide CQL and any required parameters. |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.execute(ReactivePreparedStatementCreator psc,
ReactivePreparedStatementCallback<T> action) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.execute(ReactivePreparedStatementCreator psc,
ReactivePreparedStatementCallback<T> action)
Execute a CQL data access operation, implemented as callback action working on a CQL
PreparedStatement . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder preparedStatementBinder,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder psb,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement and a
PreparedStatementBinder implementation that knows how to bind values
to the query, reading the ReactiveResultSet with a ResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
PreparedStatementBinder psb,
RowMapper<T> rowMapper)
Query using a prepared statement and a
PreparedStatementBinder implementation that knows how to bind values
to the query, mapping each row to a Java object via a RowMapper . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
ReactiveResultSetExtractor<T> rse) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
ReactiveResultSetExtractor<T> rse)
Query using a prepared statement, reading the
ReactiveResultSet with a ReactiveResultSetExtractor . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(ReactivePreparedStatementCreator psc,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(ReactivePreparedStatementCreator psc,
RowMapper<T> rowMapper)
Query using a prepared statement, mapping each row to a Java object via a
RowMapper . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.