インターフェース ReactiveCassandraOperations

メソッドの詳細

• batchOps

  default ReactiveCassandraBatchOperations batchOps()

  BatchType.LOGGED を使用して新しい ReactiveCassandraBatchOperations を返します。各 ReactiveCassandraBatchOperations インスタンスは 1 回しか実行できないため、バッチごとに新しい ReactiveCassandraBatchOperations インスタンスを取得する必要があります。

  戻り値:

  指定されたエンティティクラスに関連付けられた新しい ReactiveCassandraBatchOperations。

  導入:

  2.1

  関連事項:

  • batchOps(BatchType)

• batchOps

  ReactiveCassandraBatchOperations batchOps(com.datastax.oss.driver.api.core.cql.BatchType batchType)

  新しい ReactiveCassandraBatchOperations を返します。各 ReactiveCassandraBatchOperations インスタンスは 1 回しか実行できないため、バッチごとに新しい ReactiveCassandraBatchOperations インスタンスを取得する必要があります。

  パラメーター:

  batchType - null であってはなりません。

  戻り値:

  指定されたエンティティクラスに関連付けられた新しい ReactiveCassandraBatchOperations。

  導入:

  3.2.6

• getReactiveCqlOperations

  ReactiveCqlOperations getReactiveCqlOperations()

  CQL 操作を可能にするために、基盤となる ReactiveCqlOperations を公開します。

  戻り値:

  基礎となる ReactiveCqlOperations。

  関連事項:

  • ReactiveCqlOperations

• getConverter

  CassandraConverter getConverter()

  基本となる CassandraConverter を返します。

  戻り値:

  基礎となる CassandraConverter。

