Package com.azure.spring.data.cosmos

Class CosmosFactory

java.lang.Object

com.azure.spring.data.cosmos.CosmosFactory

public class CosmosFactory
extends Object

Factory class for CosmosDb to create client

Field Summary

Fields

Modifier and Type	Field	Description
protected String	databaseName	Database Name to be used for operations.

Constructor Summary

Constructors

Constructor	Description
CosmosFactory(com.azure.cosmos.CosmosAsyncClient cosmosAsyncClient, String databaseName)	Validate config and initialization

Method Summary

Modifier and Type	Method	Description
static com.azure.cosmos.CosmosAsyncClient	createCosmosAsyncClient(com.azure.cosmos.CosmosClientBuilder cosmosClientBuilder)	Create Cosmos Async Client
com.azure.cosmos.CosmosAsyncClient	getCosmosAsyncClient()	To create a CosmosAsyncClient
String	getDatabaseName()	Get Cosmos Database Name
String	overrideContainerName()	This returns container name for each operation.

Methods inherited from class java.lang.Object

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

Field Details

databaseName

protected String databaseName

Database Name to be used for operations. This is not practically tied to CosmosFactory instance. This can be updated even for same cosmosAsyncClient.

Constructor Details

CosmosFactory

public CosmosFactory(com.azure.cosmos.CosmosAsyncClient cosmosAsyncClient,
 String databaseName)

Validate config and initialization

Parameters:

cosmosAsyncClient - cosmosAsyncClient

databaseName - databaseName

Method Details

getCosmosAsyncClient

public com.azure.cosmos.CosmosAsyncClient getCosmosAsyncClient()

To create a CosmosAsyncClient

Returns:

CosmosAsyncClient

getDatabaseName

public String getDatabaseName()

Get Cosmos Database Name

Returns:

Cosmos Database Name

overrideContainerName

public String overrideContainerName()

This returns container name for each operation. By default, container name will be derived from entity definition. NOTE: Using this API will override container name defined on entity definition.

Returns:

container name

createCosmosAsyncClient

public static com.azure.cosmos.CosmosAsyncClient createCosmosAsyncClient(com.azure.cosmos.CosmosClientBuilder cosmosClientBuilder)

Create Cosmos Async Client

Parameters:

cosmosClientBuilder - CosmosClientBuilder

Returns:

CosmosAsyncClient