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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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)
);
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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)
);
Parameters:
Returns:
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.
Returns:
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.
Parameters:
Returns:
getClientEncryptionKey
public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)
Ruft ein CosmosAsyncClientEncryptionKey-Objekt ab, ohne einen Dienstaufruf auszuführen.
Parameters:
Returns:
getContainer
public CosmosAsyncContainer getContainer(String id)
Ruft ein CosmosAsyncContainer-Objekt ab, ohne einen Dienstaufruf durchzuführen.
Parameters:
Returns:
getId
public String getId()
Rufen Sie die ID der CosmosAsyncDatabase ab.
Returns:
getUser
public CosmosAsyncUser getUser(String id)
Ruft den Benutzer ab.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Parameters:
Returns:
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.
Returns:
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.
Parameters:
Returns:
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.
Returns:
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.
Parameters:
Returns:
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.
Returns:
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.
Parameters:
Returns:
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.
Returns:
readThroughput
public Mono
Ruft den Durchsatz der Datenbank ab.
cosmosAsyncDatabase.readThroughput()
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Returns:
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();
});
Parameters:
Returns:
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)
);
Parameters:
Returns:
Gilt für:
Azure SDK for Java
Feedback
Bald verfügbar: Im Laufe des Jahres 2024 werden wir GitHub-Issues stufenweise als Feedbackmechanismus für Inhalte abbauen und durch ein neues Feedbacksystem ersetzen. Weitere Informationen finden Sie unter https://aka.ms/ContentUserFeedback.
Feedback senden und anzeigen für