Package | Description |
---|---|
org.springframework.data.cassandra.core.cql |
CQL core support.
|
Modifier and Type | Class and Description |
---|---|
class |
ColumnMapRowMapper
RowMapper implementation that creates a java.util.Map for each row, representing all columns as
key-value pairs: one entry for each column, with the column name as key. |
class |
SingleColumnRowMapper<T>
RowMapper implementation that converts a single column into a single result value per row. |
Modifier and Type | Method and Description |
---|---|
protected RowMapper<Map<String,Object>> |
ReactiveCqlTemplate.getColumnMapRowMapper()
Create a new RowMapper for reading columns as key-value pairs.
|
protected <T> RowMapper<T> |
ReactiveCqlTemplate.getSingleColumnRowMapper(Class<T> requiredType)
Create a new RowMapper for reading result objects from a single column.
|
protected RowMapper<Map<String,Object>> |
CassandraAccessor.newColumnMapRowMapper()
Create a new RowMapper for reading columns as key-value pairs.
|
protected <T> RowMapper<T> |
CassandraAccessor.newSingleColumnRowMapper(Class<T> requiredType)
Create a new RowMapper for reading result objects from a single column.
|
Modifier and Type | Method and Description |
---|---|
protected <T> AsyncRowMapperResultSetExtractor<T> |
AsyncCqlTemplate.newAsyncResultSetExtractor(RowMapper<T> rowMapper)
Constructs a new instance of the
ResultSetExtractor initialized with and adapting the given
RowMapper . |
protected <T> RowMapperResultSetExtractor<T> |
CqlTemplate.newResultSetExtractor(RowMapper<T> rowMapper)
Constructs a new instance of the
ResultSetExtractor initialized with and adapting the given
RowMapper . |
protected <T> RowMapperResultSetExtractor<T> |
CqlTemplate.newResultSetExtractor(RowMapper<T> rowMapper,
int rowsExpected)
Constructs a new instance of the
ResultSetExtractor initialized with and adapting the given
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(AsyncPreparedStatementCreator preparedStatementCreator,
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> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(AsyncPreparedStatementCreator preparedStatementCreator,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(AsyncPreparedStatementCreator preparedStatementCreator,
RowMapper<T> rowMapper)
Query using a prepared statement, mapping each row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(AsyncPreparedStatementCreator preparedStatementCreator,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlOperations.query(PreparedStatementCreator preparedStatementCreator,
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> List<T> |
CqlTemplate.query(PreparedStatementCreator preparedStatementCreator,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlOperations.query(PreparedStatementCreator preparedStatementCreator,
RowMapper<T> rowMapper)
Query using a prepared statement, mapping each row to a Java object via a
RowMapper . |
<T> List<T> |
CqlTemplate.query(PreparedStatementCreator preparedStatementCreator,
RowMapper<T> rowMapper) |
<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,
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 . |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlOperations.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlTemplate.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper)
Query given CQL to create a prepared statement from CQL 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(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlOperations.query(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper)
Query given CQL to create a prepared statement from CQL and a
PreparedStatementBinder implementation that
knows how to bind values to the query, mapping each row to a Java object via a RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlTemplate.query(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(String cql,
PreparedStatementBinder psb,
RowMapper<T> rowMapper)
Query given CQL to create a prepared statement from CQL and a
PreparedStatement Binder implementation that
knows how to bind values to the query, mapping each row to a Java object via a RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(String cql,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlOperations.query(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(String cql,
RowMapper<T> rowMapper) |
<T> List<T> |
CqlTemplate.query(String cql,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping each row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlOperations.query(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping each
row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlTemplate.query(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> List<T> |
CqlOperations.query(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping each
row to a Java object via a
RowMapper . |
<T> ListenableFuture<List<T>> |
AsyncCqlTemplate.query(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> List<T> |
CqlTemplate.query(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCqlOperations.query(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping each
row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlOperations.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlTemplate.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> T |
CqlOperations.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlTemplate.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> T |
CqlTemplate.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlOperations.queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper) |
<T> T |
CqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper) |
<T> T |
CqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper) |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper)
Execute a query given static CQL, mapping a single result row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping a
single result row to a Java object via a
RowMapper . |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> T |
CqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping a
single result row to a Java object via a
RowMapper . |
<T> ListenableFuture<T> |
AsyncCqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> T |
CqlTemplate.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args) |
<T> reactor.core.publisher.Mono<T> |
ReactiveCqlOperations.queryForObject(String cql,
RowMapper<T> rowMapper,
Object... args)
Query given CQL to create a prepared statement from CQL and a list of arguments to bind to the query, mapping a
single result row to a Java object via a
RowMapper . |
Constructor and Description |
---|
AsyncRowMapperResultSetExtractor(RowMapper<T> rowMapper)
Create a new
AsyncRowMapperResultSetExtractor . |
ReactiveRowMapperResultSetExtractor(RowMapper<T> rowMapper)
Create a new
ReactiveRowMapperResultSetExtractor . |
RowMapperResultSetExtractor(RowMapper<T> rowMapper)
Create a new
RowMapperResultSetExtractor . |
RowMapperResultSetExtractor(RowMapper<T> rowMapper,
int rowsExpected)
Create a new
RowMapperResultSetExtractor . |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.