public class R2dbcEntityTemplate extends ObjectSE implements R2dbcEntityOperations, BeanFactoryAware
R2dbcEntityOperations
の実装。エンティティを介した Reactive R2DBC の使用を簡素化し、一般的なエラーを回避できます。このクラスは DatabaseClient
を使用して SQL クエリまたは更新を実行し、Result
に対する反復を開始します。DatabaseClient
参照を使用して直接インスタンス化することにより、サービス実装内で使用できます。または、アプリケーションコンテキストで準備し、Bean 参照としてサービスに提供できます。
ReactiveSelectOperation.ReactiveSelect<T>, ReactiveSelectOperation.SelectWithProjection<T>, ReactiveSelectOperation.SelectWithQuery<T>, ReactiveSelectOperation.SelectWithTable<T>, ReactiveSelectOperation.TerminatingSelect<T>
ReactiveInsertOperation.InsertWithTable<T>, ReactiveInsertOperation.ReactiveInsert<T>, ReactiveInsertOperation.TerminatingInsert<T>
ReactiveUpdateOperation.ReactiveUpdate, ReactiveUpdateOperation.TerminatingUpdate, ReactiveUpdateOperation.UpdateWithQuery, ReactiveUpdateOperation.UpdateWithTable
ReactiveDeleteOperation.DeleteWithQuery, ReactiveDeleteOperation.DeleteWithTable, ReactiveDeleteOperation.ReactiveDelete, ReactiveDeleteOperation.TerminatingDelete
コンストラクターと説明 |
---|
R2dbcEntityTemplate(DatabaseClient databaseClient) DatabaseClient を指定して、新しい R2dbcEntityTemplate を作成します。 |
R2dbcEntityTemplate(DatabaseClient databaseClient, ReactiveDataAccessStrategy strategy) |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<LongSE> | count(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) Query を適用する特定のエンティティクラスの行数を返します。 |
ReactiveDeleteOperation.ReactiveDelete | delete(ClassSE<?> domainType) 指定された domainType SE の DELETE 操作の作成を開始します。 |
reactor.core.publisher.Mono<IntegerSE> | delete(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) Query によってエンティティ(行)/columns をテーブルから削除します。 |
<T> reactor.core.publisher.Mono<T> | delete(T entity) 指定されたエンティティを削除し、削除が適用された場合はエンティティを発行します。 |
reactor.core.publisher.Mono<BooleanSE> | exists(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) entityClass Query の結果が少なくとも 1 つの行を生成するかどうかを判別します。 |
ReactiveDataAccessStrategy | getDataAccessStrategy() 基礎となる ReactiveDataAccessStrategy カプセル化ダイアレクトの詳細を公開します。 |
DatabaseClient | getDatabaseClient() 基になる DatabaseClient を公開して、SQL 操作を許可します。 |
<T> ReactiveInsertOperation.ReactiveInsert<T> | insert(ClassSE<T> domainType) 指定された domainType SE の INSERT 操作の作成を開始します。 |
<T> reactor.core.publisher.Mono<T> | insert(T entity) 指定されたエンティティを挿入し、挿入が適用された場合はエンティティを発行します。 |
<T> ReactiveSelectOperation.ReactiveSelect<T> | select(ClassSE<T> domainType) 指定された domainType SE の SELECT 操作の作成を開始します。 |
<T> reactor.core.publisher.Flux<T> | select(org.springframework.data.relational.core.query.Query query, ClassSE<T> entityClass) SELECT クエリを実行し、結果のアイテムをエンティティのストリームに変換します。 |
<T> reactor.core.publisher.Mono<T> | selectOne(org.springframework.data.relational.core.query.Query query, ClassSE<T> entityClass) SELECT クエリを実行し、結果のアイテムをエンティティに変換します。 |
void | setBeanFactory(BeanFactory beanFactory) |
ReactiveUpdateOperation.ReactiveUpdate | update(ClassSE<?> domainType) 指定された domainType SE の UPDATE 操作の作成を開始します。 |
reactor.core.publisher.Mono<IntegerSE> | update(org.springframework.data.relational.core.query.Query query, org.springframework.data.relational.core.query.Update update, ClassSE<?> entityClass) クエリされたエンティティを更新し、更新が適用された場合は true を返します。 |
<T> reactor.core.publisher.Mono<T> | update(T entity) 指定されたエンティティを更新し、更新が適用された場合はエンティティを発行します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public R2dbcEntityTemplate(DatabaseClient databaseClient)
DatabaseClient
を指定して、新しい R2dbcEntityTemplate
を作成します。databaseClient
- null であってはなりません。public R2dbcEntityTemplate(DatabaseClient databaseClient, ReactiveDataAccessStrategy strategy)
databaseClient
- null であってはなりません。public DatabaseClient getDatabaseClient()
R2dbcEntityOperations
DatabaseClient
を公開して、SQL 操作を許可します。R2dbcEntityOperations
の getDatabaseClient
DatabaseClient
。DatabaseClient
public ReactiveDataAccessStrategy getDataAccessStrategy()
R2dbcEntityOperations
ReactiveDataAccessStrategy
カプセル化ダイアレクトの詳細を公開します。R2dbcEntityOperations
の getDataAccessStrategy
ReactiveDataAccessStrategy
。ReactiveDataAccessStrategy
public void setBeanFactory(BeanFactory beanFactory) throws BeansException
BeanFactoryAware
の setBeanFactory
BeansException
public <T> ReactiveSelectOperation.ReactiveSelect<T> select(ClassSE<T> domainType)
ReactiveSelectOperation
domainType
SE の SELECT
操作の作成を開始します。ReactiveSelectOperation
の select
T
- アプリケーションドメインオブジェクトの type
SE。domainType
- 照会するドメインオブジェクトの type
SE。null であってはなりません。ReactiveSelectOperation.ReactiveSelect
の新しいインスタンス。ReactiveSelectOperation.ReactiveSelect
public <T> ReactiveInsertOperation.ReactiveInsert<T> insert(ClassSE<T> domainType)
ReactiveInsertOperation
domainType
SE の INSERT
操作の作成を開始します。ReactiveInsertOperation
の insert
T
- アプリケーションドメインオブジェクトの type
SE。domainType
- 挿入するドメインオブジェクトの type
SE。null であってはなりません。ReactiveInsertOperation.ReactiveInsert
の新しいインスタンス。ReactiveInsertOperation.ReactiveInsert
public ReactiveUpdateOperation.ReactiveUpdate update(ClassSE<?> domainType)
ReactiveUpdateOperation
domainType
SE の UPDATE
操作の作成を開始します。ReactiveUpdateOperation
の update
domainType
- 更新するドメインオブジェクトの type
SE。null であってはなりません。ReactiveUpdateOperation.ReactiveUpdate
の新しいインスタンス。ReactiveUpdateOperation.ReactiveUpdate
public ReactiveDeleteOperation.ReactiveDelete delete(ClassSE<?> domainType)
ReactiveDeleteOperation
domainType
SE の DELETE
操作の作成を開始します。ReactiveDeleteOperation
の delete
domainType
- 削除するドメインオブジェクトの type
SE。null であってはなりません。ReactiveDeleteOperation.ReactiveDelete
の新しいインスタンス。ReactiveDeleteOperation.ReactiveDelete
public reactor.core.publisher.Mono<LongSE> count(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) throws DataAccessException
R2dbcEntityOperations
Query
を適用する特定のエンティティクラスの行数を返します。このオーバーライドされたメソッドにより、ユーザーは Query
述語を使用して選択クエリをさらに絞り込み、指定された type
SE のエンティティがクエリに一致する数を決定できます。R2dbcEntityOperations
の count
query
- 実行するユーザー定義のカウント Query
。null であってはなりません。entityClass
- エンティティの type
SE。null であってはなりません。DataAccessException
- クエリの実行中に問題が発生した場合。public reactor.core.publisher.Mono<BooleanSE> exists(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) throws DataAccessException
R2dbcEntityOperations
entityClass
Query
の結果が少なくとも 1 つの行を生成するかどうかを判別します。R2dbcEntityOperations
の exists
query
- 実行するユーザー定義の Query
が存在します。null であってはなりません。entityClass
- エンティティの type
SE。null であってはなりません。DataAccessException
- クエリの実行中に問題が発生した場合。public <T> reactor.core.publisher.Flux<T> select(org.springframework.data.relational.core.query.Query query, ClassSE<T> entityClass) throws DataAccessException
R2dbcEntityOperations
SELECT
クエリを実行し、結果のアイテムをエンティティのストリームに変換します。R2dbcEntityOperations
の select
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。DataAccessException
- 実行の発行に問題がある場合。public <T> reactor.core.publisher.Mono<T> selectOne(org.springframework.data.relational.core.query.Query query, ClassSE<T> entityClass) throws DataAccessException
R2dbcEntityOperations
SELECT
クエリを実行し、結果のアイテムをエンティティに変換します。R2dbcEntityOperations
の selectOne
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。Mono.empty()
によって返された結果オブジェクト。DataAccessException
- 実行の発行に問題がある場合。public reactor.core.publisher.Mono<IntegerSE> update(org.springframework.data.relational.core.query.Query query, org.springframework.data.relational.core.query.Update update, ClassSE<?> entityClass) throws DataAccessException
R2dbcEntityOperations
R2dbcEntityOperations
の update
query
- null であってはなりません。update
- null であってはなりません。entityClass
- エンティティ型は null にできません。DataAccessException
- クエリの実行に問題がある場合。public reactor.core.publisher.Mono<IntegerSE> delete(org.springframework.data.relational.core.query.Query query, ClassSE<?> entityClass) throws DataAccessException
R2dbcEntityOperations
Query
によってエンティティ(行)/columns をテーブルから削除します。R2dbcEntityOperations
の delete
query
- null であってはなりません。entityClass
- エンティティ型は null にできません。DataAccessException
- 実行の発行に問題がある場合。public <T> reactor.core.publisher.Mono<T> insert(T entity) throws DataAccessException
R2dbcEntityOperations
R2dbcEntityOperations
の insert
entity
- 挿入するエンティティ。null であってはなりません。DataAccessException
- 実行の発行に問題がある場合。public <T> reactor.core.publisher.Mono<T> update(T entity) throws DataAccessException
R2dbcEntityOperations
R2dbcEntityOperations
の update
entity
- 更新するエンティティ。null であってはなりません。DataAccessException
- 実行の発行に問題がある場合。TransientDataAccessResourceException
- 更新が行に影響しなかった場合。public <T> reactor.core.publisher.Mono<T> delete(T entity) throws DataAccessException
R2dbcEntityOperations
R2dbcEntityOperations
の delete
entity
- null であってはなりません。DataAccessException
- 実行の発行に問題がある場合。Copyright © 2018–2020 Pivotal Software, Inc.. All rights reserved.