インターフェース ReactiveCqlOperations

メソッドの詳細

• execute

  <T> reactor.core.publisher.Flux<T> execute(ReactiveSessionCallback<T> action) throws org.springframework.dao.DataAccessException

  ReactiveSession で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で任意のデータアクセス操作を実装できます。つまり、CQL DriverException を Spring の DataAccessException 階層に変換できます。

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

  パラメーター:

  action - アクションを指定するコールバックオブジェクト。

  戻り値:

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

  例外:

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

• execute

  reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql) throws org.springframework.dao.DataAccessException

  単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, ReactiveResultSetExtractor<T> rse) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rse - 結果のすべての行を抽出するオブジェクトは null であってはなりません。

  戻り値:

  ReactiveResultSetExtractor によって返される任意の結果オブジェクト。

  例外:

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

  関連事項:

  • query(String, ReactiveResultSetExtractor, Object...)

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされたオブジェクトを含む結果 Flux。

  例外:

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

  関連事項:

  • query(String, RowMapper, Object[])

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされた単一のオブジェクト。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。

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

  関連事項:

  • queryForObject(String, RowMapper, Object[])

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, ClassSE<T> requiredType) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果オブジェクトのクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。

  戻り値:

  必要な型の結果オブジェクト、または CQL NULL の場合は Mono.empty()。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。

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

  関連事項:

  • queryForObject(String, Class, Object[])

• queryForMap

  reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果マップのクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  戻り値:

  結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ) は null であってはなりません。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。

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

  関連事項:

  • queryForMap(String, Object[])
  • ColumnMapRowMapper

• queryForFlux

  <T> reactor.core.publisher.Flux<T> queryForFlux(StringSE cql, ClassSE<T> elementType) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果 Flux のクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  elementType - 結果 Flux 内の要素の必須型 (たとえば、Integer.class) は null であってはなりません。

  戻り値:

  指定された要素型に一致するオブジェクトの Flux。

  例外:

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

  関連事項:

  • queryForFlux(String, Class, Object[])
  • SingleColumnRowMapper

• queryForFlux

  reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(StringSE cql) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果 Flux のクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  戻り値:

  行ごとに MapSE を含む Flux。

  例外:

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

  関連事項:

  • queryForFlux(String, Object[])

• queryForResultSet

  reactor.core.publisher.Mono<ReactiveResultSet> queryForResultSet(StringSE cql) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、ResultSet のクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  戻り値:

  ReactiveResultSet 表現。

  例外:

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

  関連事項:

  • queryForResultSet(String, Object[])

• queryForRows

  reactor.core.publisher.Flux<com.datastax.oss.driver.api.core.cql.Row> queryForRows(StringSE cql) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、行のクエリを実行します。

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

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  戻り値:

  行表現。

  例外:

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

  関連事項:

  • queryForResultSet(String, Object[])

• execute

  reactor.core.publisher.Flux<BooleanSE> execute(org.reactivestreams.Publisher<StringSE> statementPublisher) throws org.springframework.dao.DataAccessException

  CQL ステートメント Publisher から複数の CQL ステートメントを発行します。

  パラメーター:

  statementPublisher - 実行される CQL ステートメントの Publisher を定義します。

  戻り値:

  各ステートメントの影響を受ける行数の配列

  例外:

  org.springframework.dao.DataAccessException - バッチの実行中に問題が発生した場合。

• execute

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

  単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ReactiveResultSetExtractor<T> rse) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  rse - 結果のすべての行を抽出するオブジェクトは null であってはなりません。

  戻り値:

  ReactiveResultSetExtractor によって返される任意の結果オブジェクト。

  例外:

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

  関連事項:

  • query(String, ReactiveResultSetExtractor, Object...)

• query

  <T> reactor.core.publisher.Flux<T> query(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされたオブジェクトを含む結果 Flux。

  例外:

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

  関連事項:

  • query(String, RowMapper, Object[])

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされた単一のオブジェクト。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。

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

  関連事項:

  • queryForObject(String, RowMapper, Object[])

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> requiredType) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果オブジェクトのクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。

  戻り値:

  必要な型の結果オブジェクト、または CQL NULL の場合は Mono.empty()。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。

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

  関連事項:

  • queryForObject(String, Class, Object[])

