Skip to content
This repository was archived by the owner on Feb 15, 2024. It is now read-only.

Change cosoms sample from track1 to track2(Azure CosmosDB sample forhigh availability) #1

Merged
merged 5 commits into from
Oct 19, 2020
Merged

Change cosoms sample from track1 to track2(Azure CosmosDB sample forhigh availability) #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
f861cd0
Change cosoms sample from track1 to track2(Azure CosmosDB sample for …
Melanie-Ma May 12, 2020
48cf444
update for these comments
Melanie-Ma Jul 28, 2020
dd20e38
Update the sample for the comments
Melanie-Ma Aug 24, 2020
4693d0c
update by comments
Melanie-Ma Sep 10, 2020
fc3e3ee
update to GA
Melanie-Ma Sep 16, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,9 @@
<version>3.3</version>
</dependency>
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-documentdb</artifactId>
<version>1.9.4</version>
<groupId>com.azure</groupId>
<artifactId>azure-cosmos</artifactId>
<version>4.4.0</version>
</dependency>
</dependencies>
</project>
61 changes: 28 additions & 33 deletions ...om/microsoft/azure/management/cosmosdb/samples/CreateCosmosDBWithEventualConsistency.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,16 +6,16 @@

package com.microsoft.azure.management.cosmosdb.samples;

import com.azure.cosmos.ConsistencyLevel;
import com.azure.cosmos.CosmosClient;
import com.azure.cosmos.CosmosClientBuilder;
import com.azure.cosmos.CosmosDatabase;
import com.azure.cosmos.CosmosException;
import com.azure.cosmos.models.CosmosContainerProperties;
import com.azure.cosmos.models.ThroughputProperties;
import com.microsoft.azure.CloudException;
import com.microsoft.azure.credentials.ApplicationTokenCredentials;
import com.microsoft.azure.management.Azure;
import com.microsoft.azure.documentdb.DocumentClient;
import com.microsoft.azure.documentdb.ConsistencyLevel;
import com.microsoft.azure.documentdb.ConnectionPolicy;
import com.microsoft.azure.documentdb.Database;
import com.microsoft.azure.documentdb.DocumentCollection;
import com.microsoft.azure.documentdb.DocumentClientException;
import com.microsoft.azure.documentdb.RequestOptions;
import com.microsoft.azure.management.cosmosdb.CosmosDBAccount;
import com.microsoft.azure.management.cosmosdb.DatabaseAccountKind;
import com.microsoft.azure.management.cosmosdb.DatabaseAccountListKeysResult;
Expand All @@ -30,12 +30,12 @@
* Azure CosmosDB sample for high availability.
* - Create a CosmosDB configured with eventual consistency
* - Get the credentials for the CosmosDB
* - add collection to the CosmosDB
* - add container to the CosmosDB
* - Delete the CosmosDB.
*/
public final class CreateCosmosDBWithEventualConsistency {
static final String DATABASE_ID = "TestDB";
static final String COLLECTION_ID = "TestCollection";
static final String CONTAINER_ID = "TestContainer";

/**
* Main function which runs the actual sample.
Expand Down Expand Up @@ -73,10 +73,10 @@ public static boolean runSample(Azure azure, String clientId) {
String endPoint = cosmosDBAccount.documentEndpoint();

//============================================================
// Connect to CosmosDB and add a collection
// Connect to CosmosDB and add a container

System.out.println("Connecting and adding collection");
createDBAndAddCollection(masterKey, endPoint);
System.out.println("Connecting and adding container");
createDBAndAddContainer(masterKey, endPoint);

//============================================================
// Delete CosmosDB
Expand Down Expand Up @@ -106,34 +106,29 @@ public static boolean runSample(Azure azure, String clientId) {
return false;
}

private static void createDBAndAddCollection(String masterKey, String endPoint) throws DocumentClientException {
private static void createDBAndAddContainer(String masterKey, String endPoint) throws CosmosException {
try {
DocumentClient documentClient = new DocumentClient(endPoint,
masterKey, ConnectionPolicy.GetDefault(),
ConsistencyLevel.Session);
CosmosClient cosmosClient = new CosmosClientBuilder()
.endpoint(endPoint)
.key(masterKey)
.consistencyLevel(ConsistencyLevel.SESSION)
.buildClient();

// Define a new database using the id above.
Database myDatabase = new Database();
myDatabase.setId(DATABASE_ID);

myDatabase = documentClient.createDatabase(myDatabase, null)
.getResource();
cosmosClient.createDatabase(DATABASE_ID);

System.out.println("Created a new database:");
System.out.println(myDatabase.toString());
CosmosDatabase cosmosDatabase = cosmosClient.getDatabase(DATABASE_ID);

// Define a new collection using the id above.
DocumentCollection myCollection = new DocumentCollection();
myCollection.setId(COLLECTION_ID);
System.out.println("Created a new database:");
System.out.println(cosmosDatabase.getId());

// Set the provisioned throughput for this collection to be 1000 RUs.
RequestOptions requestOptions = new RequestOptions();
requestOptions.setOfferThroughput(1000);
// Set the provisioned throughput for this container to be 1000 RUs.
Integer throughput = 1000;
ThroughputProperties properties = ThroughputProperties.createManualThroughput(throughput);

// Create a new collection.
myCollection = documentClient.createCollection(
"dbs/" + DATABASE_ID, myCollection, requestOptions)
.getResource();
// Create a new container.
CosmosContainerProperties containerProperties = new CosmosContainerProperties(CONTAINER_ID, "/id");
cosmosDatabase.createContainerIfNotExists(containerProperties, properties);
} catch (Exception ex) {
throw ex;
}
Expand Down