public class ReactiveCqlTemplate extends ReactiveCassandraAccessor implements ReactiveCqlOperations
ReactiveResultSet
の反復処理を開始し、DriverException
例外をキャッチして、org.springframework.dao
パッケージで定義されている汎用的でより情報量の多い例外階層に変換します。 このクラスを使用するコードでは、コールバックインターフェースを実装するだけで、明確に定義された契約が与えられます。PreparedStatementCreator
コールバックインターフェースは、Connection を指定して準備されたステートメントを作成し、CQL と必要なパラメーターを提供します。ResultSetExtractor
インターフェースは、ReactiveResultSet
から値を抽出します。2 つの一般的な代替コールバックインターフェースについては、PreparedStatementBinder
と RowMapper
も参照してください。
ReactiveSessionFactory
参照による直接インスタンス化を介してサービス実装内で使用するか、アプリケーションコンテキストで準備して Bean 参照としてサービスに渡すことができます。注: ReactiveSessionFactory
は、アプリケーションコンテキストで常に Bean として構成する必要があります。最初のケースではサービスに直接渡され、2 番目のケースでは準備されたテンプレートに渡されます。
このクラスは、コールバックインターフェースと PersistenceExceptionTranslator
インターフェースによってパラメーター化できるため、サブクラス化する必要はありません。
このクラスによって実行されるすべての CQL 操作は、ログカテゴリとして "org.springframework.data.cassandra.core.cql.ReactiveCqlTemplate" を使用してデバッグレベルでログに記録されます。
NOTE: このクラスのインスタンスは、構成後はスレッドセーフです。
PreparedStatementCreator
, PreparedStatementBinder
, PreparedStatementCallback
, ResultSetExtractor
, RowCallbackHandler
, RowMapper
, PersistenceExceptionTranslator
logger
コンストラクターと説明 |
---|
ReactiveCqlTemplate() 新しい ReactiveCqlTemplate を構築します。注: インスタンスを使用する前に、{@link ReactiveSessionFactory} を設定する必要があります。 |
ReactiveCqlTemplate(ReactiveSession reactiveSession) ReactiveSession を指定して、新しい ReactiveCqlTemplate を構築します。 |
ReactiveCqlTemplate(ReactiveSessionFactory reactiveSessionFactory) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | applyStatementSettings(com.datastax.driver.core.PreparedStatement stmt) 再試行ポリシーや一貫性レベルなどのステートメント設定を適用して、指定された CQL ステートメント (または PreparedStatement ) を準備します。 |
protected void | applyStatementSettings(com.datastax.driver.core.Statement stmt) フェッチサイズ、再試行ポリシー、一貫性レベルなどのステートメント設定を適用して、指定された CQL ステートメント (または PreparedStatement ) を準備します。 |
protected <T> reactor.core.publisher.Flux<T> | createFlux(ReactiveSessionCallback<T> callback) 例外変換なしで ReactiveSessionCallback を指定して再利用可能な Flux を作成します。 |
protected <T> reactor.core.publisher.Flux<T> | createFlux(com.datastax.driver.core.Statement statement, ReactiveStatementCallback<T> callback) 例外変換なしで ReactiveStatementCallback を指定して再利用可能な Flux を作成します。 |
protected <T> reactor.core.publisher.Mono<T> | createMono(com.datastax.driver.core.Statement statement, ReactiveStatementCallback<T> callback) 例外変換なしで ReactiveStatementCallback を指定して再利用可能な Mono を作成します。 |
reactor.core.publisher.Flux<BooleanSE> | execute(org.reactivestreams.Publisher<StringSE> statementPublisher) CQL ステートメント Publisher から複数の CQL ステートメントを発行します。 |
reactor.core.publisher.Mono<BooleanSE> | execute(ReactivePreparedStatementCreator psc) ReactivePreparedStatementCreator を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。 |
<T> reactor.core.publisher.Flux<T> | execute(ReactivePreparedStatementCreator psc, ReactivePreparedStatementCallback<T> action) CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。 |
<T> reactor.core.publisher.Flux<T> | execute(ReactiveSessionCallback<T> action) ReactiveSession で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。 |
reactor.core.publisher.Mono<BooleanSE> | execute(com.datastax.driver.core.Statement statement) 単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。 |
reactor.core.publisher.Mono<BooleanSE> | execute(StringSE cql) 単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。 |
reactor.core.publisher.Mono<BooleanSE> | execute(StringSE cql, ObjectSE... args) 準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。 |
reactor.core.publisher.Mono<BooleanSE> | execute(StringSE cql, PreparedStatementBinder psb) 指定された CQL を使用して、 PreparedStatementBinder を使用してバインドパラメーターを設定するステートメントを発行します。 |
reactor.core.publisher.Flux<BooleanSE> | execute(StringSE cql, org.reactivestreams.Publisher<ObjectSE[]> args) 準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。 |
<T> reactor.core.publisher.Flux<T> | execute(StringSE cql, ReactivePreparedStatementCallback<T> action) CQL PreparedStatement で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。 |
protected RowMapper<MapSE<StringSE, ObjectSE>> | getColumnMapRowMapper() 列をキーと値のペアとして読み取るための新しい RowMapper を作成します。 |
com.datastax.driver.core.ConsistencyLevel | getConsistencyLevel() |
int | getFetchSize() |
com.datastax.driver.core.policies.RetryPolicy | getRetryPolicy() |
protected <T> RowMapper<T> | getSingleColumnRowMapper(ClassSE<T> requiredType) 単一の列から結果オブジェクトを読み取るための新しい RowMapper を作成します。 |
protected PreparedStatementBinder | newArgPreparedStatementBinder(ObjectSE[] args) 渡された引数を使用して、新しい引数ベースの PreparedStatementSetter を作成します。 |
protected ReactivePreparedStatementCreator | newReactivePreparedStatementCreator(StringSE cql) 渡された CQL を使用して、新しい CQL ベースの ReactivePreparedStatementCreator を作成します。 |
<T> reactor.core.publisher.Flux<T> | query(ReactivePreparedStatementCreator psc, PreparedStatementBinder preparedStatementBinder, ReactiveResultSetExtractor<T> rse) 準備されたステートメントを使用してクエリを実行し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(ReactivePreparedStatementCreator psc, PreparedStatementBinder psb, RowMapper<T> rowMapper) 準備されたステートメントと、値をクエリにバインドする方法を認識する PreparedStatementBinder 実装を使用してクエリを実行し、RowMapper を介して各行を Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Flux<T> | query(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse) 準備されたステートメントを使用してクエリを実行し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(ReactivePreparedStatementCreator psc, RowMapper<T> rowMapper) 準備済みステートメントを使用してクエリを実行し、 RowMapper を介して各行を Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Flux<T> | query(com.datastax.driver.core.Statement statement, ReactiveResultSetExtractor<T> rse) 静的 CQL を指定してクエリを実行し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(com.datastax.driver.core.Statement statement, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、 RowMapper を介して各行を Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) 準備されたステートメントを使用してクエリを実行し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, PreparedStatementBinder psb, RowMapper<T> rowMapper) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリに値をバインドする方法を認識し、各行を RowMapper を介して Java オブジェクトにマッピングする PreparedStatement Binder 実装を作成します。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, ReactiveResultSetExtractor<T> resultSetExtractor) 静的 CQL を指定してクエリを実行し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, ReactiveResultSetExtractor<T> rse, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、 ReactiveResultSetExtractor を使用して ReactiveResultSet を読み取ります。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、 RowMapper を介して各行を Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Flux<T> | query(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントとクエリにバインドする引数のリストを作成し、 RowMapper を介して各行を Java オブジェクトにマッピングします。 |
reactor.core.publisher.Flux<MapSE<StringSE, ObjectSE>> | queryForFlux(com.datastax.driver.core.Statement statement) 静的 CQL を指定して、結果 Flux のクエリを実行します。 |
<T> reactor.core.publisher.Flux<T> | queryForFlux(com.datastax.driver.core.Statement statement, ClassSE<T> elementType) 静的 CQL を指定して、結果 Flux のクエリを実行します。 |
reactor.core.publisher.Flux<MapSE<StringSE, ObjectSE>> | queryForFlux(StringSE cql) 静的 CQL を指定して、結果 Flux のクエリを実行します。 |
<T> reactor.core.publisher.Flux<T> | queryForFlux(StringSE cql, ClassSE<T> elementType) 静的 CQL を指定して、結果 Flux のクエリを実行します。 |
<T> reactor.core.publisher.Flux<T> | queryForFlux(StringSE cql, ClassSE<T> elementType, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 Flux を期待します。 |
reactor.core.publisher.Flux<MapSE<StringSE, ObjectSE>> | queryForFlux(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果 Flux を期待します。 |
reactor.core.publisher.Mono<MapSE<StringSE, ObjectSE>> | queryForMap(com.datastax.driver.core.Statement statement) 静的 CQL を指定して、結果マップのクエリを実行します。 |
reactor.core.publisher.Mono<MapSE<StringSE, ObjectSE>> | queryForMap(StringSE cql) 静的 CQL を指定して、結果マップのクエリを実行します。 |
reactor.core.publisher.Mono<MapSE<StringSE, ObjectSE>> | queryForMap(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果のマップを期待します。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(com.datastax.driver.core.Statement statement, ClassSE<T> requiredType) 静的 CQL を指定して、結果オブジェクトのクエリを実行します。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(com.datastax.driver.core.Statement statement, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(StringSE cql, ClassSE<T> requiredType) 静的 CQL を指定して、結果オブジェクトのクエリを実行します。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(StringSE cql, ClassSE<T> requiredType, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果オブジェクトを期待します。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(StringSE cql, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、単一の結果行を RowMapper 経由で Java オブジェクトにマッピングします。 |
<T> reactor.core.publisher.Mono<T> | queryForObject(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、 RowMapper を介して単一の結果行を Java オブジェクトにマッピングします。 |
reactor.core.publisher.Mono<ReactiveResultSet> | queryForResultSet(com.datastax.driver.core.Statement statement) 静的 CQL を指定して、ResultSet のクエリを実行します。 |
reactor.core.publisher.Mono<ReactiveResultSet> | queryForResultSet(StringSE cql) 静的 CQL を指定して、ResultSet のクエリを実行します。 |
reactor.core.publisher.Mono<ReactiveResultSet> | queryForResultSet(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、ResultSet を期待します。 |
reactor.core.publisher.Flux<com.datastax.driver.core.Row> | queryForRows(com.datastax.driver.core.Statement statement) 静的 CQL を指定して、行のクエリを実行します。 |
reactor.core.publisher.Flux<com.datastax.driver.core.Row> | queryForRows(StringSE cql) 静的 CQL を指定して、行のクエリを実行します。 |
reactor.core.publisher.Flux<com.datastax.driver.core.Row> | queryForRows(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリスト (行を想定) を作成します。 |
void | setConsistencyLevel(com.datastax.driver.core.ConsistencyLevel consistencyLevel) この ReactiveCqlTemplate の一貫性レベルを設定します。 |
void | setFetchSize(int fetchSize) この ReactiveCqlTemplate のフェッチサイズを設定します。 |
void | setRetryPolicy(com.datastax.driver.core.policies.RetryPolicy retryPolicy) この ReactiveCqlTemplate の再試行ポリシーを設定します。 |
protected FunctionSE<ThrowableSE, ThrowableSE> | translateException(StringSE task, StringSE cql) Mono#otherwise(Function) での使用を目的とした例外変換 Function SE。 |
afterPropertiesSet, getExceptionTranslator, getSessionFactory, setExceptionTranslator, setSessionFactory, translate, translateExceptionIfPossible
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public ReactiveCqlTemplate()
public ReactiveCqlTemplate(ReactiveSession reactiveSession)
ReactiveSession
を指定して、新しい ReactiveCqlTemplate
を構築します。reactiveSession
- ReactiveSession
は null であってはなりません。public ReactiveCqlTemplate(ReactiveSessionFactory reactiveSessionFactory)
reactiveSessionFactory
- ReactiveSession
を取得する ReactiveSessionFactory
は null であってはなりません。public void setConsistencyLevel(@Nullable com.datastax.driver.core.ConsistencyLevel consistencyLevel)
ReactiveCqlTemplate
の一貫性レベルを設定します。一貫性レベルは、クエリ処理に関係するノードの数を定義します。緩やかな一貫性レベル設定では、使用するノードは少なくなりますが、最終的な一貫性が実現される可能性が高くなります。一方、一貫性レベルが高いと、より多くのノードが関係し、より高い一貫性保証で結果が得られます。Statement.setConsistencyLevel(ConsistencyLevel)
, RetryPolicy
@Nullable public com.datastax.driver.core.ConsistencyLevel getConsistencyLevel()
ReactiveCqlTemplate
に指定された ConsistencyLevel
。public void setFetchSize(int fetchSize)
ReactiveCqlTemplate
のフェッチサイズを設定します。これは、大きな結果セットを処理する場合に重要です。この値をデフォルト値より高く設定すると、メモリ消費量は増えますが、処理速度が向上します。この値を低く設定すると、アプリケーションによって読み取られることのない行データの転送を回避できます。デフォルトは -1 で、CQL ドライバーのデフォルト構成を使用する (つまり、特定のフェッチサイズ設定をドライバーに渡さない) ことを示します。Statement.setFetchSize(int)
public int getFetchSize()
ReactiveCqlTemplate
に指定されたフェッチサイズ。public void setRetryPolicy(@Nullable com.datastax.driver.core.policies.RetryPolicy retryPolicy)
ReactiveCqlTemplate
の再試行ポリシーを設定します。これは、リクエストが失敗した場合の動作を定義するために重要です。Statement.setRetryPolicy(RetryPolicy)
, RetryPolicy
@Nullable public com.datastax.driver.core.policies.RetryPolicy getRetryPolicy()
ReactiveCqlTemplate
に指定された RetryPolicy
。public <T> reactor.core.publisher.Flux<T> execute(ReactiveSessionCallback<T> action) throws DataAccessException
ReactiveCqlOperations
ReactiveSession
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で任意のデータアクセス操作を実装できます。つまり、CQL DriverException
を Spring の DataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
ReactiveCqlOperations
の execute
action
- アクションを指定するコールバックオブジェクト。DataAccessException
- クエリの実行に問題がある場合。public reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql) throws DataAccessException
ReactiveCqlOperations
ReactiveCqlOperations
の execute
cql
- 実行する静的 CQL は空または null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(StringSE cql, ReactiveResultSetExtractor<T> resultSetExtractor) throws DataAccessException
ReactiveCqlOperations
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query
メソッドを使用します。
ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。resultSetExtractor
- 結果のすべての行を抽出するオブジェクトは null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.query(String, ReactiveResultSetExtractor, Object...)
public <T> reactor.core.publisher.Flux<T> query(StringSE cql, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して各行を Java オブジェクトにマッピングします。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query
メソッドを使用します。
ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.query(String, RowMapper, Object[])
public <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
経由で Java オブジェクトにマッピングします。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForObject(String, RowMapper, Object...)
メソッドを使用します。
ReactiveCqlOperations
の queryForObject
cql
- 実行する静的 CQL は空または null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForObject(String, RowMapper, Object[])
public <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, ClassSE<T> requiredType) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForObject(String, Class, Object...)
メソッドを使用します。
このメソッドは、既知の結果を持つ静的 CQL を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。
ReactiveCqlOperations
の queryForObject
cql
- 実行する静的 CQL は空または null であってはなりません。requiredType
- 結果オブジェクトが一致すると予想される型は null であってはなりません。Mono.empty()
。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForObject(String, Class, Object[])
public reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForMap(String, Object...)
メソッドを使用します。
クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。
ReactiveCqlOperations
の queryForMap
cql
- 実行する静的 CQL は空または null であってはなりません。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForMap(String, Object[])
, ColumnMapRowMapper
public <T> reactor.core.publisher.Flux<T> queryForFlux(StringSE cql, ClassSE<T> elementType) throws DataAccessException
ReactiveCqlOperations
Flux
のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForFlux
メソッドを使用します。
結果は、指定された要素型に一致する結果オブジェクトの Flux
(行ごとに 1 つの項目) にマップされます。
ReactiveCqlOperations
の queryForFlux
cql
- 実行する静的 CQL は空または null であってはなりません。elementType
- 結果 Flux
内の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String, Class, Object[])
, SingleColumnRowMapper
public reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(StringSE cql) throws DataAccessException
ReactiveCqlOperations
Flux
のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForFlux
メソッドを使用します。
結果は、Map
SE (列名をキーとして使用して各列に 1 つのエントリ) の Flux
(行ごとに 1 つの項目) にマップされます。Flux
の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。
ReactiveCqlOperations
の queryForFlux
cql
- 実行する静的 CQL は空または null であってはなりません。Map
SE を含む Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String, Object[])
public reactor.core.publisher.Mono<ReactiveResultSet> queryForResultSet(StringSE cql) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet
メソッドを使用します。
結果は ReactiveResultSet
にマッピングされます。
ReactiveCqlOperations
の queryForResultSet
cql
- 実行する静的 CQL は空または null であってはなりません。ReactiveResultSet
表現。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String, Object[])
public reactor.core.publisher.Flux<com.datastax.driver.core.Row> queryForRows(StringSE cql) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet
メソッドを使用します。
結果は Row
にマッピングされます。
ReactiveCqlOperations
の queryForRows
cql
- 実行する静的 CQL は空または null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String, Object[])
public reactor.core.publisher.Flux<BooleanSE> execute(org.reactivestreams.Publisher<StringSE> statementPublisher) throws DataAccessException
ReactiveCqlOperations
Publisher
から複数の CQL ステートメントを発行します。ReactiveCqlOperations
の execute
statementPublisher
- 実行される CQL ステートメントの Publisher
を定義します。DataAccessException
- バッチの実行中に問題が発生した場合。public reactor.core.publisher.Mono<BooleanSE> execute(com.datastax.driver.core.Statement statement) throws DataAccessException
ReactiveCqlOperations
ReactiveCqlOperations
の execute
statement
- 静的 CQL Statement
は null にできません。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(com.datastax.driver.core.Statement statement, ReactiveResultSetExtractor<T> rse) throws DataAccessException
ReactiveCqlOperations
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query
メソッドを使用します。
ReactiveCqlOperations
の query
statement
- 静的 CQL Statement
は null にできません。rse
- 結果のすべての行を抽出するオブジェクトは null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.query(String, ReactiveResultSetExtractor, Object...)
public <T> reactor.core.publisher.Flux<T> query(com.datastax.driver.core.Statement statement, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して各行を Java オブジェクトにマッピングします。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた query
メソッドを使用します。
ReactiveCqlOperations
の query
statement
- 静的 CQL Statement
は null にできません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.query(String, RowMapper, Object[])
public <T> reactor.core.publisher.Mono<T> queryForObject(com.datastax.driver.core.Statement statement, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
経由で Java オブジェクトにマッピングします。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForObject(String, RowMapper, Object...)
メソッドを使用します。
ReactiveCqlOperations
の queryForObject
statement
- 静的 CQL Statement
は null にできません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForObject(String, RowMapper, Object[])
public <T> reactor.core.publisher.Mono<T> queryForObject(com.datastax.driver.core.Statement statement, ClassSE<T> requiredType) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForObject(String, Class, Object...)
メソッドを使用します。
このメソッドは、既知の結果を持つ静的 CQL を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。
ReactiveCqlOperations
の queryForObject
statement
- 静的 CQL Statement
は null にできません。requiredType
- 結果オブジェクトが一致すると予想される型は null であってはなりません。Mono.empty()
。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForObject(String, Class, Object[])
public reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(com.datastax.driver.core.Statement statement) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた ReactiveCqlOperations.queryForMap(String, Object...)
メソッドを使用します。
クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。
ReactiveCqlOperations
の queryForMap
statement
- 静的 CQL Statement
は null にできません。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForMap(String, Object[])
, ColumnMapRowMapper
public <T> reactor.core.publisher.Flux<T> queryForFlux(com.datastax.driver.core.Statement statement, ClassSE<T> elementType) throws DataAccessException
ReactiveCqlOperations
Flux
のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForFlux
メソッドを使用します。
結果は、指定された要素型に一致する結果オブジェクトの Flux
(行ごとに 1 つの項目) にマップされます。
ReactiveCqlOperations
の queryForFlux
statement
- 静的 CQL Statement
は null にできません。elementType
- 結果 Flux
内の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String, Class, Object[])
, SingleColumnRowMapper
public reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(com.datastax.driver.core.Statement statement) throws DataAccessException
ReactiveCqlOperations
Flux
のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForFlux
メソッドを使用します。
結果は、Map
SE (列名をキーとして使用して各列に 1 つのエントリ) の Flux
(行ごとに 1 つの項目) にマップされます。Flux
の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。
ReactiveCqlOperations
の queryForFlux
statement
- 静的 CQL Statement
は null にできません。Map
SE を含む Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String, Object[])
public reactor.core.publisher.Mono<ReactiveResultSet> queryForResultSet(com.datastax.driver.core.Statement statement) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet
メソッドを使用します。
結果は ReactiveResultSet
にマッピングされます。
ReactiveCqlOperations
の queryForResultSet
statement
- 静的 CQL Statement
は null にできません。ReactiveResultSet
表現。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String, Object[])
public reactor.core.publisher.Flux<com.datastax.driver.core.Row> queryForRows(com.datastax.driver.core.Statement statement) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされた queryForResultSet
メソッドを使用します。
結果は Row
にマッピングされます。
ReactiveCqlOperations
の queryForRows
statement
- 静的 CQL Statement
は null にできません。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String, Object[])
public <T> reactor.core.publisher.Flux<T> execute(ReactivePreparedStatementCreator psc, ReactivePreparedStatementCallback<T> action) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一の PreparedStatement
に任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException
を Spring の DataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
ReactiveCqlOperations
の execute
psc
- ReactiveSession
を指定して PreparedStatement
を作成できるオブジェクトは null であってはなりません。action
- アクションを指定するコールバックオブジェクトは null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> execute(StringSE cql, ReactivePreparedStatementCallback<T> action) throws DataAccessException
ReactiveCqlOperations
PreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一のステートメントに任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQL DriverException
を Spring の DataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
ReactiveCqlOperations
の execute
cql
- 実行する静的 CQL は空または null であってはなりません。action
- アクションを指定するコールバックオブジェクトは null であってはなりません。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, @Nullable PreparedStatementBinder preparedStatementBinder, ReactiveResultSetExtractor<T> rse) throws DataAccessException
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。ReactiveCqlOperations
の query
psc
- ReactiveSession
を与えられた場合に PreparedStatement
を作成できるオブジェクト preparedStatementBinder
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。rse
- 結果を抽出するオブジェクト ReactiveResultSetExtractor
によって返される任意の結果オブジェクト DataAccessException
- 問題がある場合 public <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, ReactiveResultSetExtractor<T> rse) throws DataAccessException
ReactiveCqlOperations
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。ReactiveCqlOperations
の query
psc
- ReactiveSession
を指定して PreparedStatement
を作成できるオブジェクトは null であってはなりません。rse
- 結果を抽出するオブジェクトは null であってはなりません。ReactiveResultSetExtractor
によって返される任意の結果オブジェクト DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, ReactiveResultSetExtractor<T> rse) throws DataAccessException
ReactiveCqlOperations
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。rse
- 結果を抽出するオブジェクトは null であってはなりません。ReactiveResultSetExtractor
によって返される任意の結果オブジェクト。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(StringSE cql, ReactiveResultSetExtractor<T> rse, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
ReactiveResultSetExtractor
を使用して ReactiveResultSet
を読み取ります。ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。rse
- 結果を抽出するオブジェクトは null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。ReactiveResultSetExtractor
によって返される任意の結果オブジェクト DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して各行を Java オブジェクトにマッピングします。ReactiveCqlOperations
の query
psc
- ReactiveSession
を指定して PreparedStatement
を作成できるオブジェクトは null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。Flux
。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して Java オブジェクトにマッピングする PreparedStatement
Binder 実装を作成します。ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。Flux
。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(ReactivePreparedStatementCreator psc, @Nullable PreparedStatementBinder psb, RowMapper<T> rowMapper) throws DataAccessException
ReactiveCqlOperations
PreparedStatementBinder
実装を使用してクエリを実行し、RowMapper
を介して各行を Java オブジェクトにマッピングします。ReactiveCqlOperations
の query
psc
- Session
を指定して PreparedStatement
を作成できるオブジェクトは null であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。Flux
。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Flux<T> query(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して各行を Java オブジェクトにマッピングします。ReactiveCqlOperations
の query
cql
- 実行する静的 CQL は空または null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せる)Flux
にはマップされたオブジェクトが含まれる DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
RowMapper
を介して単一の結果行を Java オブジェクトにマッピングします。ReactiveCqlOperations
の queryForObject
cql
- 実行する静的 CQL は空または null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せる)IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合。DataAccessException
- クエリの実行に問題がある場合。public <T> reactor.core.publisher.Mono<T> queryForObject(StringSE cql, ClassSE<T> requiredType, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
クエリは、単一の行 / 単一列クエリであることが期待されています。返された結果は、対応するオブジェクト型に直接マップされます。
ReactiveCqlOperations
の queryForObject
cql
- 実行する静的 CQL は空または null であってはなりません。requiredType
- 結果オブジェクトが一致すると予想される型は null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement に任せる)Mono.empty()
。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合、またはその行に正確に 1 列を返さない場合。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForObject(String, Class)
public reactor.core.publisher.Mono<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。
ReactiveCqlOperations
の queryForMap
cql
- 実行する静的 CQL は空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。IncorrectResultSizeDataAccessException
- クエリが正確に 1 行を返さない場合 DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForMap(String)
, ColumnMapRowMapper
public <T> reactor.core.publisher.Flux<T> queryForFlux(StringSE cql, ClassSE<T> elementType, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
Flux
を期待します。 結果は、指定された要素型に一致する結果オブジェクトの Flux
(行ごとに 1 つの項目) にマップされます。
ReactiveCqlOperations
の queryForFlux
cql
- 実行する静的 CQL は空または null であってはなりません。elementType
- 結果 Flux
内の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。Flux
。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String, Class)
, SingleColumnRowMapper
public reactor.core.publisher.Flux<MapSE<StringSE,ObjectSE>> queryForFlux(StringSE cql, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
Flux
を期待します。 結果は、Map
SE (列名をキーとして使用し、列ごとに 1 つのエントリ) の Flux
(行ごとに 1 つの項目) にマップされます。Flux
の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。
ReactiveCqlOperations
の queryForFlux
cql
- 実行する静的 CQL は空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。Map
SE を含む Flux
DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForFlux(String)
public reactor.core.publisher.Mono<ReactiveResultSet> queryForResultSet(StringSE cql, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
結果は ReactiveResultSet
にマッピングされます。
ReactiveCqlOperations
の queryForResultSet
cql
- 実行する静的 CQL は空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。ReactiveResultSet
表現。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String)
public reactor.core.publisher.Flux<com.datastax.driver.core.Row> queryForRows(StringSE cql, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
結果は Row
にマッピングされます。
ReactiveCqlOperations
の queryForRows
cql
- 実行する静的 CQL は空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。Row
表現。DataAccessException
- クエリの実行に問題がある場合。ReactiveCqlOperations.queryForResultSet(String)
public reactor.core.publisher.Mono<BooleanSE> execute(ReactivePreparedStatementCreator psc) throws DataAccessException
ReactiveCqlOperations
ReactivePreparedStatementCreator
を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。ReactiveCqlOperations
の execute
psc
- CQL と必要なパラメーターを提供するオブジェクトは null であってはなりません。DataAccessException
- 実行の発行に問題がある場合。public reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql, @Nullable PreparedStatementBinder psb) throws DataAccessException
ReactiveCqlOperations
PreparedStatementBinder
を使用してバインドパラメーターを設定するステートメントを発行します。このメソッドは PreparedStatement
を作成するため、ReactivePreparedStatementCreator
を使用するよりも簡単です。PreparedStatementBinder
ではパラメーターを設定するだけです。ReactiveCqlOperations
の execute
cql
- 実行する静的 CQL は空または null であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。DataAccessException
- クエリの実行に問題がある場合。public reactor.core.publisher.Mono<BooleanSE> execute(StringSE cql, ObjectSE... args) throws DataAccessException
ReactiveCqlOperations
ReactiveCqlOperations
の execute
cql
- 実行する静的 CQL は空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。DataAccessException
- クエリの実行に問題がある場合。public reactor.core.publisher.Flux<BooleanSE> execute(StringSE cql, org.reactivestreams.Publisher<ObjectSE[]> args) throws DataAccessException
ReactiveCqlOperations
ReactiveCqlOperations
の execute
cql
- バインドパラメーターを含む実行する静的 CQL は、空または null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのは PreparedStatement
に任せます)。DataAccessException
- クエリの実行に問題がある場合。protected ReactivePreparedStatementCreator newReactivePreparedStatementCreator(StringSE cql)
ReactivePreparedStatementCreator
を作成します。デフォルトでは、SimpleReactivePreparedStatementCreator
を作成します。このメソッドを使用すると、サブクラスによって作成をオーバーライドできます。cql
- 実行する静的 CQL は空または null であってはなりません。ReactivePreparedStatementCreator
protected <T> reactor.core.publisher.Flux<T> createFlux(com.datastax.driver.core.Statement statement, ReactiveStatementCallback<T> callback)
ReactiveStatementCallback
を指定して再利用可能な Flux
を作成します。callback
- null であってはなりません。ReactiveStatementCallback
を包む再利用可能な Flux
。protected <T> reactor.core.publisher.Mono<T> createMono(com.datastax.driver.core.Statement statement, ReactiveStatementCallback<T> callback)
ReactiveStatementCallback
を指定して再利用可能な Mono
を作成します。callback
- null であってはなりません。ReactiveStatementCallback
を包む再利用可能な Mono
。protected <T> reactor.core.publisher.Flux<T> createFlux(ReactiveSessionCallback<T> callback)
ReactiveSessionCallback
を指定して再利用可能な Flux
を作成します。callback
- null であってはなりません。ReactiveSessionCallback
を包む再利用可能な Flux
。protected FunctionSE<ThrowableSE,ThrowableSE> translateException(StringSE task, @Nullable StringSE cql)
Mono#otherwise(Function)
での使用を目的とした例外変換 Function
SE。task
- 試行されているタスクを説明する読み取り可能なテキスト cql
- 問題の原因となった CQL クエリまたは更新 (null の可能性があります)Function
SECqlProvider
protected RowMapper<MapSE<StringSE,ObjectSE>> getColumnMapRowMapper()
ColumnMapRowMapper
protected <T> RowMapper<T> getSingleColumnRowMapper(ClassSE<T> requiredType)
requiredType
- 各結果オブジェクトが一致すると予想される型 SingleColumnRowMapper
protected void applyStatementSettings(com.datastax.driver.core.Statement stmt)
PreparedStatement
) を準備します。stmt
- 準備する CQL ステートメント setFetchSize(int)
, setRetryPolicy(RetryPolicy)
, setConsistencyLevel(ConsistencyLevel)
protected void applyStatementSettings(com.datastax.driver.core.PreparedStatement stmt)
PreparedStatement
) を準備します。stmt
- 準備する CQL ステートメント setRetryPolicy(RetryPolicy)
, setConsistencyLevel(ConsistencyLevel)
protected PreparedStatementBinder newArgPreparedStatementBinder(ObjectSE[] args)
デフォルトでは、ArgumentPreparedStatementBinder
を作成します。このメソッドを使用すると、作成をサブクラスでオーバーライドできます。
args
- 引数を持つオブジェクト配列 PreparedStatementBinder
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.