クラス CassandraTemplate

メソッドの詳細

• batchOps

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

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の batchOps 

  パラメーター:

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

  戻り値:

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

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setEntityCallbacks

  public void setEntityCallbacks(@Nullable EntityCallbacks entityCallbacks)

  永続化操作中にエンティティを前処理 / 後処理するように EntityCallbacks を構成します。

  パラメーター:

  entityCallbacks -

• setEntityLifecycleEventsEnabled

  public void setEntityLifecycleEventsEnabled(boolean enabled)

  AfterLoadEvent、BeforeSaveEvent などのライフサイクルイベントを発行するかどうか、発行を抑制するかどうかを構成します。デフォルトで有効になっています。

  パラメーター:

  enabled - エンティティのライフサイクルイベントを有効にする true。エンティティのライフサイクルイベントを無効にする false。

  導入:

  4.0

  関連事項:

  • CassandraMappingEvent

• getCqlOperations

  public CqlOperations getCqlOperations()

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の getCqlOperations 

  戻り値:

  基礎となる CqlOperations。

  関連事項:

  • CqlOperations

• getConverter

  public CassandraConverter getConverter()

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の getConverter 

  戻り値:

  基礎となる CassandraConverter。

• isUsePreparedStatements

  public boolean isUsePreparedStatements()

  このインスタンスが prepared statements を使用するように構成されているかどうかを返します。有効 (デフォルト) の場合、すべての永続化メソッド ( select(java.lang.String, java.lang.Class<T>)、update(org.springframework.data.cassandra.core.query.Query, org.springframework.data.cassandra.core.query.Update, java.lang.Class<?>) など) は準備されたステートメントを使用します。Statement を受け入れるメソッドは、ステートメントの準備に参加するために SimpleStatement インスタンスで呼び出される必要があることに注意してください。

  戻り値:

  準備されたステートメントの使用が有効な場合は true。それ以外の場合は false。

  導入:

  3.2

• setUsePreparedStatements

  public void setUsePreparedStatements(boolean usePreparedStatements)

  prepared statements の使用を有効 / 無効にします。有効 (デフォルト) の場合、すべての永続化メソッド ( select(java.lang.String, java.lang.Class<T>)、update(org.springframework.data.cassandra.core.query.Query, org.springframework.data.cassandra.core.query.Update, java.lang.Class<?>) など) は準備されたステートメントを使用します。Statement を受け入れるメソッドは、ステートメントの準備に参加するために SimpleStatement インスタンスで呼び出される必要があることに注意してください。

  パラメーター:

  usePreparedStatements - 準備されたステートメントを使用するかどうか。

  導入:

  3.2

• getEntityOperations

  protected org.springframework.data.cassandra.core.EntityOperations getEntityOperations()

  Cassandra データソース内のエンティティに対してデータアクセス操作を実行するために使用される EntityOperations を返します。

  戻り値:

  このテンプレートに設定された EntityOperations。

  関連事項:

  • EntityOperations

• getProjectionFactory

  protected SpelAwareProxyProjectionFactory getProjectionFactory()

  使用すべきではありません。

  3.4 以降、代わりに CassandraConverter.getProjectionFactory() を使用してください。

  このテンプレートが CQL クエリ 射影を処理するために使用する、構成された ProjectionFactory への参照を返します。

  戻り値:

  CQL クエリ射影を処理するためにこのテンプレートで使用される、構成された ProjectionFactory への参照。

  導入:

  2.1

  関連事項:

  • SpelAwareProxyProjectionFactory

• getStatementFactory

  protected StatementFactory getStatementFactory()

  このテンプレートによって Cassandra CQL ステートメントを構築および実行するために使用される StatementFactory を返します。

  戻り値:

  Cassandra CQL ステートメントを構築および実行するためにこのテンプレートで使用される StatementFactory。

  導入:

  2.1

  関連事項:

  • StatementFactory