• queryForMap

  reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果マップのクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  戻り値:

  結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ) は null であってはなりません。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。

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

  関連事項:

  • queryForMap(String, Object[])
  • ColumnMapRowMapper

• queryForFlux

  <T> reactor.core.publisher.Flux<T> queryForFlux(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> elementType) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果 Flux のクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  elementType - 結果 Flux 内の要素の必須型 (たとえば、Integer.class) は null であってはなりません。

  戻り値:

  指定された要素型に一致するオブジェクトの Flux。

  例外:

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

  関連事項:

  • queryForFlux(String, Class, Object[])
  • SingleColumnRowMapper

• queryForFlux

  reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、結果 Flux のクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  戻り値:

  行ごとに MapSE を含む Flux。

  例外:

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

  関連事項:

  • queryForFlux(String, Object[])

• queryForResultSet

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

  静的 CQL を指定して、ResultSet のクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  戻り値:

  ReactiveResultSet 表現。

  例外:

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

  関連事項:

  • queryForResultSet(String, Object[])

• queryForRows

  reactor.core.publisher.Flux<com.datastax.oss.driver.api.core.cql.Row> queryForRows(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws org.springframework.dao.DataAccessException

  静的 CQL を指定して、行のクエリを実行します。

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

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

  パラメーター:

  statement - 静的 CQL Statement は null にできません。

  戻り値:

  行表現。

  例外:

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

  関連事項:

  • queryForResultSet(String, Object[])

• execute

  <T> reactor.core.publisher.Flux<T> execute(ReactivePreparedStatementCreator psc, ReactivePreparedStatementCallback<T> action) throws org.springframework.dao.DataAccessException

  CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一の PreparedStatement に任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException を Spring の DataAccessException 階層に変換できます。

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

  パラメーター:

  psc - ReactiveSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。

  action - アクションを指定するコールバックオブジェクトは null であってはなりません。

  戻り値:

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

  例外:

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

• execute

  <T> reactor.core.publisher.Flux<T> execute(StringSE cql, ReactivePreparedStatementCallback<T> action) throws org.springframework.dao.DataAccessException

  CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一のステートメントに任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException を Spring の DataAccessException 階層に変換できます。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  action - アクションを指定するコールバックオブジェクトは null であってはなりません。

  戻り値:

  アクションによって返された結果オブジェクト、または null

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse) throws org.springframework.dao.DataAccessException

  準備されたステートメントを使用してクエリを実行し、ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。

  パラメーター:

  psc - ReactiveSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。

  rse - 結果を抽出するオブジェクトは null であってはなりません。

  戻り値:

  ReactiveResultSetExtractor によって返される任意の結果オブジェクト

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) throws org.springframework.dao.DataAccessException

  準備されたステートメントを使用してクエリを実行し、ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。

  rse - 結果を抽出するオブジェクトは null であってはなりません。

  戻り値:

  ReactiveResultSetExtractor によって返される任意の結果オブジェクト。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, @Nullable PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) throws org.springframework.dao.DataAccessException

  準備されたステートメントと、クエリに値をバインドする方法を認識している PreparedStatementBinder 実装を使用してクエリを実行し、ResultSetExtractor を使用して ReactiveResultSet を読み取ります。

  パラメーター:

  psc - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。

  psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。

  rse - 結果を抽出するオブジェクトは null であってはなりません。

  戻り値:

  ResultSetExtractor によって返される任意の結果オブジェクト。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, ReactiveResultSetExtractor<T> rse, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rse - 結果を抽出するオブジェクトは null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  ReactiveResultSetExtractor によって返される任意の結果オブジェクト

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  準備済みステートメントを使用してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

  パラメーター:

  psc - ReactiveSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされたオブジェクトを含む結果 Flux。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリに値をバインドする方法を認識し、各行を RowMapper を介して Java オブジェクトにマッピングする PreparedStatementBinder 実装を作成します。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされたオブジェクトを含む結果 Flux。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws org.springframework.dao.DataAccessException

  準備されたステートメントと、値をクエリにバインドする方法を認識する PreparedStatementBinder 実装を使用してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。

  パラメーター:

  psc - CqlSession を指定して PreparedStatement を作成できるオブジェクトは null であってはなりません。

  psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  戻り値:

  マップされたオブジェクトを含む結果 Flux。

  例外:

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

