This quickstart guide explains how to build a Java app to manage an Azure Cosmos DB for NoSQL account. You create the Java app using the SQL Java SDK, and add resources to your Azure Cosmos DB account by using the Java application.
First, create an Azure Cosmos DB for NoSQL account using the Azure portal. Azure Cosmos DB is a multi-model database service that lets you quickly create and query document, table, key-value, and graph databases with global distribution and horizontal scale capabilities. You can try Azure Cosmos DB account for free without a credit card or an Azure subscription.
If you work with Azure Cosmos DB resources in a Spring application, consider using Spring Cloud Azure as an alternative. Spring Cloud Azure is an open-source project that provides seamless Spring integration with Azure services. To learn more about Spring Cloud Azure, and to see an example using Cosmos DB, see Access data with Azure Cosmos DB NoSQL API.
Prerequisites
An Azure account with an active subscription. If you don't have an Azure subscription, you can try Azure Cosmos DB free with no credit card required.
Java Development Kit (JDK) 8. Point your JAVA_HOME environment variable to the folder where the JDK is installed.
Git. On Ubuntu, run sudo apt-get install git to install Git.
Introductory notes
The structure of an Azure Cosmos DB account: For any API or programming language, an Azure Cosmos DB account contains zero or more databases, a database (DB) contains zero or more containers, and a container contains zero or more items, as shown in the following diagram:
A few important properties are defined at the level of the container, including provisioned throughput and partition key. The provisioned throughput is measured in request units (RUs), which have a monetary price and are a substantial determining factor in the operating cost of the account. Provisioned throughput can be selected at per-container granularity or per-database granularity, however container-level throughput specification is typically preferred. To learn more about throughput provisioning, see Introduction to provisioned throughput in Azure Cosmos DB.
As items are inserted into an Azure Cosmos DB container, the database grows horizontally by adding more storage and compute to handle requests. Storage and compute capacity are added in discrete units known as partitions, and you must choose one field in your documents to be the partition key that maps each document to a partition. Partitions are managed such that each partition is assigned a roughly equal slice out of the range of partition key values. Therefore, you're advised to choose a partition key that's relatively random or evenly distributed. Otherwise, some partitions see substantially more requests (hot partition) while other partitions see substantially fewer requests (cold partition). To learn more, see Partitioning and horizontal scaling in Azure Cosmos DB.
Create a database account
Before you can create a document database, you need to create an API for NoSQL account with Azure Cosmos DB.
From the Azure portal menu or the Home page, select Create a resource.
In the Create Azure Cosmos DB Account page, enter the basic settings for the new Azure Cosmos DB account.
Setting
Value
Description
Subscription
Subscription name
Select the Azure subscription that you want to use for this Azure Cosmos DB account.
Resource Group
Resource group name
Select a resource group, or select Create new, then enter a unique name for the new resource group.
Account Name
A unique name
Enter a name to identify your Azure Cosmos DB account. Because documents.azure.com is appended to the name that you provide to create your URI, use a unique name. The name can contain only lowercase letters, numbers, and the hyphen (-) character. It must be 3-44 characters.
Location
The region closest to your users
Select a geographic location to host your Azure Cosmos DB account. Use the location that is closest to your users to give them the fastest access to the data.
Capacity mode
Provisioned throughput or Serverless
Select Provisioned throughput to create an account in provisioned throughput mode. Select Serverless to create an account in serverless mode.
Apply Azure Cosmos DB free tier discount
Apply or Do not apply
With Azure Cosmos DB free tier, you get the first 1000 RU/s and 25 GB of storage for free in an account. Learn more about free tier.
Limit total account throughput
Selected or not
Limit the total amount of throughput that can be provisioned on this account. This limit prevents unexpected charges related to provisioned throughput. You can update or remove this limit after your account is created.
You can have up to one free tier Azure Cosmos DB account per Azure subscription and must opt in when creating the account. If you don't see the option to apply the free tier discount, another account in the subscription has already been enabled with free tier.
Note
The following options are not available if you select Serverless as the Capacity mode:
Apply Free Tier Discount
Limit total account throughput
In the Global Distribution tab, configure the following details. You can leave the default values for this quickstart:
Setting
Value
Description
Geo-Redundancy
Disable
Enable or disable global distribution on your account by pairing your region with a pair region. You can add more regions to your account later.
Multi-region Writes
Disable
Multi-region writes capability allows you to take advantage of the provisioned throughput for your databases and containers across the globe.
Availability Zones
Disable
Availability Zones help you further improve availability and resiliency of your application.
Note
The following options are not available if you select Serverless as the Capacity mode in the previous Basics page:
Geo-redundancy
Multi-region Writes
Optionally, you can configure more details in the following tabs:
Tags. Tags are name/value pairs that enable you to categorize resources and view consolidated billing by applying the same tag to multiple resources and resource groups.
Select Review + create.
Review the account settings, and then select Create. It takes a few minutes to create the account. Wait for the portal page to display Your deployment is complete.
Select Go to resource to go to the Azure Cosmos DB account page.
Add a container
You can now use the Data Explorer tool in the Azure portal to create a database and container.
Select Data Explorer > New Container.
The Add Container area is displayed on the far right, you may need to scroll right to see it.
In the Add container page, enter the settings for the new container.
Setting
Suggested value
Description
Database ID
ToDoList
Enter Tasks as the name for the new database. Database names must contain from 1 through 255 characters, and they cannot contain /, \\, #, ?, or a trailing space. Check the Share throughput across containers option, it allows you to share the throughput provisioned on the database across all the containers within the database. This option also helps with cost savings.
Database throughput
You can provision Autoscale or Manual throughput. Manual throughput allows you to scale RU/s yourself whereas autoscale throughput allows the system to scale RU/s based on usage. Select Manual for this example.
Leave the throughput at 400 request units per second (RU/s). If you want to reduce latency, you can scale up the throughput later by estimating the required RU/s with the capacity calculator.
Note: This setting is not available when creating a new container in a serverless account.
Container ID
Items
Enter Items as the name for your new container. Container IDs have the same character requirements as database names.
Partition key
/category
The sample described in this article uses /category as the partition key.
Don't add Unique keys or turn on Analytical store for this example. Unique keys let you add a layer of data integrity to the database by ensuring the uniqueness of one or more values per partition key. For more information, see Unique keys in Azure Cosmos DB.Analytical store is used to enable large-scale analytics against operational data without any impact to your transactional workloads.
Select OK. The Data Explorer displays the new database and container.
Add sample data
You can now add data to your new container using Data Explorer.
From the Data Explorer, expand the Tasks database, expand the Items container. Select Items, and then select New Item.
Now add a document to the container with the following structure.
{
"id": "1",
"category": "personal",
"name": "groceries",
"description": "Pick up apples and strawberries.",
"isComplete": false
}
Once you've added the json to the Documents tab, select Save.
Create and save one more document where you insert a unique value for the id property, and change the other properties as you see fit. Your new documents can have any structure you want as Azure Cosmos DB doesn't impose any schema on your data.
Query your data
You can use queries in Data Explorer to retrieve and filter your data.
At the top of the Items tab in Data Explorer, review the default query SELECT * FROM c. This query retrieves and displays all documents from the container ordered by ID.
To change the query, select Edit Filter, replace the default query with ORDER BY c._ts DESC, and then select Apply Filter.
The modified query displays the documents in descending order based on their description, so now your second document is listed first.
If you're familiar with SQL syntax, you can enter any supported SQL queries in the query predicate box. You can also use Data Explorer to create stored procedures, user defined functions, and triggers for server-side business logic.
Data Explorer provides easy access in the Azure portal to all of the built-in programmatic data access features available in the APIs. You can also use the Azure portal to scale throughput, get keys and connection strings, and review metrics and SLAs for your Azure Cosmos DB account.
Clone the sample application
Now let's switch to working with code. Clone an API for NoSQL app from GitHub, set the connection string, and run it. You can see how easy it is to work with data programmatically.
Run the following command to clone the sample repository. This command creates a copy of the sample app on your computer.
This step is optional. If you're interested in learning how the database resources are created in the code, you can review the following snippets. Otherwise, you can skip ahead to Run the app.
DefaultAzureCredential is a class provided by the Azure Identity library for Java. To learn more about DefaultAzureCredential, see the Azure authentication with Java and Azure Identity. DefaultAzureCredential supports multiple authentication methods and determines which method should be used at runtime. This approach enables your app to use different authentication methods in different environments (local vs. production) without implementing environment-specific code.
For example, your app can authenticate using your Visual Studio sign-in credentials when developing locally, and then use a managed identity once it has been deployed to Azure. No code changes are required for this transition.
When developing locally with Passwordless authentication, make sure the user account that connects to Cosmos DB is assigned a role with the correct permissions to perform data operations. Currently, Azure Cosmos DB for NoSQL does not include built-in roles for data operations, but you can create your own using the Azure CLI or PowerShell.
Roles consist of a collection of permissions or actions that a user is allowed to perform, such as read, write, and delete. You can read more about configuring role based access control (RBAC) in the cosmos security configuration documentation.
Create the custom role
Create roles using the az role definition create command. Pass in the Cosmos DB account name and resource group, followed by a body of JSON that defines the custom role. The following example creates a role named PasswordlessReadWrite with permissions to read and write items in Cosmos DB containers. The role is also scoped to the account level using /.
When the command completes, copy the ID value from the name field and paste it somewhere for later use.
Next, assign the role you created to the user account or service principal that will connect to Cosmos DB. During local development, this will generally be your own account that is logged into Visual Studio or the Azure CLI.
Retrieve the details of your account using the az ad user command.
az ad user show --id "<your-email-address>"
Copy the value of the id property out of the results and paste it somewhere for later use.
Finally, assign the custom role you created to your user account using the az cosmosdb sql role assignment create command and the IDs you copied previously.
az cosmosdb sql role assignment create
--account-name passwordlessnosql
--resource-group passwordlesstesting
--scope "/"
--principal-id <your-user-id>
--role-definition-id <your-custom-role-id>
Authenticate using DefaultAzureCredential
Make sure you're authenticated with the same Azure AD account you assigned the role to. You can authenticate via the Azure CLI, Visual Studio, or Azure PowerShell.
Sign-in to Azure through the Azure CLI using the following command:
az login
Select the Sign in button in the top right of Visual Studio.
Sign-in using the Azure AD account you assigned a role to previously.
You will need to install the Azure CLI to work with DefaultAzureCredential through Visual Studio code.
On the main menu of Visual Studio Code, navigate to Terminal > New Terminal.
Sign-in to Azure through the Azure CLI using the following command:
az login
Sign-in to Azure using PowerShell via the following command:
Connect-AzAccount
You can authenticate to Cosmos DB for NoSQL using DefaultAzureCredential by adding the azure-identitydependency to your application. DefaultAzureCredential automatically discovers and uses the account you signed into in the previous step.
Manage database resources using the synchronous (sync) API
CosmosClient initialization: The CosmosClient provides client-side logical representation for the Azure Cosmos DB database service. This client is used to configure and execute requests against the service.
DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();
client = new CosmosClientBuilder()
.endpoint(AccountSettings.HOST)
.credential(credential)
// Setting the preferred location to Cosmos DB Account region
// West US is just an example. User should set preferred location to the Cosmos DB region closest to the application
.preferredRegions(Collections.singletonList("West US"))
.consistencyLevel(ConsistencyLevel.EVENTUAL)
.buildClient();
# Create a SQL API database
az cosmosdb sql database create \
--account-name msdocs-cosmos-nosql \
--resource-group msdocs \
--name AzureSampleFamilyDB
# Create a SQL API container
az cosmosdb sql container create \
--account-name msdocs-cosmos-nosql \
--resource-group msdocs \
--database-name AzureSampleFamilyDB \
--name FamilyContainer \
--partition-key-path '/lastName'
Item creation by using the createItem method.
// Create item using container that we created using sync client
// Use lastName as partitionKey for cosmos item
// Using appropriate partition key improves the performance of database operations
CosmosItemRequestOptions cosmosItemRequestOptions = new CosmosItemRequestOptions();
CosmosItemResponse<Family> item = container.createItem(family, new PartitionKey(family.getLastName()), cosmosItemRequestOptions);
Point reads are performed using readItem method.
try {
CosmosItemResponse<Family> item = container.readItem(family.getId(), new PartitionKey(family.getLastName()), Family.class);
double requestCharge = item.getRequestCharge();
Duration requestLatency = item.getDuration();
logger.info("Item successfully read with id {} with a charge of {} and within duration {}",
item.getItem().getId(), requestCharge, requestLatency);
} catch (CosmosException e) {
logger.error("Read Item failed with", e);
}
SQL queries over JSON are performed using the queryItems method.
// Set some common query options
CosmosQueryRequestOptions queryOptions = new CosmosQueryRequestOptions();
//queryOptions.setEnableCrossPartitionQuery(true); //No longer necessary in SDK v4
// Set query metrics enabled to get metrics around query executions
queryOptions.setQueryMetricsEnabled(true);
CosmosPagedIterable<Family> familiesPagedIterable = container.queryItems(
"SELECT * FROM Family WHERE Family.lastName IN ('Andersen', 'Wakefield', 'Johnson')", queryOptions, Family.class);
familiesPagedIterable.iterableByPage(10).forEach(cosmosItemPropertiesFeedResponse -> {
logger.info("Got a page of query result with {} items(s) and request charge of {}",
cosmosItemPropertiesFeedResponse.getResults().size(), cosmosItemPropertiesFeedResponse.getRequestCharge());
logger.info("Item Ids {}", cosmosItemPropertiesFeedResponse
.getResults()
.stream()
.map(Family::getId)
.collect(Collectors.toList()));
});
Run the app
Now go back to the Azure portal to get your connection string information and launch the app with your endpoint information. This enables your app to communicate with your hosted database.
In the git terminal window, cd to the sample code folder.
cd azure-cosmos-java-getting-started
In the git terminal window, use the following command to install the required Java packages.
mvn package
In the git terminal window, use the following command to start the Java application. Replace SYNCASYNCMODE with sync-passwordless or async-passwordless, depending on which sample code you'd like to run. Replace YOUR_COSMOS_DB_HOSTNAME with the quoted URI value from the portal, and replace YOUR_COSMOS_DB_MASTER_KEY with the quoted primary key from portal.
The terminal window displays a notification that the FamilyDB database was created.
The app references the database and container you created via Azure CLI earlier.
The app performs point reads using object IDs and partition key value (which is lastName in our sample).
The app queries items to retrieve all families with last name (Andersen, Wakefield, Johnson).
The app doesn't delete the created resources. Switch back to the portal to clean up the resources from your account so that you don't incur charges.
DefaultAzureCredential is a class provided by the Azure Identity library for Java. To learn more about DefaultAzureCredential, see the Azure authentication with Java and Azure Identity. DefaultAzureCredential supports multiple authentication methods and determines which method should be used at runtime. This approach enables your app to use different authentication methods in different environments (local vs. production) without implementing environment-specific code.
For example, your app can authenticate using your Visual Studio sign-in credentials when developing locally, and then use a managed identity once it has been deployed to Azure. No code changes are required for this transition.
When developing locally with Passwordless authentication, make sure the user account that connects to Cosmos DB is assigned a role with the correct permissions to perform data operations. Currently, Azure Cosmos DB for NoSQL does not include built-in roles for data operations, but you can create your own using the Azure CLI or PowerShell.
Roles consist of a collection of permissions or actions that a user is allowed to perform, such as read, write, and delete. You can read more about configuring role based access control (RBAC) in the cosmos security configuration documentation.
Create the custom role
Create roles using the az role definition create command. Pass in the Cosmos DB account name and resource group, followed by a body of JSON that defines the custom role. The following example creates a role named PasswordlessReadWrite with permissions to read and write items in Cosmos DB containers. The role is also scoped to the account level using /.
When the command completes, copy the ID value from the name field and paste it somewhere for later use.
Next, assign the role you created to the user account or service principal that will connect to Cosmos DB. During local development, this will generally be your own account that is logged into Visual Studio or the Azure CLI.
Retrieve the details of your account using the az ad user command.
az ad user show --id "<your-email-address>"
Copy the value of the id property out of the results and paste it somewhere for later use.
Finally, assign the custom role you created to your user account using the az cosmosdb sql role assignment create command and the IDs you copied previously.
az cosmosdb sql role assignment create
--account-name passwordlessnosql
--resource-group passwordlesstesting
--scope "/"
--principal-id <your-user-id>
--role-definition-id <your-custom-role-id>
Authenticate using DefaultAzureCredential
Make sure you're authenticated with the same Azure AD account you assigned the role to. You can authenticate via the Azure CLI, Visual Studio, or Azure PowerShell.
Sign-in to Azure through the Azure CLI using the following command:
az login
Select the Sign in button in the top right of Visual Studio.
Sign-in using the Azure AD account you assigned a role to previously.
You will need to install the Azure CLI to work with DefaultAzureCredential through Visual Studio code.
On the main menu of Visual Studio Code, navigate to Terminal > New Terminal.
Sign-in to Azure through the Azure CLI using the following command:
az login
Sign-in to Azure using PowerShell via the following command:
Connect-AzAccount
You can authenticate to Cosmos DB for NoSQL using DefaultAzureCredential by adding the azure-identity dependency to your application. DefaultAzureCredential automatically discovers and uses the account you signed-in with in the previous step.
Managing database resources using the asynchronous (async) API
Async API calls return immediately, without waiting for a response from the server. The following code snippets show proper design patterns for accomplishing all of the preceding management tasks using async API.
CosmosAsyncClient initialization. The CosmosAsyncClient provides client-side logical representation for the Azure Cosmos DB database service. This client is used to configure and execute asynchronous requests against the service.
DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();
client = new CosmosClientBuilder()
.endpoint(AccountSettings.HOST)
.credential(credential)
// Setting the preferred location to Cosmos DB Account region
// West US is just an example. User should set preferred location to the Cosmos DB region closest to the application
.preferredRegions(Collections.singletonList("West US"))
.consistencyLevel(ConsistencyLevel.EVENTUAL)
// Setting content response on write enabled, which enables the SDK to return response on write operations.
.contentResponseOnWriteEnabled(true)
.buildAsyncClient();
# Create a SQL API database
az cosmosdb sql database create \
--account-name msdocs-cosmos-nosql \
--resource-group msdocs \
--name AzureSampleFamilyDB
# Create a SQL API container
az cosmosdb sql container create \
--account-name msdocs-cosmos-nosql \
--resource-group msdocs \
--database-name AzureSampleFamilyDB \
--name FamilyContainer \
--partition-key-path '/lastName'
As with the sync API, item creation is accomplished using the createItem method. This example shows how to efficiently issue numerous async createItem requests by subscribing to a Reactive Stream that issues the requests and prints notifications. Since this simple example runs to completion and terminates, CountDownLatch instances are used to ensure the program doesn't terminate during item creation. The proper asynchronous programming practice is not to block on async calls. In realistic use cases, requests are generated from a main() loop that executes indefinitely, eliminating the need to latch on async calls.
try {
// Combine multiple item inserts, associated success println's, and a final aggregate stats println into one Reactive stream.
double charge = families.flatMap(family -> {
return container.createItem(family);
}) //Flux of item request responses
.flatMap(itemResponse -> {
logger.info("Created item with request charge of {} within" +
" duration {}",
itemResponse.getRequestCharge(), itemResponse.getDuration());
logger.info("Item ID: {}\n", itemResponse.getItem().getId());
return Mono.just(itemResponse.getRequestCharge());
}) //Flux of request charges
.reduce(0.0,
(charge_n, charge_nplus1) -> charge_n + charge_nplus1
) //Mono of total charge - there will be only one item in this stream
.block(); //Preserve the total charge and print aggregate charge/item count stats.
logger.info("Created items with total request charge of {}\n", charge);
} catch (Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed with error\n", err);
}
}
As with the sync API, point reads are performed using readItem method.
try {
familiesToCreate.flatMap(family -> {
Mono<CosmosItemResponse<Family>> asyncItemResponseMono = container.readItem(family.getId(), new PartitionKey(family.getLastName()), Family.class);
return asyncItemResponseMono;
}).flatMap(itemResponse -> {
double requestCharge = itemResponse.getRequestCharge();
Duration requestLatency = itemResponse.getDuration();
logger.info("Item successfully read with id {} with a charge of {} and within duration {}",
itemResponse.getItem().getId(), requestCharge, requestLatency);
return Flux.empty();
}).blockLast();
} catch (Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed\n", err);
}
}
As with the sync API, SQL queries over JSON are performed using the queryItems method.
// Set some common query options
int preferredPageSize = 10; // We'll use this later
CosmosQueryRequestOptions queryOptions = new CosmosQueryRequestOptions();
// Set populate query metrics to get metrics around query executions
queryOptions.setQueryMetricsEnabled(true);
CosmosPagedFlux<Family> pagedFluxResponse = container.queryItems(
"SELECT * FROM Family WHERE Family.lastName IN ('Andersen', 'Wakefield', 'Johnson')", queryOptions, Family.class);
try {
pagedFluxResponse.byPage(preferredPageSize).flatMap(fluxResponse -> {
logger.info("Got a page of query result with " +
fluxResponse.getResults().size() + " items(s)"
+ " and request charge of " + fluxResponse.getRequestCharge());
logger.info("Item Ids " + fluxResponse
.getResults()
.stream()
.map(Family::getId)
.collect(Collectors.toList()));
return Flux.empty();
}).blockLast();
} catch(Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed\n", err);
}
}
Run the app
Now go back to the Azure portal to get your connection string information and launch the app with your endpoint information. This enables your app to communicate with your hosted database.
In the git terminal window, cd to the sample code folder.
cd azure-cosmos-java-getting-started
In the git terminal window, use the following command to install the required Java packages.
mvn package
In the git terminal window, use the following command to start the Java application. Replace SYNCASYNCMODE with sync-passwordless or async-passwordless depending on which sample code you would like to run, replace YOUR_COSMOS_DB_HOSTNAME with the quoted URI value from the portal, and replace YOUR_COSMOS_DB_MASTER_KEY with the quoted primary key from portal.
The terminal window displays a notification that the AzureSampleFamilyDB database was created.
The app references the database and container you created via Azure CLI earlier.
The app performs point reads using object IDs and partition key value (which is lastName in our sample).
The app queries items to retrieve all families with last name (Andersen, Wakefield, Johnson).
The app doesn't delete the created resources. Switch back to the portal to clean up the resources from your account so that you don't incur charges.
Managing database resources using the synchronous (sync) API
CosmosClient initialization. The CosmosClient provides client-side logical representation for the Azure Cosmos DB database service. This client is used to configure and execute requests against the service.
client = new CosmosClientBuilder()
.endpoint(AccountSettings.HOST)
.key(AccountSettings.MASTER_KEY)
// Setting the preferred location to Cosmos DB Account region
// West US is just an example. User should set preferred location to the Cosmos DB region closest to the application
.preferredRegions(Collections.singletonList("West US"))
.consistencyLevel(ConsistencyLevel.EVENTUAL)
.buildClient();
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerName, "/lastName");
// Create container with 400 RU/s
CosmosContainerResponse cosmosContainerResponse =
database.createContainerIfNotExists(containerProperties, ThroughputProperties.createManualThroughput(400));
container = database.getContainer(cosmosContainerResponse.getProperties().getId());
Item creation by using the createItem method.
// Create item using container that we created using sync client
// Use lastName as partitionKey for cosmos item
// Using appropriate partition key improves the performance of database operations
CosmosItemRequestOptions cosmosItemRequestOptions = new CosmosItemRequestOptions();
CosmosItemResponse<Family> item = container.createItem(family, new PartitionKey(family.getLastName()), cosmosItemRequestOptions);
Point reads are performed using readItem method.
try {
CosmosItemResponse<Family> item = container.readItem(family.getId(), new PartitionKey(family.getLastName()), Family.class);
double requestCharge = item.getRequestCharge();
Duration requestLatency = item.getDuration();
logger.info("Item successfully read with id {} with a charge of {} and within duration {}",
item.getItem().getId(), requestCharge, requestLatency);
} catch (CosmosException e) {
logger.error("Read Item failed with", e);
}
SQL queries over JSON are performed using the queryItems method.
// Set some common query options
CosmosQueryRequestOptions queryOptions = new CosmosQueryRequestOptions();
//queryOptions.setEnableCrossPartitionQuery(true); //No longer necessary in SDK v4
// Set query metrics enabled to get metrics around query executions
queryOptions.setQueryMetricsEnabled(true);
CosmosPagedIterable<Family> familiesPagedIterable = container.queryItems(
"SELECT * FROM Family WHERE Family.lastName IN ('Andersen', 'Wakefield', 'Johnson')", queryOptions, Family.class);
familiesPagedIterable.iterableByPage(10).forEach(cosmosItemPropertiesFeedResponse -> {
logger.info("Got a page of query result with {} items(s) and request charge of {}",
cosmosItemPropertiesFeedResponse.getResults().size(), cosmosItemPropertiesFeedResponse.getRequestCharge());
logger.info("Item Ids {}", cosmosItemPropertiesFeedResponse
.getResults()
.stream()
.map(Family::getId)
.collect(Collectors.toList()));
});
Run the app
Now go back to the Azure portal to get your connection string information and launch the app with your endpoint information. This enables your app to communicate with your hosted database.
In the git terminal window, cd to the sample code folder.
cd azure-cosmos-java-getting-started
In the git terminal window, use the following command to install the required Java packages.
mvn package
In the git terminal window, use the following command to start the Java application. Replace SYNCASYNCMODE with sync or async depending on which sample code you would like to run, replace YOUR_COSMOS_DB_HOSTNAME with the quoted URI value from the portal, and replace YOUR_COSMOS_DB_MASTER_KEY with the quoted primary key from portal.
The terminal window displays a notification that the FamilyDB database was created.
The app creates a database with the name AzureSampleFamilyDB.
The app creates a container with the name FamilyContainer.
The app performs point reads using object IDs and partition key value (which is lastName in our sample).
The app queries items to retrieve all families with last name (Andersen, Wakefield, Johnson).
The app doesn't delete the created resources. Return to the Azure portal to clean up the resources from your account so you don't incur charges.
Managing database resources using the asynchronous (async) API
Async API calls return immediately, without waiting for a response from the server. The following code snippets show proper design patterns for accomplishing all of the preceding management tasks using async API.
CosmosAsyncClient initialization. The CosmosAsyncClient provides client-side logical representation for the Azure Cosmos DB database service. This client is used to configure and execute asynchronous requests against the service.
client = new CosmosClientBuilder()
.endpoint(AccountSettings.HOST)
.key(AccountSettings.MASTER_KEY)
// Setting the preferred location to Cosmos DB Account region
// West US is just an example. User should set preferred location to the Cosmos DB region closest to the application
.preferredRegions(Collections.singletonList("West US"))
.consistencyLevel(ConsistencyLevel.EVENTUAL)
// Setting content response on write enabled, which enables the SDK to return response on write operations.
.contentResponseOnWriteEnabled(true)
.buildAsyncClient();
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerName, "/lastName");
// Create container with 400 RU/s
CosmosContainerResponse cosmosContainerResponse =
database.createContainerIfNotExists(containerProperties, ThroughputProperties.createManualThroughput(400));
container = database.getContainer(cosmosContainerResponse.getProperties().getId());
As with the sync API, item creation is accomplished using the createItem method. This example shows how to efficiently issue numerous async createItem requests by subscribing to a Reactive Stream that issues the requests and prints notifications. Since this simple example runs to completion and terminates, CountDownLatch instances are used to ensure the program doesn't terminate during item creation. The proper asynchronous programming practice is not to block on async calls. In realistic use cases, requests are generated from a main() loop that executes indefinitely, eliminating the need to latch on async calls.
try {
// Combine multiple item inserts, associated success println's, and a final aggregate stats println into one Reactive stream.
double charge = families.flatMap(family -> {
return container.createItem(family);
}) //Flux of item request responses
.flatMap(itemResponse -> {
logger.info("Created item with request charge of {} within" +
" duration {}",
itemResponse.getRequestCharge(), itemResponse.getDuration());
logger.info("Item ID: {}\n", itemResponse.getItem().getId());
return Mono.just(itemResponse.getRequestCharge());
}) //Flux of request charges
.reduce(0.0,
(charge_n, charge_nplus1) -> charge_n + charge_nplus1
) //Mono of total charge - there will be only one item in this stream
.block(); //Preserve the total charge and print aggregate charge/item count stats.
logger.info("Created items with total request charge of {}\n", charge);
} catch (Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed with error\n", err);
}
}
As with the sync API, point reads are performed by using readItem method.
try {
familiesToCreate.flatMap(family -> {
Mono<CosmosItemResponse<Family>> asyncItemResponseMono = container.readItem(family.getId(), new PartitionKey(family.getLastName()), Family.class);
return asyncItemResponseMono;
}).flatMap(itemResponse -> {
double requestCharge = itemResponse.getRequestCharge();
Duration requestLatency = itemResponse.getDuration();
logger.info("Item successfully read with id {} with a charge of {} and within duration {}",
itemResponse.getItem().getId(), requestCharge, requestLatency);
return Flux.empty();
}).blockLast();
} catch (Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed\n", err);
}
}
As with the sync API, SQL queries over JSON are performed by using the queryItems method.
// Set some common query options
int preferredPageSize = 10; // We'll use this later
CosmosQueryRequestOptions queryOptions = new CosmosQueryRequestOptions();
// Set populate query metrics to get metrics around query executions
queryOptions.setQueryMetricsEnabled(true);
CosmosPagedFlux<Family> pagedFluxResponse = container.queryItems(
"SELECT * FROM Family WHERE Family.lastName IN ('Andersen', 'Wakefield', 'Johnson')", queryOptions, Family.class);
try {
pagedFluxResponse.byPage(preferredPageSize).flatMap(fluxResponse -> {
logger.info("Got a page of query result with " +
fluxResponse.getResults().size() + " items(s)"
+ " and request charge of " + fluxResponse.getRequestCharge());
logger.info("Item Ids " + fluxResponse
.getResults()
.stream()
.map(Family::getId)
.collect(Collectors.toList()));
return Flux.empty();
}).blockLast();
} catch(Exception err) {
if (err instanceof CosmosException) {
//Client-specific errors
CosmosException cerr = (CosmosException) err;
logger.error("Read Item failed with CosmosException\n", cerr);
} else {
//General errors
logger.error("Read Item failed\n", err);
}
}
Run the app
Now go back to the Azure portal to get your connection string information and launch the app with your endpoint information. This enables your app to communicate with your hosted database.
In the git terminal window, cd to the sample code folder.
cd azure-cosmos-java-getting-started
In the git terminal window, use the following command to install the required Java packages.
mvn package
In the git terminal window, use the following command to start the Java application. Replace SYNCASYNCMODE with sync or async depending on which sample code you would like to run, replace YOUR_COSMOS_DB_HOSTNAME with the quoted URI value from the portal, and replace YOUR_COSMOS_DB_MASTER_KEY with the quoted primary key from portal.
The terminal window displays a notification that the FamilyDB database was created.
The app creates a database with the name AzureSampleFamilyDB.
The app creates a container with the name FamilyContainer.
The app performs point reads using object IDs and partition key value (which is lastName in our sample).
The app queries items to retrieve all families with last name (Andersen, Wakefield, Johnson).
The app doesn't delete the created resources. Return to the Azure portal to clean up the resources from your account so you don't incur charges.
Application requests to most Azure services must be authorized. Using the DefaultAzureCredential class provided by the Azure Identity client library is the recommended approach for implementing passwordless connections to Azure services in your code.
You can also authorize requests to Azure services using passwords, connection strings, or other credentials directly. However, this approach should be used with caution. Developers must be diligent to never expose these secrets in an unsecure location. Anyone who gains access to the password or secret key is able to authenticate. DefaultAzureCredential offers improved management and security benefits over the account key to allow passwordless authentication. Both options are demonstrated in the following example.
Review SLAs in the Azure portal
The Azure portal monitors your Azure Cosmos DB account throughput, storage, availability, latency, and consistency. Charts for metrics associated with an Azure Cosmos DB Service Level Agreement (SLA) show the SLA value compared to actual performance. This suite of metrics makes monitoring your SLAs transparent.
To review metrics and SLAs:
Select Metrics in your Azure Cosmos DB account's navigation menu.
Select a tab such as Latency, and select a timeframe on the right. Compare the Actual and SLA lines on the charts.
Review the metrics on the other tabs.
Clean up resources
When you're done with your app and Azure Cosmos DB account, you can delete the Azure resources you created so you don't incur more charges. To delete the resources:
In the Azure portal Search bar, search for and select Resource groups.
From the list, select the resource group you created for this quickstart.
On the resource group Overview page, select Delete resource group.
In the next window, enter the name of the resource group to delete, and then select Delete.
Next steps
In this quickstart, you learned how to create an Azure Cosmos DB for NoSQL account, create a document database and container using Data Explorer, and run a Java app to do the same thing programmatically. You can now import additional data into your Azure Cosmos DB account.
Are you capacity planning for a migration to Azure Cosmos DB? You can use information about your existing database cluster for capacity planning.