public class CosmosEncryptionAsyncContainer extends Object
Modifier and Type | Method and Description |
---|---|
<T> Mono<CosmosItemResponse<T>> |
createItem(T item,
PartitionKey partitionKey,
CosmosItemRequestOptions requestOptions)
create item and encrypts the requested fields
|
Mono<CosmosItemResponse<Object>> |
deleteItem(String itemId,
PartitionKey partitionKey,
CosmosItemRequestOptions options)
Deletes the item.
|
CosmosAsyncContainer |
getCosmosAsyncContainer()
Gets the CosmosAsyncContainer
|
<T> CosmosPagedFlux<T> |
queryChangeFeed(CosmosChangeFeedRequestOptions options,
Class<T> classType) |
<T> CosmosPagedFlux<T> |
queryItems(SqlQuerySpec query,
CosmosQueryRequestOptions options,
Class<T> classType)
Query for items in the current container using a
SqlQuerySpec . |
<T> CosmosPagedFlux<T> |
queryItems(String query,
CosmosQueryRequestOptions options,
Class<T> classType)
Query for items in the current container using a string.
|
<T> CosmosPagedFlux<T> |
queryItemsOnEncryptedProperties(SqlQuerySpecWithEncryption sqlQuerySpecWithEncryption,
CosmosQueryRequestOptions options,
Class<T> classType)
Query for items in the current container using a
SqlQuerySpecWithEncryption . |
<T> Mono<CosmosItemResponse<T>> |
readItem(String id,
PartitionKey partitionKey,
CosmosItemRequestOptions requestOptions,
Class<T> classType)
Reads item and decrypt the encrypted fields
|
<T> Mono<CosmosItemResponse<T>> |
replaceItem(T item,
String itemId,
PartitionKey partitionKey,
CosmosItemRequestOptions requestOptions)
replaces item and encrypts the requested fields
|
<T> Mono<CosmosItemResponse<T>> |
upsertItem(T item,
PartitionKey partitionKey,
CosmosItemRequestOptions requestOptions)
upserts item and encrypts the requested fields
|
public <T> Mono<CosmosItemResponse<T>> createItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions requestOptions)
T
- serialization class typeitem
- the Cosmos item represented as a POJO or Cosmos item object.partitionKey
- the partition key.requestOptions
- request optionMono
containing the Cosmos item resource response.public Mono<CosmosItemResponse<Object>> deleteItem(String itemId, PartitionKey partitionKey, CosmosItemRequestOptions options)
After subscription the operation will be performed. The Mono
upon successful completion will contain a
single Cosmos item response with the deleted item.
itemId
- id of the item.partitionKey
- partitionKey of the item.options
- the request options.Mono
containing the Cosmos item resource response.public <T> Mono<CosmosItemResponse<T>> upsertItem(T item, PartitionKey partitionKey, CosmosItemRequestOptions requestOptions)
T
- serialization class typeitem
- the Cosmos item represented as a POJO or Cosmos item object.partitionKey
- the partition key.requestOptions
- request optionMono
containing the Cosmos item resource response.public <T> Mono<CosmosItemResponse<T>> replaceItem(T item, String itemId, PartitionKey partitionKey, CosmosItemRequestOptions requestOptions)
T
- serialization class typeitem
- the Cosmos item represented as a POJO or Cosmos item object.itemId
- the item id.partitionKey
- the partition key.requestOptions
- request optionMono
containing the Cosmos item resource response.public <T> Mono<CosmosItemResponse<T>> readItem(String id, PartitionKey partitionKey, CosmosItemRequestOptions requestOptions, Class<T> classType)
T
- typeid
- item idpartitionKey
- the partition key.requestOptions
- request optionsclassType
- deserialization class typeMono
containing the Cosmos item resource response.public <T> CosmosPagedFlux<T> queryItems(String query, CosmosQueryRequestOptions options, Class<T> classType)
After subscription the operation will be performed. The CosmosPagedFlux
will contain one or several feed
response of the obtained items. In case of failure the CosmosPagedFlux
will error.
T
- the type parameter.query
- the query text.options
- the query request options.classType
- the class type.CosmosPagedFlux
containing one or several feed response pages of the obtained items or an
error.public <T> CosmosPagedFlux<T> queryItems(SqlQuerySpec query, CosmosQueryRequestOptions options, Class<T> classType)
SqlQuerySpec
.
After subscription the operation will be performed. The CosmosPagedFlux
will contain one or several feed
response of the obtained items. In case of failure the CosmosPagedFlux
will error.
T
- the type parameter.query
- the query.options
- the query request options.classType
- the class type.CosmosPagedFlux
containing one or several feed response pages of the obtained items or an
error.public <T> CosmosPagedFlux<T> queryItemsOnEncryptedProperties(SqlQuerySpecWithEncryption sqlQuerySpecWithEncryption, CosmosQueryRequestOptions options, Class<T> classType)
SqlQuerySpecWithEncryption
.
After subscription the operation will be performed. The CosmosPagedFlux
will contain one or several feed
response of the obtained items. In case of failure the CosmosPagedFlux
will error.
T
- the type parameter.sqlQuerySpecWithEncryption
- the sqlQuerySpecWithEncryption.options
- the query request options.classType
- the class type.CosmosPagedFlux
containing one or several feed response pages of the obtained items or an
error.@Beta(value=V1, warningText="Preview API - subject to change in non-backwards compatible way") public <T> CosmosPagedFlux<T> queryChangeFeed(CosmosChangeFeedRequestOptions options, Class<T> classType)
public CosmosAsyncContainer getCosmosAsyncContainer()
Copyright © 2021 Microsoft Corporation. All rights reserved.