• query

  <T> reactor.core.publisher.Flux<T> query(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントとクエリにバインドする引数のリストを作成し、RowMapper を介して各行を Java オブジェクトにマッピングします。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)

  戻り値:

  結果 Flux にはマップされたオブジェクトが含まれる

  例外:

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

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、RowMapper を介して単一の結果行を Java オブジェクトにマッピングします。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  rowMapper - 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)

  戻り値:

  単一のマッピングされたオブジェクト

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合。

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

• queryForObject

  <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, ClassSE<T> requiredType, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果オブジェクトを期待します。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  requiredType - 結果オブジェクトが一致すると予想される型は null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)

  戻り値:

  必要な型の結果オブジェクト、または CQL NULL の場合は Mono.empty()。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。

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

  関連事項:

  • queryForObject(String, Class)

• queryForMap

  reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果のマップを期待します。このインターフェースで定義されている queryForMap() メソッドは、ドメインモデルがない場合に適しています。それ以外の場合は、queryForObject() メソッドのいずれかを使用することを検討してください。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  結果マップ (列名をキーとして使用し、列ごとに 1 つのエントリ)。

  例外:

  org.springframework.dao.IncorrectResultSizeDataAccessException - クエリが正確に 1 行を返さない場合

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

  関連事項:

  • queryForMap(String)
  • ColumnMapRowMapper

• queryForFlux

  <T> reactor.core.publisher.Flux<T> queryForFlux(StringSE cql, ClassSE<T> elementType, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 Flux を期待します。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  elementType - 結果 Flux 内の要素の必須型 (たとえば、Integer.class) は null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  指定された要素型に一致するオブジェクトの Flux。

  例外:

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

  関連事項:

  • queryForFlux(String, Class)
  • SingleColumnRowMapper

• queryForFlux

  reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(StringSE cql, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 Flux を期待します。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  行ごとに MapSE を含む Flux 

  例外:

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

  関連事項:

  • queryForFlux(String)

• queryForResultSet

  reactor.core.publisher.Mono<ReactiveResultSet> queryForResultSet(StringSE cql, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、ResultSet を期待します。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  ReactiveResultSet 表現。

  例外:

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

  関連事項:

  • queryForResultSet(String)

• queryForRows

  reactor.core.publisher.Flux<com.datastax.oss.driver.api.core.cql.Row> queryForRows(StringSE cql, ObjectSE... args) throws org.springframework.dao.DataAccessException

  指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリスト (行を想定) を作成します。

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

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  Row 表現。

  例外:

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

  関連事項:

  • queryForResultSet(String)

• execute

  reactor.core.publisher.Mono<BooleanSE> execute(ReactivePreparedStatementCreator psc) throws org.springframework.dao.DataAccessException

  ReactivePreparedStatementCreator を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。

  パラメーター:

  psc - CQL と必要なパラメーターを提供するオブジェクトは null であってはなりません。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

  org.springframework.dao.DataAccessException - 実行の発行に問題がある場合。

• execute

  reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql, @Nullable PreparedStatementBinder psb) throws org.springframework.dao.DataAccessException

  指定された CQL を使用して、PreparedStatementBinder を使用してバインドパラメーターを設定するステートメントを発行します。このメソッドは PreparedStatement を作成するため、ReactivePreparedStatementCreator を使用するよりも簡単です。PreparedStatementBinder ではパラメーターを設定するだけです。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  psb - 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

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

• execute

  reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql, ObjectSE... args) throws org.springframework.dao.DataAccessException

  準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。

  パラメーター:

  cql - 実行する静的 CQL は空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

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

• execute

  reactor.core.publisher.Flux<BooleanSE> execute(StringSE cql, org.reactivestreams.Publisher<ObjectSE[]> args) throws org.springframework.dao.DataAccessException

  準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。

  パラメーター:

  cql - バインドパラメーターを含む実行する静的 CQL は、空または null であってはなりません。

  args - クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せます)。

  戻り値:

  ステートメントが適用されたかどうかを示すブール値。

  例外:

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