クラス AsyncCqlTemplate

java.lang.ObjectSE
org.springframework.data.cassandra.core.cql.CassandraAccessor
org.springframework.data.cassandra.core.cql.AsyncCqlTemplate
実装されたすべてのインターフェース:
InitializingBeanAsyncCqlOperations

public class AsyncCqlTemplate extends CassandraAccessor implements AsyncCqlOperations
これは、非同期 Cassandra データアクセス用の CQL コアパッケージの中心的なクラスです。CQL の使用を簡素化し、一般的なエラーを回避できます。コア CQL ワークフローを実行し、CQL を提供して結果を抽出するためのアプリケーションコードを残します。このクラスは CQL クエリまたは更新を実行し、ResultSet の反復処理を開始し、DriverException 例外をキャッチして、org.springframework.dao パッケージで定義されている汎用的でより情報量の多い例外階層に変換します。

このクラスを使用するコードでは、コールバックインターフェースを実装するだけで、明確に定義された契約が与えられます。PreparedStatementCreator コールバックインターフェースは、Connection を指定して準備されたステートメントを作成し、CQL と必要なパラメーターを提供します。AsyncResultSetExtractor インターフェースは、ResultSet から値を抽出します。2 つの一般的な代替コールバックインターフェースについては、PreparedStatementBinderRowMapper も参照してください。

CqlSession 参照による直接インスタンス化を介してサービス実装内で使用するか、アプリケーションコンテキストで準備して Bean 参照としてサービスに渡すことができます。注: CqlSession は、アプリケーションコンテキストで常に Bean として構成する必要があります。最初のケースではサービスに直接渡され、2 番目のケースでは準備されたテンプレートに渡されます。

このクラスは、コールバックインターフェースと PersistenceExceptionTranslator インターフェースによってパラメーター化できるため、サブクラス化する必要はありません。

このクラスによって実行されるすべての CQL 操作は、ログカテゴリとして "org.springframework.data.cassandra.core.cqlTemplate" を使用してデバッグレベルでログに記録されます。

NOTE: このクラスのインスタンスは、構成後はスレッドセーフです。

導入:
2.0
作成者:
Mark Paluch, John Blum
関連事項:
  • コンストラクターの詳細

  • メソッドの詳細

    • execute

      public <T> CompletableFutureSE<T> execute(AsyncSessionCallback<T> action) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      CqlSession で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で任意のデータアクセス操作を実装できます。つまり、CQL DriverException を Spring の DataAccessException 階層に変換できます。

      コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。

      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      action - アクションを指定するコールバックオブジェクト。
      戻り値:
      アクションによって返される結果オブジェクト、または null。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • execute

      インターフェースからコピーされた説明: AsyncCqlOperations
      単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。
      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      戻り値:
      ステートメントが適用されたかどうかを示すブール値。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(StringSE cql, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、AsyncResultSetExtractor で ResultSet を読み取ります。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      resultSetExtractor - 結果のすべての行を抽出するオブジェクトは null であってはなりません。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • query

      public CompletableFutureSE<VoidSE> query(StringSE cql, RowCallbackHandler rowCallbackHandler) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(StringSE cql, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされたオブジェクトを含む結果 ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForList

      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果 ListSE のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForList メソッドを使用します。

      結果は、MapSE (列名をキーとして使用して各列に 1 つのエントリ) の ListSE (行ごとに 1 つの項目) にマップされます。ListSE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      戻り値:
      行ごとに MapSE を含む ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForList

      public <T> CompletableFutureSE<ListSE<T>> queryForList(StringSE cql, ClassSE<T> elementType) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果 ListSE のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForList メソッドを使用します。

      結果は、指定された要素型に一致する結果オブジェクトの ListSE (行ごとに 1 つの項目) にマップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      elementType - 結果 ListSE の要素の必須型 (たとえば、Integer.class) は null であってはなりません。
      戻り値:
      指定された要素型に一致するオブジェクトの ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForMap

      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果マップのクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForMap(String, Object...) メソッドを使用します。

      クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForMap 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      戻り値:
      結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ) は null であってはなりません。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(StringSE cql, ClassSE<T> requiredType) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果オブジェクトのクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForObject(String, Class, Object...) メソッドを使用します。

      このメソッドは、既知の結果を持つ静的 CQL を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。
      戻り値:
      必要な型の結果オブジェクト、または CQL NULL の場合は null。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(StringSE cql, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForObject(String, RowMapper, Object...) メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされた単一のオブジェクト。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForResultSet

      public CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet> queryForResultSet(StringSE cql) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、ResultSet のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet メソッドを使用します。

      結果は ResultSet にマッピングされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForResultSet 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      戻り値:
      ResultSet 表現。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • execute

      public CompletableFutureSE<BooleanSE> execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。
      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      戻り値:
      ステートメントが適用されたかどうかを示すブール値。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(com.datastax.oss.driver.api.core.cql.Statement<?> statement, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、AsyncResultSetExtractor で ResultSet を読み取ります。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      resultSetExtractor - 結果のすべての行を抽出するオブジェクトは null であってはなりません。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • query

      public CompletableFutureSE<VoidSE> query(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowCallbackHandler rowCallbackHandler) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされたオブジェクトを含む結果 ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForList

      public CompletableFutureSE<ListSE<MapSE<StringSE,ObjectSE>>> queryForList(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果 ListSE のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForList メソッドを使用します。

      結果は、MapSE (列名をキーとして使用して各列に 1 つのエントリ) の ListSE (行ごとに 1 つの項目) にマップされます。ListSE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      statement - 実行する静的 CQL Statement は null または空であってはなりません。
      戻り値:
      行ごとに MapSE を含む ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForList

      public <T> CompletableFutureSE<ListSE<T>> queryForList(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> elementType) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果 ListSE のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForList メソッドを使用します。

      結果は、指定された要素型に一致する結果オブジェクトの ListSE (行ごとに 1 つの項目) にマップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      elementType - 結果 ListSE の要素の必須型 (たとえば、Integer.class) は null であってはなりません。
      戻り値:
      指定された要素型に一致するオブジェクトの ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForMap

      public CompletableFutureSE<MapSE<StringSE,ObjectSE>> queryForMap(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果マップのクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForMap(String, Object...) メソッドを使用します。

      クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForMap 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      戻り値:
      結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ) は null であってはなりません。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> requiredType) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、結果オブジェクトのクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForObject(String, Class, Object...) メソッドを使用します。

      このメソッドは、既知の結果を持つ静的 CQL を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。
      戻り値:
      必要な型の結果オブジェクト、または CQL NULL の場合は null。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた AsyncCqlOperations.queryForObject(String, RowMapper, Object...) メソッドを使用します。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされた単一のオブジェクト。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForResultSet

      public CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet> queryForResultSet(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      静的 CQL を指定して、ResultSet のクエリを実行します。

      PreparedStatement ではなく、CQL ステートメントを使用します。PreparedStatement を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet メソッドを使用します。

      結果は ResultSet にマッピングされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForResultSet 
      パラメーター:
      statement - 静的 CQL Statement は null にできません。
      戻り値:
      ResultSet 表現。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • execute

      public CompletableFutureSE<BooleanSE> execute(AsyncPreparedStatementCreator preparedStatementCreator) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      AsyncPreparedStatementCreator を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。
      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      preparedStatementCreator - CQL と必要なパラメーターを提供するオブジェクトは null であってはなりません。
      戻り値:
      ステートメントが適用されたかどうかを示すブール値。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • execute

      public CompletableFutureSE<BooleanSE> execute(StringSE cql, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。
      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      ステートメントが適用されたかどうかを示すブール値。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • execute

      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL を使用して、PreparedStatementBinder を使用してバインドパラメーターを設定するステートメントを発行します。このメソッドは PreparedStatement を作成するため、AsyncPreparedStatementCreator を使用するよりも簡単です。PreparedStatementBinder ではパラメーターを設定するだけです。
      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      戻り値:
      ステートメントが適用されたかどうかを示すブール値。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • execute

      public <T> CompletableFutureSE<T> execute(StringSE cql, PreparedStatementCallback<T> action) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一のステートメントに任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException を Spring の DataAccessException 階層に変換できます。

      コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。

      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      action - アクションを指定するコールバックオブジェクトは null であってはなりません。
      戻り値:
      アクションによって返された結果オブジェクト、または null
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • execute

      public <T> CompletableFutureSE<T> execute(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementCallback<T> action) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一の PreparedStatement に任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException を Spring の DataAccessException 階層に変換できます。

      コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。

      次で指定:
      インターフェース AsyncCqlOperationsexecute 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      action - アクションを指定するコールバックオブジェクトは null であってはなりません。
      戻り値:
      アクションによって返される結果オブジェクト、または null。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(AsyncPreparedStatementCreator preparedStatementCreator, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor を使用して ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      resultSetExtractor - 結果を抽出するオブジェクトは null であってはなりません。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public CompletableFutureSE<VoidSE> query(AsyncPreparedStatementCreator preparedStatementCreator, RowCallbackHandler rowCallbackHandler) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備済みステートメントを使用してクエリを実行し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(AsyncPreparedStatementCreator preparedStatementCreator, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備済みステートメントを使用してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされたオブジェクトを含む結果 ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(AsyncPreparedStatementCreator preparedStatementCreator, @Nullable PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントと、値をクエリにバインドする方法を認識している PreparedStatementBinder 実装を使用してクエリを実行し、AsyncResultSetExtractor で ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      resultSetExtractor - 結果を抽出するオブジェクトは null であってはなりません。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public CompletableFutureSE<VoidSE> query(AsyncPreparedStatementCreator preparedStatementCreator, @Nullable PreparedStatementBinder psb, RowCallbackHandler rowCallbackHandler) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントと、値をクエリにバインドする方法を認識する PreparedStatementBinder 実装を使用してクエリを実行し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(AsyncPreparedStatementCreator preparedStatementCreator, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントと、値をクエリにバインドする方法を認識する PreparedStatementBinder 実装を使用してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      preparedStatementCreator - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされたオブジェクトを含む結果 ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(StringSE cql, AsyncResultSetExtractor<T> resultSetExtractor, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL からプリペアドステートメントを作成し、クエリにバインドする引数のリストを作成し、AsyncResultSetExtractor で ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      resultSetExtractor - 結果を抽出するオブジェクトは null であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public CompletableFutureSE<VoidSE> query(StringSE cql, RowCallbackHandler rowCallbackHandler, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL からプリペアドステートメントを作成し、クエリにバインドする引数のリストを作成し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントとクエリにバインドする引数のリストを作成し、RowMapper を介して各行を Java オブジェクトにマッピングします。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)
      戻り値:
      結果 ListSE にはマップされたオブジェクトが含まれる
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor を使用して ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      resultSetExtractor - 結果を抽出するオブジェクトは null であってはなりません。
      戻り値:
      AsyncResultSetExtractor によって返される任意の結果オブジェクト。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリに値をバインドする方法を認識している PreparedStatementBinder 実装を作成し、RowCallbackHandler を使用して行ごとに ResultSet を読み取ります。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      rowCallbackHandler - 一度に 1 行ずつ結果を抽出するオブジェクトは null であってはなりません。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • query

      public <T> CompletableFutureSE<ListSE<T>> query(StringSE cql, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL と、値をクエリにバインドする方法を認識する PreparedStatementBinder 実装からプリペアドステートメントを作成し、RowMapper を介して各行を Java オブジェクトにマッピングします。
      次で指定:
      インターフェース AsyncCqlOperationsquery 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      戻り値:
      マップされたオブジェクトを含む結果 ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
    • queryForList

      public CompletableFutureSE<ListSE<MapSE<StringSE,ObjectSE>>> queryForList(StringSE cql, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 ListSE を期待します。

      結果は、MapSE (列名をキーとして使用し、列ごとに 1 つのエントリ) の ListSE (行ごとに 1 つの項目) にマップされます。ListSE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      行ごとに MapSE を含む ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForList

      public <T> CompletableFutureSE<ListSE<T>> queryForList(StringSE cql, ClassSE<T> elementType, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 ListSE を期待します。

      結果は、指定された要素型に一致する結果オブジェクトの ListSE (行ごとに 1 つの項目) にマップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForList 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      elementType - 結果 ListSE の要素の必須型 (たとえば、Integer.class) は null であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      指定された要素型に一致するオブジェクトの ListSE
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForMap

      public CompletableFutureSE<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果のマップを期待します。このインターフェースで定義されている queryForMap() メソッドは、ドメインモデルがない場合に適しています。それ以外の場合は、queryForObject() メソッドのいずれかを使用することを検討してください。

      クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForMap 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ)。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(StringSE cql, ClassSE<T> requiredType, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果オブジェクトを期待します。

      クエリは、単一の行 / 単一列クエリであることが期待されています。返された結果は、対応するオブジェクト型に直接マップされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)
      戻り値:
      必要な型の結果オブジェクト、または CQL NULL の場合は null。
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • queryForObject

      public <T> CompletableFutureSE<T> queryForObject(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、RowMapper を介して単一の結果行を Java オブジェクトにマッピングします。
      次で指定:
      インターフェース AsyncCqlOperationsqueryForObject 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)
      戻り値:
      単一のマッピングされたオブジェクト
      例外:
      IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。
      DataAccessException - クエリの実行に問題がある場合。
    • queryForResultSet

      public CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet> queryForResultSet(StringSE cql, ObjectSE... args) throws DataAccessException
      インターフェースからコピーされた説明: AsyncCqlOperations
      指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、ResultSet を期待します。

      結果は ResultSet にマッピングされます。

      次で指定:
      インターフェース AsyncCqlOperationsqueryForResultSet 
      パラメーター:
      cql - 実行する静的 CQL は null または空であってはなりません。
      args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。
      戻り値:
      ResultSet 表現。
      例外:
      DataAccessException - クエリの実行に問題がある場合。
      関連事項:
    • translateException

      protected DataAccessException translateException(StringSE task, @Nullable StringSE cql, com.datastax.oss.driver.api.core.DriverException ex)
      指定された DriverException を一般的な DataAccessException に変換します。
      パラメーター:
      task - 試行されているタスクを説明する読み取り可能なテキスト
      cql - 問題の原因となった CQL クエリまたは更新 (null の可能性があります)
      ex - 問題の RuntimeException
      戻り値:
      例外変換 FunctionSE
      関連事項:
    • translateExceptionIfPossible

      @Nullable protected DataAccessException translateExceptionIfPossible(StringSE task, @Nullable StringSE cql, RuntimeExceptionSE ex)
      指定された DriverException を一般的な DataAccessException に変換します。
      パラメーター:
      task - 試行されているタスクを説明する読み取り可能なテキスト
      cql - 問題の原因となった CQL クエリまたは更新 (null の可能性があります)
      ex - 問題の RuntimeException
      戻り値:
      変換された DataAccessException、または変換が不可能な場合は null。
      関連事項:
    • newAsyncPreparedStatementCreator

      protected AsyncPreparedStatementCreator newAsyncPreparedStatementCreator(StringSE cql)
      渡された CQL を使用して、新しい CQL ベースの AsyncPreparedStatementCreator を作成します。デフォルトでは、AsyncCqlTemplate.SimpleAsyncPreparedStatementCreator を作成します。このメソッドを使用すると、サブクラスによって作成をオーバーライドできます。
      パラメーター:
      cql - 実行する静的 CQL は空または null であってはなりません。
      戻り値:
      使用する新しい AsyncPreparedStatementCreator
    • newAsyncResultSetExtractor

      protected AsyncCqlTemplate.AsyncRowCallbackHandlerResultSetExtractor newAsyncResultSetExtractor(RowCallbackHandler rowCallbackHandler)
      指定された RowCallbackHandler を適応させて ResultSetExtractor の新しいインスタンスを構築します。
      パラメーター:
      rowCallbackHandler - RowCallbackHandlerResultSetExtractor として適応させます。
      戻り値:
      RowCallbackHandler のインスタンスを適応させた ResultSetExtractor 実装。
      関連事項:
    • newAsyncResultSetExtractor

      protected <T> AsyncRowMapperResultSetExtractor<T> newAsyncResultSetExtractor(RowMapper<T> rowMapper)
      指定された RowMapper を適応させて ResultSetExtractor の新しいインスタンスを構築します。
      パラメーター:
      rowMapper - RowMapperResultSetExtractor として適応させます。
      戻り値:
      RowMapper のインスタンスを適応させた ResultSetExtractor 実装。
      関連事項: