com.azure.cosmos

Class CosmosAsyncClient

java.lang.Object

com.azure.cosmos.CosmosAsyncClient

All Implemented Interfaces:

AutoCloseable

public class CosmosAsyncClient
extends Object
implements AutoCloseable

Provides a client-side logical representation of the Azure Cosmos database service. This asynchronous client is used to configure and execute requests against the service.

Method Summary

Modifier and Type	Method and Description
void	close() Close this CosmosAsyncClient instance and cleans up the resources.
static CosmosClientBuilder	cosmosClientBuilder() Instantiate the cosmos client builder to build cosmos client
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseSettings) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseSettings, CosmosDatabaseRequestOptions options) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseSettings, int throughput) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(CosmosDatabaseProperties databaseSettings, int throughput, CosmosDatabaseRequestOptions options) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(String id) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabase(String id, int throughput) Creates a database.
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabaseIfNotExists(CosmosDatabaseProperties databaseSettings) CREATE a Database if it does not already exist on the service
reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse>	createDatabaseIfNotExists(String id) CREATE a Database if it does not already exist on the service The Mono upon successful completion will contain a single cosmos database response with the created or existing database.
CosmosAsyncDatabase	getDatabase(String id) Gets a database object without making a service call.
CosmosContinuablePagedFlux<CosmosDatabaseProperties>	queryDatabases(SqlQuerySpec querySpec, FeedOptions options) Query for databases.
CosmosContinuablePagedFlux<CosmosDatabaseProperties>	queryDatabases(String query, FeedOptions options) Query for databases.
CosmosContinuablePagedFlux<CosmosDatabaseProperties>	readAllDatabases() Reads all databases.
CosmosContinuablePagedFlux<CosmosDatabaseProperties>	readAllDatabases(FeedOptions options) Reads all databases.
reactor.core.publisher.Mono<DatabaseAccount>	readDatabaseAccount()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

cosmosClientBuilder

public static CosmosClientBuilder cosmosClientBuilder()

Instantiate the cosmos client builder to build cosmos client

Returns:

CosmosClientBuilder

createDatabaseIfNotExists

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabaseIfNotExists(CosmosDatabaseProperties databaseSettings)

CREATE a Database if it does not already exist on the service

The Mono upon successful completion will contain a single cosmos database response with the created or existing database.

Parameters:

databaseSettings - CosmosDatabaseProperties

Returns:

a Mono containing the cosmos database response with the created or existing database or an error.

createDatabaseIfNotExists

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabaseIfNotExists(String id)

CREATE a Database if it does not already exist on the service The Mono upon successful completion will contain a single cosmos database response with the created or existing database.

Parameters:

id - the id of the database

Returns:

a Mono containing the cosmos database response with the created or existing database or an error

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(CosmosDatabaseProperties databaseSettings,
                                                                               CosmosDatabaseRequestOptions options)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

databaseSettings - CosmosDatabaseProperties

options - CosmosDatabaseRequestOptions

Returns:

an Mono containing the single cosmos database response with the created database or an error.

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(CosmosDatabaseProperties databaseSettings)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

databaseSettings - CosmosDatabaseProperties

Returns:

an Mono containing the single cosmos database response with the created database or an error.

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(String id)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

id - id of the database

Returns:

a Mono containing the single cosmos database response with the created database or an error.

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(CosmosDatabaseProperties databaseSettings,
                                                                               int throughput,
                                                                               CosmosDatabaseRequestOptions options)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

databaseSettings - CosmosDatabaseProperties

throughput - the throughput for the database

options - CosmosDatabaseRequestOptions

Returns:

an Mono containing the single cosmos database response with the created database or an error.

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(CosmosDatabaseProperties databaseSettings,
                                                                               int throughput)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

databaseSettings - CosmosDatabaseProperties

throughput - the throughput for the database

Returns:

an Mono containing the single cosmos database response with the created database or an error.

createDatabase

public reactor.core.publisher.Mono<CosmosAsyncDatabaseResponse> createDatabase(String id,
                                                                               int throughput)

Creates a database.

After subscription the operation will be performed. The Mono upon successful completion will contain a single resource response with the created database. In case of failure the Mono will error.

Parameters:

id - id of the database

throughput - the throughput for the database

Returns:

a Mono containing the single cosmos database response with the created database or an error.

readAllDatabases

public CosmosContinuablePagedFlux<CosmosDatabaseProperties> readAllDatabases(FeedOptions options)

Reads all databases.

After subscription the operation will be performed. The CosmosContinuablePagedFlux will contain one or several feed response of the read databases. In case of failure the CosmosContinuablePagedFlux will error.

Parameters:

options - FeedOptions

Returns:

a CosmosContinuablePagedFlux containing one or several feed response pages of read databases or an error.

readAllDatabases

public CosmosContinuablePagedFlux<CosmosDatabaseProperties> readAllDatabases()

Reads all databases.

After subscription the operation will be performed. The CosmosContinuablePagedFlux will contain one or several feed response of the read databases. In case of failure the CosmosContinuablePagedFlux will error.

Returns:

a CosmosContinuablePagedFlux containing one or several feed response pages of read databases or an error.

queryDatabases

public CosmosContinuablePagedFlux<CosmosDatabaseProperties> queryDatabases(String query,
                                                                           FeedOptions options)

Query for databases.

After subscription the operation will be performed. The CosmosContinuablePagedFlux will contain one or several feed response of the read databases. In case of failure the CosmosContinuablePagedFlux will error.

Parameters:

query - the query.

options - the feed options.

Returns:

a CosmosContinuablePagedFlux containing one or several feed response pages of read databases or an error.

queryDatabases

public CosmosContinuablePagedFlux<CosmosDatabaseProperties> queryDatabases(SqlQuerySpec querySpec,
                                                                           FeedOptions options)

Query for databases.

After subscription the operation will be performed. The CosmosContinuablePagedFlux will contain one or several feed response of the read databases. In case of failure the CosmosContinuablePagedFlux will error.

Parameters:

querySpec - the SQL query specification.

options - the feed options.

Returns:

a CosmosContinuablePagedFlux containing one or several feed response pages of read databases or an error.

readDatabaseAccount

public reactor.core.publisher.Mono<DatabaseAccount> readDatabaseAccount()

getDatabase

public CosmosAsyncDatabase getDatabase(String id)

Gets a database object without making a service call.

Parameters:

id - name of the database

Returns:

CosmosAsyncDatabase

close

public void close()

Close this CosmosAsyncClient instance and cleans up the resources.

Specified by:

close in interface AutoCloseable