クラス AsyncCqlTemplate
- 実装されたすべてのインターフェース:
InitializingBean
,AsyncCqlOperations
ResultSet
の反復処理を開始し、DriverException
例外をキャッチして、org.springframework.dao
パッケージで定義されている汎用的でより情報量の多い例外階層に変換します。 このクラスを使用するコードでは、コールバックインターフェースを実装するだけで、明確に定義された契約が与えられます。PreparedStatementCreator
コールバックインターフェースは、Connection を指定して準備されたステートメントを作成し、CQL と必要なパラメーターを提供します。AsyncResultSetExtractor
インターフェースは、ResultSet
から値を抽出します。2 つの一般的な代替コールバックインターフェースについては、PreparedStatementBinder
と RowMapper
も参照してください。
CqlSession
参照による直接インスタンス化を介してサービス実装内で使用するか、アプリケーションコンテキストで準備して Bean 参照としてサービスに渡すことができます。注: CqlSession
は、アプリケーションコンテキストで常に Bean として構成する必要があります。最初のケースではサービスに直接渡され、2 番目のケースでは準備されたテンプレートに渡されます。
このクラスは、コールバックインターフェースと PersistenceExceptionTranslator
インターフェースによってパラメーター化できるため、サブクラス化する必要はありません。
このクラスによって実行されるすべての CQL 操作は、ログカテゴリとして "org.springframework.data.cassandra.core.cqlTemplate" を使用してデバッグレベルでログに記録されます。
NOTE: このクラスのインスタンスは、構成後はスレッドセーフです。
ネストされたクラスのサマリー
ネストされたクラスフィールドサマリー
クラス org.springframework.data.cassandra.core.cql.CassandraAccessor から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクターコンストラクター説明新しい、初期化されていないAsyncCqlTemplate
を作成します。AsyncCqlTemplate
(com.datastax.oss.driver.api.core.CqlSession session) 指定されたCqlSession
で新しいAsyncCqlTemplate
を作成します。AsyncCqlTemplate
(SessionFactory sessionFactory) 指定されたSessionFactory
を使用して新しいAsyncCqlTemplate
を構築します。メソッドのサマリー
修飾子と型メソッド説明execute
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) 単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。execute
(StringSE cql, PreparedStatementBinder psb) 指定された CQL を使用して、PreparedStatementBinder
を使用してバインドパラメーターを設定するステートメントを発行します。<T> CompletableFutureSE<T>
execute
(StringSE cql, PreparedStatementCallback<T> action) CQLPreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。execute
(AsyncPreparedStatementCreator preparedStatementCreator) AsyncPreparedStatementCreator
を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。<T> CompletableFutureSE<T>
execute
(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementCallback<T> action) CQLPreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。<T> CompletableFutureSE<T>
execute
(AsyncSessionCallback<T> action) CqlSession
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。protected AsyncPreparedStatementCreator
渡された CQL を使用して、新しい CQL ベースのAsyncPreparedStatementCreator
を作成します。newAsyncResultSetExtractor
(RowCallbackHandler rowCallbackHandler) 指定されたRowCallbackHandler
を適応させてResultSetExtractor
の新しいインスタンスを構築します。protected <T> AsyncRowMapperResultSetExtractor<T>
newAsyncResultSetExtractor
(RowMapper<T> rowMapper) 指定されたRowMapper
を適応させてResultSetExtractor
の新しいインスタンスを構築します。<T> CompletableFutureSE<T>
query
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, AsyncResultSetExtractor<T> resultSetExtractor) 静的 CQL を指定してクエリを実行し、AsyncResultSetExtractor
でResultSet
を読み取ります。query
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowCallbackHandler rowCallbackHandler) 静的 CQL を指定してクエリを実行し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。<T> CompletableFutureSE<ListSE<T>>
静的 CQL を指定してクエリを実行し、RowMapper
を介して各行を Java オブジェクトにマッピングします。<T> CompletableFutureSE<T>
query
(StringSE cql, AsyncResultSetExtractor<T> resultSetExtractor) 静的 CQL を指定してクエリを実行し、AsyncResultSetExtractor
でResultSet
を読み取ります。<T> CompletableFutureSE<T>
query
(StringSE cql, AsyncResultSetExtractor<T> resultSetExtractor, ObjectSE... args) 指定された CQL をクエリして、CQL からプリペアドステートメントを作成し、クエリにバインドする引数のリストを作成し、AsyncResultSetExtractor
でResultSet
を読み取ります。<T> CompletableFutureSE<T>
query
(StringSE cql, PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) 準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor
を使用してResultSet
を読み取ります。query
(StringSE cql, PreparedStatementBinder psb, RowCallbackHandler rowCallbackHandler) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリに値をバインドする方法を認識しているPreparedStatementBinder
実装を作成し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。<T> CompletableFutureSE<ListSE<T>>
query
(StringSE cql, PreparedStatementBinder psb, RowMapper<T> rowMapper) 指定された CQL をクエリして、CQL と、値をクエリにバインドする方法を認識するPreparedStatementBinder
実装からプリペアドステートメントを作成し、RowMapper
を介して各行を Java オブジェクトにマッピングします。query
(StringSE cql, RowCallbackHandler rowCallbackHandler) 静的 CQL を指定してクエリを実行し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。query
(StringSE cql, RowCallbackHandler rowCallbackHandler, ObjectSE... args) 指定された CQL をクエリして、CQL からプリペアドステートメントを作成し、クエリにバインドする引数のリストを作成し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。<T> CompletableFutureSE<ListSE<T>>
静的 CQL を指定してクエリを実行し、RowMapper
を介して各行を Java オブジェクトにマッピングします。<T> CompletableFutureSE<ListSE<T>>
指定された CQL をクエリして、CQL から準備されたステートメントとクエリにバインドする引数のリストを作成し、RowMapper
を介して各行を Java オブジェクトにマッピングします。<T> CompletableFutureSE<T>
query
(AsyncPreparedStatementCreator preparedStatementCreator, AsyncResultSetExtractor<T> resultSetExtractor) 準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor
を使用してResultSet
を読み取ります。<T> CompletableFutureSE<T>
query
(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) 準備されたステートメントと、値をクエリにバインドする方法を認識しているPreparedStatementBinder
実装を使用してクエリを実行し、AsyncResultSetExtractor
でResultSet
を読み取ります。query
(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementBinder psb, RowCallbackHandler rowCallbackHandler) 準備されたステートメントと、値をクエリにバインドする方法を認識するPreparedStatementBinder
実装を使用してクエリを実行し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。<T> CompletableFutureSE<ListSE<T>>
query
(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementBinder psb, RowMapper<T> rowMapper) 準備されたステートメントと、値をクエリにバインドする方法を認識するPreparedStatementBinder
実装を使用してクエリを実行し、RowMapper
を介して各行を Java オブジェクトにマッピングします。query
(AsyncPreparedStatementCreator preparedStatementCreator, RowCallbackHandler rowCallbackHandler) 準備済みステートメントを使用してクエリを実行し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。<T> CompletableFutureSE<ListSE<T>>
query
(AsyncPreparedStatementCreator preparedStatementCreator, RowMapper<T> rowMapper) 準備済みステートメントを使用してクエリを実行し、RowMapper
を介して各行を Java オブジェクトにマッピングします。queryForList
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) 静的 CQL を指定して、結果List
SE のクエリを実行します。<T> CompletableFutureSE<ListSE<T>>
queryForList
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> elementType) 静的 CQL を指定して、結果List
SE のクエリを実行します。queryForList
(StringSE cql) 静的 CQL を指定して、結果List
SE のクエリを実行します。<T> CompletableFutureSE<ListSE<T>>
queryForList
(StringSE cql, ClassSE<T> elementType) 静的 CQL を指定して、結果List
SE のクエリを実行します。<T> CompletableFutureSE<ListSE<T>>
queryForList
(StringSE cql, ClassSE<T> elementType, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果List
SE を期待します。queryForList
(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果List
SE を期待します。queryForMap
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) 静的 CQL を指定して、結果マップのクエリを実行します。queryForMap
(StringSE cql) 静的 CQL を指定して、結果マップのクエリを実行します。queryForMap
(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果のマップを期待します。<T> CompletableFutureSE<T>
queryForObject
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> requiredType) 静的 CQL を指定して、結果オブジェクトのクエリを実行します。<T> CompletableFutureSE<T>
queryForObject
(com.datastax.oss.driver.api.core.cql.Statement<?> statement, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、単一の結果行をRowMapper
経由で Java オブジェクトにマッピングします。<T> CompletableFutureSE<T>
queryForObject
(StringSE cql, ClassSE<T> requiredType) 静的 CQL を指定して、結果オブジェクトのクエリを実行します。<T> CompletableFutureSE<T>
queryForObject
(StringSE cql, ClassSE<T> requiredType, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果オブジェクトを期待します。<T> CompletableFutureSE<T>
queryForObject
(StringSE cql, RowMapper<T> rowMapper) 静的 CQL を指定してクエリを実行し、単一の結果行をRowMapper
経由で Java オブジェクトにマッピングします。<T> CompletableFutureSE<T>
queryForObject
(StringSE cql, RowMapper<T> rowMapper, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、RowMapper
を介して単一の結果行を Java オブジェクトにマッピングします。CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet>
queryForResultSet
(com.datastax.oss.driver.api.core.cql.Statement<?> statement) 静的 CQL を指定して、ResultSet のクエリを実行します。CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet>
静的 CQL を指定して、ResultSet のクエリを実行します。CompletableFutureSE<com.datastax.oss.driver.api.core.cql.AsyncResultSet>
queryForResultSet
(StringSE cql, ObjectSE... args) 指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、ResultSet を期待します。protected DataAccessException
translateException
(StringSE task, StringSE cql, com.datastax.oss.driver.api.core.DriverException ex) 指定されたDriverException
を一般的なDataAccessException
に変換します。protected DataAccessException
translateExceptionIfPossible
(StringSE task, StringSE cql, RuntimeExceptionSE ex) 指定されたDriverException
を一般的なDataAccessException
に変換します。クラス org.springframework.data.cassandra.core.cql.CassandraAccessor から継承されたメソッド
afterPropertiesSet, applyStatementSettings, getConsistencyLevel, getExceptionTranslator, getExecutionProfileResolver, getFetchSize, getKeyspace, getPageSize, getSerialConsistencyLevel, getSession, getSessionFactory, newColumnMapRowMapper, newPreparedStatementBinder, newSingleColumnRowMapper, newStatement, setConsistencyLevel, setExceptionTranslator, setExecutionProfile, setExecutionProfileResolver, setFetchSize, setKeyspace, setPageSize, setSerialConsistencyLevel, setSession, setSessionFactory, toCql, translate, translateExceptionIfPossible
コンストラクターの詳細
AsyncCqlTemplate
public AsyncCqlTemplate()新しい、初期化されていないAsyncCqlTemplate
を作成します。注: インスタンスを使用する前にSessionFactory
を設定する必要があります。AsyncCqlTemplate
public AsyncCqlTemplate(com.datastax.oss.driver.api.core.CqlSession session) 指定されたCqlSession
で新しいAsyncCqlTemplate
を作成します。- パラメーター:
session
- アクティブな CassandraCqlSession
は null であってはなりません。- 例外:
IllegalStateExceptionSE
-CqlSession
が null の場合。
AsyncCqlTemplate
指定されたSessionFactory
を使用して新しいAsyncCqlTemplate
を構築します。- パラメーター:
sessionFactory
- アクティブな CassandraSessionFactory
。- 導入:
- 2.0
- 関連事項:
メソッドの詳細
execute
public <T> CompletableFutureSE<T> execute(AsyncSessionCallback<T> action) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
CqlSession
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で任意のデータアクセス操作を実装できます。つまり、CQLDriverException
を Spring のDataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
action
- アクションを指定するコールバックオブジェクト。- 戻り値:
- アクションによって返される結果オブジェクト、または null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
インターフェースからコピーされた説明:AsyncCqlOperations
単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。- 戻り値:
- マップされたオブジェクトを含む結果
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForList
public CompletableFutureSE<ListSE<MapSE<StringSE,ObjectSE>>> queryForList(StringSE cql) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
静的 CQL を指定して、結果List
SE のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされたqueryForList
メソッドを使用します。結果は、
Map
SE (列名をキーとして使用して各列に 1 つのエントリ) のList
SE (行ごとに 1 つの項目) にマップされます。List
SE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。- 戻り値:
- 行ごとに
Map
SE を含むList
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForList
public <T> CompletableFutureSE<ListSE<T>> queryForList(StringSE cql, ClassSE<T> elementType) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
静的 CQL を指定して、結果List
SE のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされたqueryForList
メソッドを使用します。結果は、指定された要素型に一致する結果オブジェクトの
List
SE (行ごとに 1 つの項目) にマップされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。elementType
- 結果List
SE の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。- 戻り値:
- 指定された要素型に一致するオブジェクトの
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForMap
public CompletableFutureSE<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
静的 CQL を指定して、結果マップのクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされたAsyncCqlOperations.queryForMap(String, Object...)
メソッドを使用します。クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForMap
- パラメーター:
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 を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
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...)
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
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
にマッピングされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForResultSet
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。- 戻り値:
ResultSet
表現。- 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
execute
public CompletableFutureSE<BooleanSE> execute(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
単一の CQL 実行 (通常は DDL ステートメント、挿入、更新、削除ステートメント) を発行します。- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
statement
- 静的 CQLStatement
は 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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
statement
- 静的 CQLStatement
は 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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
statement
- 静的 CQLStatement
は 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
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
statement
- 静的 CQLStatement
は null にできません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。- 戻り値:
- マップされたオブジェクトを含む結果
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForList
public CompletableFutureSE<ListSE<MapSE<StringSE,ObjectSE>>> queryForList(com.datastax.oss.driver.api.core.cql.Statement<?> statement) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
静的 CQL を指定して、結果List
SE のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされたqueryForList
メソッドを使用します。結果は、
Map
SE (列名をキーとして使用して各列に 1 つのエントリ) のList
SE (行ごとに 1 つの項目) にマップされます。List
SE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
statement
- 実行する静的 CQLStatement
は null または空であってはなりません。- 戻り値:
- 行ごとに
Map
SE を含むList
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForList
public <T> CompletableFutureSE<ListSE<T>> queryForList(com.datastax.oss.driver.api.core.cql.Statement<?> statement, ClassSE<T> elementType) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
静的 CQL を指定して、結果List
SE のクエリを実行します。PreparedStatement
ではなく、CQL ステートメントを使用します。PreparedStatement
を使用して静的クエリを実行する場合は、引数配列として null を指定してオーバーロードされたqueryForList
メソッドを使用します。結果は、指定された要素型に一致する結果オブジェクトの
List
SE (行ごとに 1 つの項目) にマップされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
statement
- 静的 CQLStatement
は null にできません。elementType
- 結果List
SE の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。- 戻り値:
- 指定された要素型に一致するオブジェクトの
List
SE。 - 例外:
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 つのエントリ)。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForMap
- パラメーター:
statement
- 静的 CQLStatement
は 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 を実行する場合に便利です。クエリは単一行 / 単一列のクエリであることが想定されており、返される結果は対応するオブジェクト型に直接マップされます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
statement
- 静的 CQLStatement
は 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...)
メソッドを使用します。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
statement
- 静的 CQLStatement
は 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
にマッピングされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForResultSet
- パラメーター:
statement
- 静的 CQLStatement
は null にできません。- 戻り値:
ResultSet
表現。- 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
execute
public CompletableFutureSE<BooleanSE> execute(AsyncPreparedStatementCreator preparedStatementCreator) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
AsyncPreparedStatementCreator
を使用して単一の CQL 実行操作 (挿入、更新、削除ステートメントなど) を発行し、CQL および必要なパラメーターを指定します。- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
preparedStatementCreator
- CQL と必要なパラメーターを提供するオブジェクトは null であってはなりません。- 戻り値:
- ステートメントが適用されたかどうかを示すブール値。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
public CompletableFutureSE<BooleanSE> execute(StringSE cql, ObjectSE... args) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
準備されたステートメントを介して単一の CQL 操作 (挿入、更新、削除ステートメントなど) を発行し、指定された引数をバインドします。- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのはPreparedStatement
に任せます)。- 戻り値:
- ステートメントが適用されたかどうかを示すブール値。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
public CompletableFutureSE<BooleanSE> execute(StringSE cql, @Nullable PreparedStatementBinder psb) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL を使用して、PreparedStatementBinder
を使用してバインドパラメーターを設定するステートメントを発行します。このメソッドはPreparedStatement
を作成するため、AsyncPreparedStatementCreator
を使用するよりも簡単です。PreparedStatementBinder
ではパラメーターを設定するだけです。- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。- 戻り値:
- ステートメントが適用されたかどうかを示すブール値。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
public <T> CompletableFutureSE<T> execute(StringSE cql, PreparedStatementCallback<T> action) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
CQLPreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一のステートメントに任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQLDriverException
を Spring のDataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。action
- アクションを指定するコールバックオブジェクトは null であってはなりません。- 戻り値:
- アクションによって返された結果オブジェクト、または null
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
execute
public <T> CompletableFutureSE<T> execute(AsyncPreparedStatementCreator preparedStatementCreator, PreparedStatementCallback<T> action) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
CQLPreparedStatement
で動作するコールバックアクションとして実装された CQL データアクセス操作を実行します。これにより、Spring の管理された CQL 環境内で、単一のPreparedStatement
に任意のデータアクセス操作を実装できます。つまり、Spring 管理のトランザクションに参加し、CQLDriverException
を Spring のDataAccessException
階層に変換できます。コールバックアクションは、ドメインオブジェクトまたはドメインオブジェクトのコレクションなどの結果オブジェクトを返すことができます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のexecute
- パラメーター:
preparedStatementCreator
-CqlSession
を指定してPreparedStatement
を作成できるオブジェクトは null であってはなりません。action
- アクションを指定するコールバックオブジェクトは null であってはなりません。- 戻り値:
- アクションによって返される結果オブジェクト、または null。
- 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public <T> CompletableFutureSE<T> query(AsyncPreparedStatementCreator preparedStatementCreator, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor
を使用してResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
preparedStatementCreator
-CqlSession
を指定してPreparedStatement
を作成できるオブジェクトは null であってはなりません。resultSetExtractor
- 結果を抽出するオブジェクトは null であってはなりません。- 戻り値:
AsyncResultSetExtractor
によって返される任意の結果オブジェクト- 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public CompletableFutureSE<VoidSE> query(AsyncPreparedStatementCreator preparedStatementCreator, RowCallbackHandler rowCallbackHandler) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
準備済みステートメントを使用してクエリを実行し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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 オブジェクトにマッピングします。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
preparedStatementCreator
-CqlSession
を指定してPreparedStatement
を作成できるオブジェクトは null であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。- 戻り値:
- マップされたオブジェクトを含む結果
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public <T> CompletableFutureSE<T> query(AsyncPreparedStatementCreator preparedStatementCreator, @Nullable PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
準備されたステートメントと、値をクエリにバインドする方法を認識しているPreparedStatementBinder
実装を使用してクエリを実行し、AsyncResultSetExtractor
でResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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 オブジェクトにマッピングします。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
preparedStatementCreator
-CqlSession
を指定してPreparedStatement
を作成できるオブジェクトは null であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。- 戻り値:
- マップされたオブジェクトを含む結果
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public <T> CompletableFutureSE<T> query(StringSE cql, AsyncResultSetExtractor<T> resultSetExtractor, ObjectSE... args) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL をクエリして、CQL からプリペアドステートメントを作成し、クエリにバインドする引数のリストを作成し、AsyncResultSetExtractor
でResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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 オブジェクトにマッピングします。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクトargs
- クエリにバインドする引数 (対応する CQL 型を推測するのはPreparedStatement
に任せる)- 戻り値:
- 結果
List
SE にはマップされたオブジェクトが含まれる - 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public <T> CompletableFutureSE<T> query(StringSE cql, @Nullable PreparedStatementBinder psb, AsyncResultSetExtractor<T> resultSetExtractor) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
準備されたステートメントを使用してクエリを実行し、AsyncResultSetExtractor
を使用してResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。resultSetExtractor
- 結果を抽出するオブジェクトは null であってはなりません。- 戻り値:
AsyncResultSetExtractor
によって返される任意の結果オブジェクト。- 例外:
DataAccessException
- クエリの実行に問題がある場合。
query
public CompletableFutureSE<VoidSE> query(StringSE cql, @Nullable PreparedStatementBinder psb, RowCallbackHandler rowCallbackHandler) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL をクエリして、CQL から準備されたステートメントと、クエリに値をバインドする方法を認識しているPreparedStatementBinder
実装を作成し、RowCallbackHandler
を使用して行ごとにResultSet
を読み取ります。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
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 オブジェクトにマッピングします。- 次で指定:
- インターフェース
AsyncCqlOperations
のquery
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。psb
- 準備されたステートメントに値を設定する方法を知っているオブジェクト。これが null の場合、CQL にはバインドパラメーターが含まれていないと見なされます。バインドパラメーターがない場合でも、このオブジェクトを使用してフェッチサイズやその他のパフォーマンスオプションを設定できます。rowMapper
- 行ごとに 1 つのオブジェクトをマップするオブジェクト。null にすることはできません。- 戻り値:
- マップされたオブジェクトを含む結果
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。
queryForList
public CompletableFutureSE<ListSE<MapSE<StringSE,ObjectSE>>> queryForList(StringSE cql, ObjectSE... args) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果List
SE を期待します。結果は、
Map
SE (列名をキーとして使用し、列ごとに 1 つのエントリ) のList
SE (行ごとに 1 つの項目) にマップされます。List
SE の各項目は、このインターフェースの queryForMap() メソッドによって返される形式になります。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのはPreparedStatement
に任せます)。- 戻り値:
- 行ごとに
Map
SE を含むList
SE - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForList
public <T> CompletableFutureSE<ListSE<T>> queryForList(StringSE cql, ClassSE<T> elementType, ObjectSE... args) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果List
SE を期待します。結果は、指定された要素型に一致する結果オブジェクトの
List
SE (行ごとに 1 つの項目) にマップされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForList
- パラメーター:
cql
- 実行する静的 CQL は null または空であってはなりません。elementType
- 結果List
SE の要素の必須型 (たとえば、Integer.class
) は null であってはなりません。args
- クエリにバインドする引数 (対応する CQL 型を推測するのはPreparedStatement
に任せます)。- 戻り値:
- 指定された要素型に一致するオブジェクトの
List
SE。 - 例外:
DataAccessException
- クエリの実行に問題がある場合。- 関連事項:
queryForMap
public CompletableFutureSE<MapSE<StringSE,ObjectSE>> queryForMap(StringSE cql, ObjectSE... args) throws DataAccessException インターフェースからコピーされた説明:AsyncCqlOperations
指定された CQL をクエリして、CQL から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果のマップを期待します。このインターフェースで定義されている queryForMap() メソッドは、ドメインモデルがない場合に適しています。それ以外の場合は、queryForObject() メソッドのいずれかを使用することを検討してください。クエリは単一行クエリであることが期待されています。結果行はマップにマップされます(列名をキーとして使用して、各列に 1 つのエントリ)。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForMap
- パラメーター:
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 から準備されたステートメントと、クエリにバインドする引数のリストを作成し、結果オブジェクトを期待します。クエリは、単一の行 / 単一列クエリであることが期待されています。返された結果は、対応するオブジェクト型に直接マップされます。
- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
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 オブジェクトにマッピングします。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForObject
- パラメーター:
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
にマッピングされます。- 次で指定:
- インターフェース
AsyncCqlOperations
のqueryForResultSet
- パラメーター:
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
。- 戻り値:
- 例外変換
Function
SE - 関連事項:
translateExceptionIfPossible
@Nullable protected DataAccessException translateExceptionIfPossible(StringSE task, @Nullable StringSE cql, RuntimeExceptionSE ex) 指定されたDriverException
を一般的なDataAccessException
に変換します。- パラメーター:
task
- 試行されているタスクを説明する読み取り可能なテキストcql
- 問題の原因となった CQL クエリまたは更新 (null の可能性があります)ex
- 問題のRuntimeException
。- 戻り値:
- 変換された
DataAccessException
、または変換が不可能な場合は null。 - 関連事項:
newAsyncPreparedStatementCreator
渡された CQL を使用して、新しい CQL ベースのAsyncPreparedStatementCreator
を作成します。デフォルトでは、AsyncCqlTemplate.SimpleAsyncPreparedStatementCreator
を作成します。このメソッドを使用すると、サブクラスによって作成をオーバーライドできます。- パラメーター:
cql
- 実行する静的 CQL は空または null であってはなりません。- 戻り値:
- 使用する新しい
AsyncPreparedStatementCreator
newAsyncResultSetExtractor
protected AsyncCqlTemplate.AsyncRowCallbackHandlerResultSetExtractor newAsyncResultSetExtractor(RowCallbackHandler rowCallbackHandler) 指定されたRowCallbackHandler
を適応させてResultSetExtractor
の新しいインスタンスを構築します。- パラメーター:
rowCallbackHandler
-RowCallbackHandler
をResultSetExtractor
として適応させます。- 戻り値:
RowCallbackHandler
のインスタンスを適応させたResultSetExtractor
実装。- 関連事項:
newAsyncResultSetExtractor
protected <T> AsyncRowMapperResultSetExtractor<T> newAsyncResultSetExtractor(RowMapper<T> rowMapper) 指定されたRowMapper
を適応させてResultSetExtractor
の新しいインスタンスを構築します。- パラメーター:
rowMapper
-RowMapper
をResultSetExtractor
として適応させます。- 戻り値:
RowMapper
のインスタンスを適応させたResultSetExtractor
実装。- 関連事項: