インターフェース AsyncCassandraOperations
- すべての既知の実装クラス:
AsyncCassandraTemplate
public interface AsyncCassandraOperations
非同期 Cassandra 操作の基本セットを指定するインターフェース。
AsyncCassandraTemplate
によって実装されます。直接使用されることはあまりありませんが、簡単にモック化またはスタブ化できるため、テスト可能性を高めるのに役立つオプションです。- 導入:
- 2.0
- 作成者:
- Mark Paluch, John Blum
- 関連事項:
メソッドのサマリー
修飾子と型メソッド説明指定されたエンティティクラスの行数を返します。Query
を適用する特定のエンティティクラスの行数を返します。delete
(ObjectSE entity, QueryOptions options) QueryOptions
を適用する指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。default CompletableFutureSE<WriteResult>
delete
(ObjectSE entity, DeleteOptions options) DeleteOptions
を適用する指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。Query
によってテーブルからエンティティ (行)/columns を削除します。<T> CompletableFutureSE<T>
delete
(T entity) 指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。deleteById
(ObjectSE id, ClassSE<?> entityClass) 指定されたオブジェクトを ID によってテーブルから削除します。CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet>
execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) 指定された CassandraStatement
を実行します。指定されたid
を持つentityClass
の行が存在するかどうかを確認します。entityClass
Query
の結果が少なくとも 1 つの行を生成するかどうかを判別します。基礎となるAsyncCqlOperations
を公開して、非同期 CQL 操作を可能にします。基本となるCassandraConverter
を返します。<T> CompletableFutureSE<T>
insert
(T entity) 指定されたエンティティを挿入し、挿入が適用された場合はエンティティを返します。<T> CompletableFutureSE<EntityWriteResult<T>>
insert
(T entity, InsertOptions options) WriteOptions
を適用する指定されたエンティティを挿入し、挿入が適用された場合はエンティティを返します。<T> CompletableFutureSE<ListSE<T>>
SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。select
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。<T> CompletableFutureSE<ListSE<T>>
SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。select
(StringSE cql, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。<T> CompletableFutureSE<ListSE<T>>
SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。select
(Query query, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。<T> CompletableFutureSE<T>
SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。<T> CompletableFutureSE<T>
SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。<T> CompletableFutureSE<T>
SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。<T> CompletableFutureSE<T>
selectOneById
(ObjectSE id, ClassSE<T> entityClass) 指定されたentityClass
に対してid
による選択を実行します。<T> CompletableFutureSE<Slice<T>>
ページングを使用してSELECT
クエリを実行し、結果セットをエンティティのSlice
に変換します。<T> CompletableFutureSE<Slice<T>>
ページングを使用してSELECT
クエリを実行し、結果セットをエンティティのSlice
に変換します。TRUNCATE
クエリを実行して、指定されたクラスのすべてのエンティティを削除します。クエリされたエンティティを更新し、更新が適用された場合は true を返します。<T> CompletableFutureSE<T>
update
(T entity) 指定されたエンティティを更新し、更新が適用された場合はエンティティを返します。<T> CompletableFutureSE<EntityWriteResult<T>>
update
(T entity, UpdateOptions options) WriteOptions
を適用する指定されたエンティティを更新し、更新が適用された場合はエンティティを返します。
メソッドの詳細
getAsyncCqlOperations
AsyncCqlOperations getAsyncCqlOperations()基礎となるAsyncCqlOperations
を公開して、非同期 CQL 操作を可能にします。- 戻り値:
- 基礎となる
AsyncCqlOperations
。 - 関連事項:
getConverter
CassandraConverter getConverter()基本となるCassandraConverter
を返します。- 戻り値:
- 基礎となる
CassandraConverter
。
select
<T> CompletableFutureSE<ListSE<T>> select(StringSE cql, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。- パラメーター:
cql
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換された結果
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
select
<T> CompletableFutureSE<VoidSE> select(StringSE cql, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。- パラメーター:
cql
- null であってはなりません。entityConsumer
- 各エンティティで一度に 1 つのオブジェクトが通知されるオブジェクトは null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 完了ハンドル
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
selectOne
<T> CompletableFutureSE<T> selectOne(StringSE cql, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。- パラメーター:
cql
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換されたオブジェクトまたは null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet> execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException 指定された CassandraStatement
を実行します。このコマンドの実行によって発生したエラーはすべて、Spring の DAO 例外階層に変換されます。- パラメーター:
statement
- CassandraStatement
は null であってはなりません。- 戻り値:
AsyncResultSet
- 例外:
DataAccessException
- クエリの実行に問題がある場合。- 導入:
- 3.2
select
<T> CompletableFutureSE<ListSE<T>> select(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。- パラメーター:
statement
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換された結果
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
slice
<T> CompletableFutureSE<Slice<T>> slice(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException - パラメーター:
statement
- CQL ステートメントは null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換された結果
- 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
select
<T> CompletableFutureSE<VoidSE> select(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。- パラメーター:
statement
- null であってはなりません。entityConsumer
- 各エンティティで一度に 1 つのオブジェクトが通知されるオブジェクトは null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 完了ハンドル
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
selectOne
<T> CompletableFutureSE<T> selectOne(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。- パラメーター:
statement
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換されたオブジェクトまたは null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
select
<T> CompletableFutureSE<ListSE<T>> select(Query query, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目をエンティティのList
SE に変換します。- パラメーター:
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換された結果
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
slice
<T> CompletableFutureSE<Slice<T>> slice(Query query, ClassSE<T> entityClass) throws DataAccessException ページングを使用してSELECT
クエリを実行し、結果セットをエンティティのSlice
に変換します。- パラメーター:
query
- CQL ステートメントの作成に使用されるクエリオブジェクトは null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換された結果
- 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
select
<T> CompletableFutureSE<VoidSE> select(Query query, ConsumerSE<T> entityConsumer, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果の項目を変換して各エンティティのConsumer
SE に通知します。- パラメーター:
query
- null であってはなりません。entityConsumer
- 各エンティティで一度に 1 つのオブジェクトが通知されるオブジェクトは null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 完了ハンドル
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
selectOne
<T> CompletableFutureSE<T> selectOne(Query query, ClassSE<T> entityClass) throws DataAccessException SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。- パラメーター:
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換されたオブジェクトまたは null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
update
CompletableFutureSE<BooleanSE> update(Query query, Update update, ClassSE<?> entityClass) throws DataAccessException クエリされたエンティティを更新し、更新が適用された場合は true を返します。- パラメーター:
query
- null であってはなりません。update
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 例外:
DataAccessException
- クエリの実行に問題がある場合。
delete
CompletableFutureSE<BooleanSE> delete(Query query, ClassSE<?> entityClass) throws DataAccessException Query
によってテーブルからエンティティ (行)/columns を削除します。- パラメーター:
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 削除が適用された場合は true。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
count
指定されたエンティティクラスの行数を返します。- パラメーター:
entityClass
- エンティティのtype
SE。null であってはなりません。- 戻り値:
- 既存のエンティティの数。
- 例外:
DataAccessException
- クエリの実行中に問題が発生した場合。
count
Query
を適用して、指定されたエンティティクラスの行数を返します。このオーバーライドされたメソッドにより、ユーザーはQuery
述語を使用して選択条件をさらに絞り込み、指定されたtype
SE のエンティティのうち条件に一致するエンティティの数を判断できます。- パラメーター:
query
- 実行するユーザー指定のカウントQuery
。null にすることはできません。entityClass
- エンティティのtype
SE。null であってはなりません。- 戻り値:
- 既存のエンティティの数。
- 例外:
DataAccessException
- クエリの実行中に問題が発生した場合。- 導入:
- 2.1
exists
CompletableFutureSE<BooleanSE> exists(ObjectSE id, ClassSE<?> entityClass) throws DataAccessException 指定されたid
を持つentityClass
の行が存在するかどうかを確認します。- パラメーター:
id
- ID 値。単一の主キーの場合はプレーンな値です。複合主キーの場合は、PrimaryKeyClass
またはMapId
のインスタンスです。null にすることはできません。entityClass
- エンティティのtype
SE。null であってはなりません。- 戻り値:
- オブジェクトが存在する場合は true。
- 例外:
DataAccessException
- クエリの実行中に問題が発生した場合。
exists
CompletableFutureSE<BooleanSE> exists(Query query, ClassSE<?> entityClass) throws DataAccessException entityClass
Query
の結果が少なくとも 1 つの行を生成するかどうかを判別します。- パラメーター:
query
- 実行するユーザー指定のQuery
が存在します。null にすることはできません。entityClass
- エンティティのtype
SE。null であってはなりません。- 戻り値:
- オブジェクトが存在する場合は true。
- 例外:
DataAccessException
- クエリの実行中に問題が発生した場合。- 導入:
- 2.1
selectOneById
<T> CompletableFutureSE<T> selectOneById(ObjectSE id, ClassSE<T> entityClass) throws DataAccessException 指定されたentityClass
に対してid
による選択を実行します。- パラメーター:
id
- Id 値。単一の主キーの場合はプレーンな値です。複合主キーの場合はPrimaryKeyClass
またはMapId
のいずれかです。null にすることはできません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 変換されたオブジェクトまたは null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
insert
指定されたエンティティを挿入し、挿入が適用された場合はエンティティを返します。- パラメーター:
entity
- 挿入するエンティティ。null であってはなりません。- 戻り値:
- 挿入されたエンティティ。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
insert
<T> CompletableFutureSE<EntityWriteResult<T>> insert(T entity, InsertOptions options) throws DataAccessException WriteOptions
を適用する指定されたエンティティを挿入し、挿入が適用された場合はエンティティを返します。- パラメーター:
entity
- 挿入するエンティティ。null であってはなりません。options
- null であってはなりません。- 戻り値:
- この操作の
EntityWriteResult
。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
update
指定されたエンティティを更新し、更新が適用された場合はエンティティを返します。- パラメーター:
entity
- 更新するエンティティ。null であってはなりません。- 戻り値:
- 更新されたエンティティ。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
update
<T> CompletableFutureSE<EntityWriteResult<T>> update(T entity, UpdateOptions options) throws DataAccessException WriteOptions
を適用する指定されたエンティティを更新し、更新が適用された場合はエンティティを返します。- パラメーター:
entity
- 更新するエンティティ。null であってはなりません。options
- null であってはなりません。- 戻り値:
- この操作の
EntityWriteResult
。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
delete
指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。- パラメーター:
entity
- null であってはなりません。- 戻り値:
- 削除されたエンティティ。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
delete
CompletableFutureSE<WriteResult> delete(ObjectSE entity, QueryOptions options) throws DataAccessException QueryOptions
を適用する指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。- パラメーター:
entity
- null であってはなりません。options
- null であってはなりません。- 戻り値:
- この操作の
WriteResult
。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
delete
default CompletableFutureSE<WriteResult> delete(ObjectSE entity, DeleteOptions options) throws DataAccessException DeleteOptions
を適用する指定されたエンティティを削除し、削除ステートメントが適用された場合はエンティティを返します。- パラメーター:
entity
- null であってはなりません。options
- null であってはなりません。- 戻り値:
- この操作の
WriteResult
。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 導入:
- 2.2
- 関連事項:
deleteById
CompletableFutureSE<BooleanSE> deleteById(ObjectSE id, ClassSE<?> entityClass) throws DataAccessException 指定されたオブジェクトを ID によってテーブルから削除します。- パラメーター:
id
- Id 値。単一の主キーの場合はプレーンな値です。複合主キーの場合はPrimaryKeyClass
またはMapId
のいずれかです。null にすることはできません。entityClass
- エンティティ型は null にできません。- 戻り値:
- 削除が適用された場合は true。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
truncate
TRUNCATE
クエリを実行して、指定されたクラスのすべてのエンティティを削除します。- パラメーター:
entityClass
- エンティティ型は null にできません。- 例外:
DataAccessException
- クエリの実行に問題がある場合。