• getTableName

  public com.datastax.oss.driver.api.core.CqlIdentifier getTableName(ClassSE<?> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

  このテンプレートによって指定されたクラスに使用されるテーブル名。

  次で指定:

  インターフェース CassandraOperations の getTableName 

  パラメーター:

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

  戻り値:

  CqlIdentifier

• select

  public <T> ListSE<T> select(StringSE cql, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの ListSE に変換します。

  次で指定:

  インターフェース CassandraOperations の select 

  パラメーター:

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

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

  戻り値:

  変換された結果

• selectOne

  public <T> T selectOne(StringSE cql, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の selectOne 

  パラメーター:

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

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

  戻り値:

  変換されたオブジェクトまたは null。

• stream

  public <T> StreamSE<T> stream(StringSE cql, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの IteratorSE に変換します。

  Cassandra ResultSet をラップする IteratorSE を返します。

  次で指定:

  インターフェース CassandraOperations の stream 

  型パラメーター:

  T - 要素の戻り値の型。

  パラメーター:

  cql - 実行するクエリ。空または null にすることはできません。

  entityClass - IteratorSE ストリーム内の要素のクラス型。null にすることはできません。

  戻り値:

  クエリ結果セット内の要素に対する IteratorSE (ストリーム)。

  例外:

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

• execute

  public com.datastax.oss.driver.api.core.cql.ResultSet execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の execute 

  パラメーター:

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

  戻り値:

  ResultSet

• select

  public <T> ListSE<T> select(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの ListSE に変換します。

  次で指定:

  インターフェース CassandraOperations の select 

  パラメーター:

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

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

  戻り値:

  変換された結果

• selectOne

  public <T> T selectOne(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の selectOne 

  パラメーター:

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

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

  戻り値:

  変換されたオブジェクトまたは null。

• slice

  public <T> Slice<T> slice(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の slice 

  パラメーター:

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

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

  戻り値:

  変換された結果

• stream

  public <T> StreamSE<T> stream(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの IteratorSE に変換します。

  Cassandra ResultSet をラップする IteratorSE を返します。

  次で指定:

  インターフェース CassandraOperations の stream 

  型パラメーター:

  T - 要素の戻り値の型。

  パラメーター:

  statement - 実行するクエリ。空または null にすることはできません。

  entityClass - IteratorSE ストリーム内の要素のクラス型。null にすることはできません。

  戻り値:

  クエリ結果セット内の要素に対する IteratorSE (ストリーム)。

  例外:

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

• select

  public <T> ListSE<T> select(Query query, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの ListSE に変換します。

  次で指定:

  インターフェース CassandraOperations の select 

  パラメーター:

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

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

  戻り値:

  変換された結果

  例外:

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

• selectOne

  public <T> T selectOne(Query query, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の selectOne 

  パラメーター:

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

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

  戻り値:

  変換されたオブジェクトまたは null。

  例外:

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

• slice

  public <T> Slice<T> slice(Query query, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の slice 

  パラメーター:

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

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

  戻り値:

  変換された結果

  例外:

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

  関連事項:

  • CassandraPageRequest

• stream

  public <T> StreamSE<T> stream(Query query, ClassSE<T> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

  SELECT クエリを実行し、結果の項目をエンティティの IteratorSE に変換します。

  Cassandra ResultSet をラップする IteratorSE を返します。

  次で指定:

  インターフェース CassandraOperations の stream 

  型パラメーター:

  T - 要素の戻り値の型。

  パラメーター:

  query - 実行するクエリ。空または null にすることはできません。

  entityClass - IteratorSE ストリーム内の要素のクラス型。null にすることはできません。

  戻り値:

  クエリ結果セット内の要素に対する IteratorSE (ストリーム)。

  例外:

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

• update

  public boolean update(Query query, Update update, ClassSE<?> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の update 

  パラメーター:

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

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

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

  例外:

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

• delete

  public boolean delete(Query query, ClassSE<?> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の delete 

  パラメーター:

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

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

  例外:

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

• count

  public long count(ClassSE<?> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の count 

  パラメーター:

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

  戻り値:

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

• count

  public long count(Query query, ClassSE<?> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の count 

  パラメーター:

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

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

  戻り値:

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

  例外:

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

• exists

  public boolean exists(ObjectSE id, ClassSE<?> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の exists 

  パラメーター:

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

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

  戻り値:

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

• exists

  public boolean exists(Query query, ClassSE<?> entityClass) throws DataAccessException

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の exists 

  パラメーター:

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

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

  戻り値:

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

  例外:

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

• selectOneById

  public <T> T selectOneById(ObjectSE id, ClassSE<T> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の selectOneById 

  パラメーター:

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

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

  戻り値:

  変換されたオブジェクトまたは null。

• insert

  public <T> T insert(T entity)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の insert 

  パラメーター:

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

  戻り値:

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

• insert

  public <T> EntityWriteResult<T> insert(T entity, InsertOptions options)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の insert 

  パラメーター:

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

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

  戻り値:

  この操作の EntityWriteResult。

  関連事項:

  • InsertOptions.empty()

• update

  public <T> T update(T entity)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の update 

  パラメーター:

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

  戻り値:

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

• update

  public <T> EntityWriteResult<T> update(T entity, UpdateOptions options)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の update 

  パラメーター:

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

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

  戻り値:

  この操作の EntityWriteResult。

  関連事項:

  • UpdateOptions.empty()

• delete

  public void delete(ObjectSE entity)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の delete 

  パラメーター:

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

• delete

  public WriteResult delete(ObjectSE entity, QueryOptions options)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の delete 

  パラメーター:

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

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

  戻り値:

  この操作の WriteResult。

  関連事項:

  • QueryOptions.empty()

• deleteById

  public boolean deleteById(ObjectSE id, ClassSE<?> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の deleteById 

  パラメーター:

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

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

• truncate

  public void truncate(ClassSE<?> entityClass)

  インターフェースからコピーされた説明: CassandraOperations

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

  次で指定:

  インターフェース CassandraOperations の truncate 

  パラメーター:

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

• query

  public <T> ExecutableSelectOperation.ExecutableSelect<T> query(ClassSE<T> domainType)

  インターフェースからコピーされた説明: ExecutableSelectOperation

  指定された domainTypeSE に対する Cassandra SELECT クエリ操作の作成を開始します。

  次で指定:

  インターフェース ExecutableSelectOperation の query 

  型パラメーター:

  T - アプリケーションドメインオブジェクトの typeSE。

  パラメーター:

  domainType - クエリするドメインオブジェクトへの typeSE。null にすることはできません。

  戻り値:

  ExecutableSelectOperation.ExecutableSelect の新しいインスタンス。

  関連事項:

  • ExecutableSelectOperation.ExecutableSelect

• insert

  public <T> ExecutableInsertOperation.ExecutableInsert<T> insert(ClassSE<T> domainType)

  インターフェースからコピーされた説明: ExecutableInsertOperation

  指定された domainTypeSE の INSERT 操作の作成を開始します。

  次で指定:

  インターフェース ExecutableInsertOperation の insert 

  パラメーター:

  domainType - 挿入するドメインオブジェクトの typeSE。null にすることはできません。

  戻り値:

  ExecutableInsertOperation.ExecutableInsert の新しいインスタンス。

  関連事項:

  • ExecutableInsertOperation.ExecutableInsert

• update

  public ExecutableUpdateOperation.ExecutableUpdate update(ClassSE<?> domainType)

  インターフェースからコピーされた説明: ExecutableUpdateOperation

  指定された domainTypeSE の UPDATE 操作の作成を開始します。

  次で指定:

  インターフェース ExecutableUpdateOperation の update 

  パラメーター:

  domainType - 更新するドメインオブジェクトの typeSE。null であってはなりません。

  戻り値:

  ExecutableUpdateOperation.ExecutableUpdate の新しいインスタンス。

• delete

  public ExecutableDeleteOperation.ExecutableDelete delete(ClassSE<?> domainType)

  インターフェースからコピーされた説明: ExecutableDeleteOperation

  指定された domainTypeSE の DELETE 操作の作成を開始します。

  次で指定:

  インターフェース ExecutableDeleteOperation の delete 

  パラメーター:

  domainType - 削除するドメインオブジェクトの typeSE。null であってはなりません。

  戻り値:

  ExecutableDeleteOperation.ExecutableDelete の新しいインスタンス。

  関連事項:

  • ExecutableDeleteOperation.ExecutableDelete

• createPreparedStatementHandler

  protected CassandraTemplate.PreparedStatementHandler createPreparedStatementHandler(com.datastax.oss.driver.api.core.cql.Statement<?> statement)

  渡されたステートメントを使用して、新しいステートメントベースの CassandraTemplate.PreparedStatementHandler を作成します。

  このメソッドを使用すると、サブクラスによって作成をオーバーライドできます。

  パラメーター:

  statement - 準備する声明。

  戻り値:

  使用する新しい CassandraTemplate.PreparedStatementHandler。

  導入:

  3.3.3

• maybeEmitEvent

  protected <E extends CassandraMappingEvent<T>, T> void maybeEmitEvent(SupplierSE<E> event)

• maybeCallBeforeConvert

  protected <T> T maybeCallBeforeConvert(T object, com.datastax.oss.driver.api.core.CqlIdentifier tableName)

• maybeCallBeforeSave

  protected <T> T maybeCallBeforeSave(T object, com.datastax.oss.driver.api.core.CqlIdentifier tableName, com.datastax.oss.driver.api.core.cql.Statement<?> statement)