CosmosAsyncDatabase Klasse
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncDatabase
- com.
public class CosmosAsyncDatabase
Ausführen von Lese- und Löschdatenbanken, Aktualisieren des Datenbankdurchsatzes und Ausführen von Vorgängen für untergeordnete Ressourcen
Methodenzusammenfassung
Geerbte Methoden von java.lang.Object
Details zur Methode
createClientEncryptionKey
public Mono
Erstellt einen Clientverschlüsselungsschlüssel, nachdem das Abonnement ausgeführt wird. Nach Mono erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der Mono Fehler angezeigt.
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Cosmos-Container.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono Fehler angezeigt.
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Cosmos-Container.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreicher Fertigstellung enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Cosmos-Container mit benutzerdefinierten Durchsatzeigenschaften.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.createContainer(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Container.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(
containerProperties,
throughput,
options
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Cosmos-Container.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainer
public Mono
Erstellt einen Cosmos-Container.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainerIfNotExists
public Mono
Erstellt einen Cosmos-Container, wenn er im Dienst nicht vorhanden ist.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten oder vorhandenen Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainerIfNotExists
public Mono
Erstellt einen Cosmos-Container, wenn er im Dienst nicht vorhanden ist.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Die Durchsatzeigenschaften werden nur verwendet, wenn der angegebene Container nicht vorhanden ist und daher ein neuer Container erstellt wird.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten oder vorhandenen Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainerIfNotExists
public Mono
Erstellt einen Cosmos-Container, wenn er im Dienst nicht vorhanden ist.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createContainerIfNotExists
public Mono
Erstellt einen Cosmos-Container, wenn er im Dienst nicht vorhanden ist.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Die Durchsatzeigenschaften werden nur verwendet, wenn der angegebene Container nicht vorhanden ist und daher ein neuer Container erstellt wird.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Containerantwort mit dem erstellten Container. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
createUser
public Mono
Erstellt einen Benutzer Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem erstellten Benutzer. Im Falle eines Fehlers wird der Mono fehler.
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.createUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to create user: " + throwable)
);
Parameter:
Gibt zurück:
delete
public Mono
Löscht die aktuelle Cosmos-Datenbank.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine cosmos-Datenbankantwort mit der gelöschten Datenbank. Im Falle eines Fehlers wird der Mono fehler.
Gibt zurück:
delete
public Mono
Löscht die aktuelle Cosmos-Datenbank, während zusätzliche Anforderungsoptionen angegeben werden.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine cosmos-Datenbankantwort mit der gelöschten Datenbank. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
getClientEncryptionKey
public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)
Ruft ein CosmosAsyncClientEncryptionKey-Objekt ab, ohne einen Dienstaufruf auszuführen.
Parameter:
Gibt zurück:
getContainer
public CosmosAsyncContainer getContainer(String id)
Ruft ein CosmosAsyncContainer-Objekt ab, ohne einen Dienstaufruf durchzuführen.
Parameter:
Gibt zurück:
getId
public String getId()
Rufen Sie die ID der CosmosAsyncDatabase ab.
Gibt zurück:
getUser
public CosmosAsyncUser getUser(String id)
Ruft den Benutzer ab.
Parameter:
Gibt zurück:
queryClientEncryptionKeys
public CosmosPagedFlux
Abfragen von Cosmos-Clientverschlüsselungsschlüsseln in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryClientEncryptionKeys
public CosmosPagedFlux
Abfragen von Cosmos-Clientverschlüsselungsschlüsseln in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryClientEncryptionKeys
public CosmosPagedFlux
Abfragen von Cosmos-Clientverschlüsselungsschlüsseln in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryClientEncryptionKeys
public CosmosPagedFlux
Abfragen von Cosmos-Clientverschlüsselungsschlüsseln in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryContainers
public CosmosPagedFlux
Abfragen von Cosmos-Containern in einer cosmos-Datenbank.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Container. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryContainers
public CosmosPagedFlux
Abfragen von Cosmos-Containern in einer cosmos-Datenbank.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Container. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryContainers
public CosmosPagedFlux
Abfragen von Cosmos-Containern in einer cosmos-Datenbank.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Container. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryContainers
public CosmosPagedFlux
Abfragen von Cosmos-Containern in einer cosmos-Datenbank.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der erhaltenen Container. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryUsers
public CosmosPagedFlux
Abfragen von Cosmos-Benutzern in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der abgerufenen Benutzer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryUsers
public CosmosPagedFlux
Abfragen von Cosmos-Benutzern in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der abgerufenen Benutzer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryUsers
public CosmosPagedFlux
Abfragen von Cosmos-Benutzern in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der abgerufenen Benutzer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
queryUsers
public CosmosPagedFlux
Abfragen von Cosmos-Benutzern in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der abgerufenen Benutzer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
read
public Mono
Liest eine Datenbank. Rufen Sie die Details und Eigenschaften einer Datenbank basierend auf ihrem eindeutigen Bezeichner ab.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Cosmos-Datenbankantwort mit der Lesedatenbank. Im Falle eines Fehlers wird der Mono fehler.
Gibt zurück:
read
public Mono
Liest eine Datenbank. Rufen Sie die Details und Eigenschaften einer Datenbank basierend auf ihrem eindeutigen Bezeichner ab.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine Cosmos-Datenbankantwort mit der Lesedatenbank. Im Falle eines Fehlers wird der Mono fehler.
Parameter:
Gibt zurück:
readAllClientEncryptionKeys
public CosmosPagedFlux
Liest alle Cosmos-Clientverschlüsselungsschlüssel in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der Read Cosmos-Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Gibt zurück:
readAllClientEncryptionKeys
public CosmosPagedFlux
Liest alle Cosmos-Clientverschlüsselungsschlüssel in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der Read Cosmos-Clientverschlüsselungsschlüssel. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
readAllContainers
public CosmosPagedFlux
Liest alle Cosmos-Container.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der Lesecontainer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Gibt zurück:
readAllContainers
public CosmosPagedFlux
Liest alle Cosmos-Container.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der Lesecontainer. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Parameter:
Gibt zurück:
readAllUsers
public CosmosPagedFlux
Liest alle Cosmos-Benutzer in einer Datenbank.
cosmosAsyncDatabase.readAllUsers()
.byPage()
.flatMap(userPropertiesFeedResponse -> {
for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält CosmosPagedFlux<T> eine oder mehrere Feedantworten der Cosmos-Leser. Im Falle eines Fehlers wird der CosmosPagedFlux<T> fehler.
Gibt zurück:
readThroughput
public Mono
Ruft den Durchsatz der Datenbank ab.
cosmosAsyncDatabase.readThroughput()
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Gibt zurück:
replaceThroughput
public Mono
Legt den Durchsatz fest, der für einen Container bei der Messung von Anforderungen pro Einheit im Azure Cosmos-Dienst bereitgestellt wird.
ThroughputProperties autoscaledThroughput = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameter:
Gibt zurück:
upsertUser
public Mono
Upsertieren eines Benutzers. Upsert erstellt einen neuen Benutzer, wenn er nicht vorhanden ist, oder ersetzt den vorhandenen Benutzer, wenn dies der Fall ist. Nach dem Abonnement wird der Vorgang ausgeführt. Nach Mono erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem erstellten Benutzer. Im Falle eines Fehlers wird der Mono fehler.
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.upsertUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to upsert user: " + throwable)
);
Parameter:
Gibt zurück:
Gilt für:
Azure SDK for Java