インターフェース R2dbcEntityOperations

メソッドの詳細

• getDatabaseClient

  DatabaseClient getDatabaseClient()

  基になる DatabaseClient を公開して、SQL 操作を許可します。

  戻り値:

  基礎となる DatabaseClient。

  関連事項:

  • DatabaseClient

• getDataAccessStrategy

  @DeprecatedSE ReactiveDataAccessStrategy getDataAccessStrategy()

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

  ReactiveDataAccessStrategy は将来のリリースで削除されるため、代わりに getConverter() を使用してください。

  基礎となる ReactiveDataAccessStrategy カプセル化ダイアレクトの詳細を公開します。

  戻り値:

  基礎となる ReactiveDataAccessStrategy。

  導入:

  1.1.3

  関連事項:

  • ReactiveDataAccessStrategy

• getConverter

  R2dbcConverter getConverter()

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

  戻り値:

  基礎となる R2dbcConverter。

  導入:

  1.2

• count

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

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

  パラメーター:

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

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

  戻り値:

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

  例外:

  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

• select

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

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

  パラメーター:

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

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

  戻り値:

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

  例外:

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

• selectOne

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

  SELECT クエリを実行し、結果のアイテムをエンティティに変換して、結果が 1 つだけになるようにします。

  パラメーター:

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

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

  戻り値:

  正確に 1 つの結果、または一致するものが見つからない場合は Mono.empty()。

  例外:

  IncorrectResultSizeDataAccessException - 複数の一致が見つかった場合。

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

• update

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

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

  パラメーター:

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

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

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

  戻り値:

  影響を受ける行の数。

  例外:

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

• delete

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

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

  パラメーター:

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

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

  戻り値:

  影響を受ける行の数。

  例外:

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

• query

  <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, ClassSE<T> entityClass) throws DataAccessException

  PreparedOperation を指定して、RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は entityClass にマップされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

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

  戻り値:

  RowsFetchSpec を実現する準備ができました。

  例外:

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

  導入:

  1.4

• query

  <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, ClassSE<?> entityClass, ClassSE<T> resultType) throws DataAccessException

  PreparedOperation を指定して、RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は entityClass にマップされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

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

  resultType - 返されるエンティティの型は null であってはなりません。

  戻り値:

  RowsFetchSpec を実現する準備ができました。

  例外:

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

  導入:

  3.2.1

• query

  default <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, FunctionSE<io.r2dbc.spi.Row,T> rowMapper) throws DataAccessException

  PreparedOperation を指定して、RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は、rowMapperSE を使用してマッピングされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

  rowMapper - 行マッパーは null であってはなりません。

  戻り値:

  rowMapperSE が適用された RowsFetchSpec は、実現する準備ができています。

  例外:

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

  導入:

  1.4

  関連事項:

  • query(PreparedOperation, BiFunction)

• query

  <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, BiFunctionSE<io.r2dbc.spi.Row,io.r2dbc.spi.RowMetadata,T> rowMapper) throws DataAccessException

  PreparedOperation を指定して、RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は、rowMapperSE を使用してマッピングされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

  rowMapper - 行マッパーは null であってはなりません。

  戻り値:

  rowMapperSE が適用された RowsFetchSpec は、実現する準備ができています。

  例外:

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

  導入:

  1.4

• query

  default <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, ClassSE<?> entityClass, FunctionSE<io.r2dbc.spi.Row,T> rowMapper) throws DataAccessException

  PreparedOperation を指定して、entityClass のコンテキストで RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は、rowMapperSE を使用してマッピングされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

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

  rowMapper - 行マッパーは null であってはなりません。

  戻り値:

  rowMapperSE が適用された RowsFetchSpec は、実現する準備ができています。

  例外:

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

  導入:

  1.4

  関連事項:

  • query(PreparedOperation, Class, BiFunction)

• query

  <T> RowsFetchSpec<T> query(PreparedOperation<?> operation, ClassSE<?> entityClass, BiFunctionSE<io.r2dbc.spi.Row,io.r2dbc.spi.RowMetadata,T> rowMapper) throws DataAccessException

  PreparedOperation を指定して、entityClass のコンテキストで RowsFetchSpec のクエリを実行します。PreparedOperation 内で提供されたバインディングはすべて、基礎となる DatabaseClient に適用されます。クエリは、名前付きパラメーターの展開などの追加の前処理なしで、そのまま発行されます。クエリの結果は、rowMapperSE を使用してマッピングされます。

  パラメーター:

  operation - SQL クエリとバインドパラメーターをラップする準備された操作。

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

  rowMapper - 行マッパーは null であってはなりません。

  戻り値:

  rowMapperSE が適用された RowsFetchSpec は、実現する準備ができています。

  例外:

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

  導入:

  1.4

  関連事項:

  • query(PreparedOperation, Class, BiFunction)

• getRowsFetchSpec

  <T> RowsFetchSpec<T> getRowsFetchSpec(DatabaseClient.GenericExecuteSpec executeSpec, ClassSE<?> entityType, ClassSE<T> resultType)

• insert

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

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

  パラメーター:

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

  戻り値:

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

  例外:

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

• update

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

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

  パラメーター:

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

  戻り値:

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

  例外:

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

  TransientDataAccessResourceException - 更新が行に影響しなかった場合。

• delete

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

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

  パラメーター:

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

  戻り値:

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

  例外:

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