• select

  <T> reactor.core.publisher.Flux<T> select(StringSE cql, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティのストリームに変換します。

  パラメーター:

  cql - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  変換された結果

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• selectOne

  <T> reactor.core.publisher.Mono<T> selectOne(StringSE cql, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティに変換します。

  パラメーター:

  cql - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションまたは Mono.empty() によって返された結果オブジェクト

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• select

  <T> reactor.core.publisher.Flux<T> select(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティのストリームに変換します。

  パラメーター:

  statement - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションによって返される結果オブジェクト。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• slice

  <T> reactor.core.publisher.Mono<Slice<T>> slice(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException

  ページング付きの SELECT クエリを実行し、結果セットをエンティティの Slice に変換します。スライスされたクエリは、有効な fetch size をページサイズに変換します。

  パラメーター:

  statement - CQL ステートメントは null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションによって返される結果オブジェクト、または空の Slice の Mono.just(Object)。

  例外:

  DataAccessException - クエリの実行に問題がある場合。

  導入:

  2.1

• selectOne

  <T> reactor.core.publisher.Mono<T> selectOne(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティに変換します。

  パラメーター:

  statement - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションまたは Mono.empty() によって返された結果オブジェクト

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• execute

  reactor.core.publisher.Mono<ReactiveResultSet> execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException

  指定された Cassandra Statement を実行します。このコマンドの実行によって発生したエラーはすべて、Spring の DAO 例外階層に変換されます。

  パラメーター:

  statement - Cassandra Statement は null であってはなりません。

  戻り値:

  ReactiveResultSet

  例外:

  DataAccessException - 実行の発行に問題がある場合。

  導入:

  3.2

• select

  <T> reactor.core.publisher.Flux<T> select(Query query, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティのストリームに変換します。

  パラメーター:

  query - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションによって返される結果オブジェクト。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• slice

  <T> reactor.core.publisher.Mono<Slice<T>> slice(Query query, ClassSE<T> entityClass) throws DataAccessException

  ページングを使用して SELECT クエリを実行し、結果セットをエンティティの Slice に変換します。

  パラメーター:

  query - CQL ステートメントの作成に使用されるクエリオブジェクトは null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションによって返される結果オブジェクト、または空の Slice の Mono.just(Object)。

  例外:

  DataAccessException - クエリの実行に問題がある場合。

  導入:

  2.1

  関連事項:

  • CassandraPageRequest

• selectOne

  <T> reactor.core.publisher.Mono<T> selectOne(Query query, ClassSE<T> entityClass) throws DataAccessException

  SELECT クエリを実行し、結果のアイテムをエンティティに変換します。

  パラメーター:

  query - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションまたは Mono.empty() によって返された結果オブジェクト。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• update

  reactor.core.publisher.Mono<BooleanSE> update(Query query, Update update, ClassSE<?> entityClass) throws DataAccessException

  クエリされたエンティティを更新し、更新が適用された場合は true を返します。

  パラメーター:

  query - null であってはなりません。

  update - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  例外:

  DataAccessException - クエリの実行に問題がある場合。

• delete

  reactor.core.publisher.Mono<BooleanSE> delete(Query query, ClassSE<?> entityClass) throws DataAccessException

  Query によってテーブルからエンティティ (行)/columns を削除します。

  パラメーター:

  query - null であってはなりません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  削除が適用された場合は true。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• count

  reactor.core.publisher.Mono<LongSE> count(ClassSE<?> entityClass) throws DataAccessException

  指定されたエンティティクラスの行数を返します。

  パラメーター:

  entityClass - エンティティの typeSE。null であってはなりません。

  戻り値:

  既存のエンティティの数。

  例外:

  DataAccessException - クエリの実行中に問題が発生した場合。

• count

  reactor.core.publisher.Mono<LongSE> count(Query query, ClassSE<?> entityClass) throws DataAccessException

  Query を適用して、指定されたエンティティクラスの行数を返します。このオーバーライドされたメソッドにより、ユーザーは Query 述語を使用して選択条件をさらに絞り込み、指定された typeSE のエンティティのうち条件に一致するエンティティの数を判断できます。

  パラメーター:

  query - 実行するユーザー定義のカウント Query。null であってはなりません。

  entityClass - エンティティの typeSE。null であってはなりません。

  戻り値:

  既存のエンティティの数。

  例外:

  DataAccessException - クエリの実行中に問題が発生した場合。

  導入:

  2.1

• exists

  reactor.core.publisher.Mono<BooleanSE> exists(ObjectSE id, ClassSE<?> entityClass) throws DataAccessException

  指定された id を持つ entityClass の行が存在するかどうかを確認します。

  パラメーター:

  id - ID 値。単一の主キーの場合はプレーンな値です。複合主キーの場合は、PrimaryKeyClass または MapId のインスタンスです。null にすることはできません。

  entityClass - エンティティの typeSE。null であってはなりません。

  戻り値:

  オブジェクトが存在する場合は true。

  例外:

  DataAccessException - クエリの実行中に問題が発生した場合。

• exists

  reactor.core.publisher.Mono<BooleanSE> exists(Query query, ClassSE<?> entityClass) throws DataAccessException

  entityClass Query の結果が少なくとも 1 つの行を生成するかどうかを判別します。

  パラメーター:

  query - 実行するユーザー定義の存在 Query。null であってはなりません。

  entityClass - エンティティの typeSE。null であってはなりません。

  戻り値:

  オブジェクトが存在する場合は true。

  例外:

  DataAccessException - クエリの実行中に問題が発生した場合。

  導入:

  2.1

• selectOneById

  <T> reactor.core.publisher.Mono<T> selectOneById(ObjectSE id, ClassSE<T> entityClass) throws DataAccessException

  指定された entityClass に対して id による選択を実行します。

  パラメーター:

  id - Id 値。単一の主キーの場合はプレーンな値です。複合主キーの場合は PrimaryKeyClass または MapId のいずれかです。null にすることはできません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  アクションまたは Mono.empty() によって返された結果オブジェクト

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• insert

  <T> reactor.core.publisher.Mono<T> insert(T entity) throws DataAccessException

  指定されたエンティティを挿入し、挿入が適用された場合はエンティティを発行します。

  パラメーター:

  entity - 挿入するエンティティ。null であってはなりません。

  戻り値:

  挿入されたエンティティ。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• insert

  <T> reactor.core.publisher.Mono<EntityWriteResult<T>> insert(T entity, InsertOptions options) throws DataAccessException

  WriteOptions を適用して指定されたエンティティを挿入し、挿入が適用された場合はエンティティを出力します。

  パラメーター:

  entity - 挿入するエンティティ。null であってはなりません。

  options - null であってはなりません。

  戻り値:

  この操作の EntityWriteResult。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

  関連事項:

  • InsertOptions.empty()

• update

  <T> reactor.core.publisher.Mono<T> update(T entity) throws DataAccessException

  指定されたエンティティを更新し、更新が適用された場合はエンティティを発行します。

  パラメーター:

  entity - 更新するエンティティ。null であってはなりません。

  戻り値:

  更新されたエンティティ。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• update

  <T> reactor.core.publisher.Mono<EntityWriteResult<T>> update(T entity, UpdateOptions options) throws DataAccessException

  WriteOptions を適用して指定されたエンティティを更新し、更新が適用された場合はエンティティを出力します。

  パラメーター:

  entity - 更新するエンティティ。null であってはなりません。

  options - null であってはなりません。

  戻り値:

  この操作の EntityWriteResult。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

  関連事項:

  • UpdateOptions.empty()

• delete

  <T> reactor.core.publisher.Mono<T> delete(T entity) throws DataAccessException

  指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを出力します。

  パラメーター:

  entity - null であってはなりません。

  戻り値:

  削除されたエンティティ。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• delete

  reactor.core.publisher.Mono<WriteResult> delete(ObjectSE entity, QueryOptions options) throws DataAccessException

  QueryOptions を適用して指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを出力します。

  パラメーター:

  entity - null であってはなりません。

  options - null であってはなりません。

  戻り値:

  この操作の WriteResult。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

  関連事項:

  • QueryOptions.empty()

• delete

  default reactor.core.publisher.Mono<WriteResult> delete(ObjectSE entity, DeleteOptions options) throws DataAccessException

  QueryOptions を適用して指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを出力します。

  パラメーター:

  entity - null であってはなりません。

  options - null であってはなりません。

  戻り値:

  この操作の WriteResult。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

  導入:

  2.2

  関連事項:

  • DeleteOptions.empty()

• deleteById

  reactor.core.publisher.Mono<BooleanSE> deleteById(ObjectSE id, ClassSE<?> entityClass) throws DataAccessException

  指定されたオブジェクトを ID によってテーブルから削除します。

  パラメーター:

  id - Id 値。単一の主キーの場合はプレーンな値です。複合主キーの場合は PrimaryKeyClass または MapId のいずれかです。null にすることはできません。

  entityClass - エンティティ型は null にできません。

  戻り値:

  削除が適用された場合は true。

  例外:

  DataAccessException - 実行の発行に問題がある場合。

• truncate

  reactor.core.publisher.Mono<VoidSE> truncate(ClassSE<?> entityClass) throws DataAccessException

  TRUNCATE クエリを実行して、指定されたクラスのすべてのエンティティを削除します。

  パラメーター:

  entityClass - エンティティ型は null にできません。

  例外:

  DataAccessException - 実行の発行に問題がある場合。