AsyncDocumentClient Schnittstelle
public interface AsyncDocumentClient
Stellt eine clientseitige logische Darstellung des Azure Cosmos DB-Datenbankdiensts bereit. Dieser asynchrone Client wird verwendet, um Anforderungen für den Dienst zu konfigurieren und auszuführen.
AsyncDocumentClientasynchrone APIs geben das Observable vonrxJava zurück
</code> , and so you can use rxJava <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> functionality. <b>The async <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> based APIs perform the requested operation only after subscription.</b></p>
Der Dienstclient kapselt den Endpunkt und die Anmeldeinformationen, die für den Zugriff auf den Cosmos DB-Dienst verwendet werden.
Zum Instanziieren können Sie die AsyncDocumentClient.Builder
ConnectionPolicy connectionPolicy = new ConnectionPolicy();connectionPolicy.setConnectionMode(ConnectionMode.Direct);
AsyncDocumentClient client = new AsyncDocumentClient.Builder()
.withServiceEndpoint(serviceEndpoint)
.withMasterKeyOrResourceToken(masterKey)
.withConnectionPolicy(connectionPolicy)
.withConsistencyLevel(ConsistencyLevel.Session)
.build();
</code></pre></p>
Methodenzusammenfassung
Modifizierer und Typ
Methode und Beschreibung
void
close()
Schließen Sie diese AsyncDocumentClient instance, und bereinigen Sie die Ressourcen.
Observable<ResourceResponse <Attachment>>
createAttachment(String documentLink, Attachment attachment, RequestOptions options)
Erstellt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Attachment>>
createAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Erstellt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <DocumentCollection >>
createCollection(String databaseLink, DocumentCollection collection, RequestOptions options)
Erstellt eine Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Auflistung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Database>>
createDatabase(Database database, RequestOptions options)
Erstellt eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Document>>
createDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Erstellt ein Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Permission>>
createPermission(String userLink, Permission permission, RequestOptions options)
Erstellt eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Berechtigung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <StoredProcedure >>
createStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Erstellt eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der erstellten gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Trigger>>
createTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Erstellt einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält bei erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit dem erstellten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <User>>
createUser(String databaseLink, User user, RequestOptions options)
Erstellt einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <UserDefinedFunction >>
createUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Erstellt eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Attachment>>
deleteAttachment(String attachmentLink, RequestOptions options)
Löscht eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für die gelöschte Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <DocumentCollection >>
deleteCollection(String collectionLink, RequestOptions options)
Löscht eine Dokumentsammlung über den Sammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für die gelöschte Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Conflict>>
deleteConflict(String conflictLink, RequestOptions options)
Löscht einen Konflikt.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für den gelöschten Konflikt. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Database>>
deleteDatabase(String databaseLink, RequestOptions options)
Löscht eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der gelöschten Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Document>>
deleteDocument(String documentLink, RequestOptions options)
Löscht ein Dokument anhand des Dokumentlinks.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für das gelöschte Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Permission>>
deletePermission(String permissionLink, RequestOptions options)
Löscht eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte Berechtigung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <StoredProcedure >>
deleteStoredProcedure(String storedProcedureLink, RequestOptions options)
Löscht eine gespeicherte Prozedur durch den Link für die gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte gespeicherte Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Trigger>>
deleteTrigger(String triggerLink, RequestOptions options)
Löscht einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für den gelöschten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <User>>
deleteUser(String userLink, RequestOptions options)
Löscht einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für den gelöschten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <UserDefinedFunction >>
deleteUserDefinedFunction(String udfLink, RequestOptions options)
Löscht eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte benutzerdefinierte Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<StoredProcedureResponse >
executeStoredProcedure(String storedProcedureLink, Object[] procedureParams)
Führt eine gespeicherte Prozedur über den Link für die gespeicherte Prozedur aus.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der Antwort der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<StoredProcedureResponse >
executeStoredProcedure(String storedProcedureLink, RequestOptions options, Object[] procedureParams)
Führt eine gespeicherte Prozedur über den Link für die gespeicherte Prozedur aus.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der Antwort der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
ConnectionPolicy
getConnectionPolicy()
Ruft die Verbindungsrichtlinie ab.
Observable<DatabaseAccount >
getDatabaseAccount()
Ruft Datenbankkontoinformationen ab.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem Datenbankkonto. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
URI
getReadEndpoint()
Ruft den aktuellen Leseendpunkt ab, der basierend auf Verfügbarkeit und Einstellung ausgewählt wurde.
URI
getServiceEndpoint()
Ruft den Standardendpunkt des Dienstendpunkts ab, der vom Benutzer während der Erstellung übergeben wird.
URI
getWriteEndpoint()
Ruft den aktuellen Schreibendpunkt ab, der basierend auf Verfügbarkeit und Einstellung ausgewählt wurde.
void
monitor(MeterRegistry registry)
Fügt eine Verbrauchseinheitsregistrierung zum Melden von Direct TCP-Metriken hinzu.
Observable<FeedResponse <Attachment>>
queryAttachments(String documentLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Anlagen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Anlagen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Attachment>>
queryAttachments(String documentLink, String query, FeedOptions options)
Abfragen von Anlagen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Anlagen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <DocumentCollection >>
queryCollections(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Sammlungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <DocumentCollection >>
queryCollections(String databaseLink, String query, FeedOptions options)
Abfragen von Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Sammlungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Conflict>>
queryConflicts(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Konflikten.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Konflikte. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Conflict>>
queryConflicts(String collectionLink, String query, FeedOptions options)
Abfragen von Konflikten.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Konflikte. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Database>>
queryDatabases(SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Datenbanken. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Database>>
queryDatabases(String query, FeedOptions options)
Abfragen von Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Document>>
queryDocumentChangeFeed(String collectionLink, ChangeFeedOptions changeFeedOptions)
Abfragen von Dokumentenänderungsfeeds in einer Dokumentsammlung. Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Document>>
queryDocuments(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Dokumenten in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Document>>
queryDocuments(String collectionLink, String query, FeedOptions options)
Abfragen von Dokumenten in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Offer>>
queryOffers(SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Angeboten in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten mit erhaltenen Angeboten. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Offer>>
queryOffers(String query, FeedOptions options)
Abfragen von Angeboten in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten mit erhaltenen Angeboten. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Permission>>
queryPermissions(String permissionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Permission>>
queryPermissions(String permissionLink, String query, FeedOptions options)
Abfragen von Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <StoredProcedure >>
queryStoredProcedures(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen gespeicherter Prozeduren in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <StoredProcedure >>
queryStoredProcedures(String collectionLink, String query, FeedOptions options)
Abfragen gespeicherter Prozeduren in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Trigger>>
queryTriggers(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfrage nach Triggern.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Trigger. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Trigger>>
queryTriggers(String collectionLink, String query, FeedOptions options)
Abfrage nach Triggern.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Trigger. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <UserDefinedFunction >>
queryUserDefinedFunctions(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfrage für benutzerdefinierte Funktionen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <UserDefinedFunction >>
queryUserDefinedFunctions(String collectionLink, String query, FeedOptions options)
Abfrage für benutzerdefinierte Funktionen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <User>>
queryUsers(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen für Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <User>>
queryUsers(String databaseLink, String query, FeedOptions options)
Abfragen für Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Attachment>>
readAttachment(String attachmentLink, RequestOptions options)
Liest eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Leseanlage. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Attachment>>
readAttachments(String documentLink, FeedOptions options)
Liest alle Anlagen in einem Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseanlagen. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <DocumentCollection >>
readCollection(String collectionLink, RequestOptions options)
Liest eine Dokumentsammlung über den Sammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Leseauflistung. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <DocumentCollection >>
readCollections(String databaseLink, FeedOptions options)
Liest alle Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Leseauflistungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Conflict>>
readConflict(String conflictLink, RequestOptions options)
Liest einen Konflikt.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem Lesekonflikt. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Conflict>>
readConflicts(String collectionLink, FeedOptions options)
Liest alle Konflikte in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Lesekonflikte. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Database>>
readDatabase(String databaseLink, RequestOptions options)
Liest eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Lesedatenbank. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Database>>
readDatabases(FeedOptions options)
Liest alle Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Document>>
readDocument(String documentLink, RequestOptions options)
Liest ein Dokument anhand des Dokumentlinks.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem gelesenen Dokument. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Document>>
readDocuments(String collectionLink, FeedOptions options)
Liest alle Dokumente in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der gelesenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Observable<MediaResponse >
readMedia(String mediaLink)
Liest ein Medium über den Medienlink.
Observable<ResourceResponse <Offer>>
readOffer(String offerLink)
Liest ein Angebot.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem Leseangebot. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Offer>>
readOffers(FeedOptions options)
Liest Angebote.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseangebote. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <PartitionKeyRange >>
readPartitionKeyRanges(String collectionLink, FeedOptions options)
Liest alle Partitionsschlüsselbereiche in einer Dokumentsammlung. Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Partitionsschlüsselbereiche. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Permission>>
readPermission(String permissionLink, RequestOptions options)
Liest eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit leseberechtigung. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Permission>>
readPermissions(String permissionLink, FeedOptions options)
Liest alle Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseberechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <StoredProcedure >>
readStoredProcedure(String storedProcedureLink, RequestOptions options)
Liest eine gespeicherte Prozedur über den Link für gespeicherte Prozeduren.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der gelesenen gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <StoredProcedure >>
readStoredProcedures(String collectionLink, FeedOptions options)
Liest alle gespeicherten Prozeduren in einem Dokumentsammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der gelesenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Trigger>>
readTrigger(String triggerLink, RequestOptions options)
Liest einen Trigger über den Triggerlink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort für den Lesetrigger. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <Trigger>>
readTriggers(String collectionLink, FeedOptions options)
Liest alle Trigger in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Lesetrigger. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <User>>
readUser(String userLink, RequestOptions options)
Liest einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem gelesenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <UserDefinedFunction >>
readUserDefinedFunction(String udfLink, RequestOptions options)
Liest eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort für die benutzerdefinierte Funktion read. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <UserDefinedFunction >>
readUserDefinedFunctions(String collectionLink, FeedOptions options)
Liest alle benutzerdefinierten Funktionen in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der benutzerdefinierten Lesefunktionen. Im Falle eines Fehlers wird der Observable fehler.
Observable<FeedResponse <User>>
readUsers(String databaseLink, FeedOptions options)
Liest alle Benutzer in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der gelesenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Attachment>>
replaceAttachment(Attachment attachment, RequestOptions options)
Ersetzt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Anlage. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <DocumentCollection >>
replaceCollection(DocumentCollection collection, RequestOptions options)
Ersetzt eine Dokumentauflistung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Dokumentauflistung. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Document>>
replaceDocument(Document document, RequestOptions options)
Ersetzt ein Dokument durch das übergebene Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Dokument. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Document>>
replaceDocument(String documentLink, Object document, RequestOptions options)
Ersetzt ein Dokument mithilfe eines POJO-Objekts.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Dokument. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Offer>>
replaceOffer(Offer offer)
Ersetzt ein Angebot.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Angebot. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Permission>>
replacePermission(Permission permission, RequestOptions options)
Ersetzt eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Berechtigung. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <StoredProcedure >>
replaceStoredProcedure(StoredProcedure storedProcedure, RequestOptions options)
Ersetzt eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable fehler.
Observable<ResourceResponse <Trigger>>
replaceTrigger(Trigger trigger, RequestOptions options)
Ersetzt einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält bei erfolgreicher Ausführung eine einzelne Ressourcenantwort mit dem ersetzten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <User>>
replaceUser(User user, RequestOptions options)
Ersetzt einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem ersetzten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <UserDefinedFunction >>
replaceUserDefinedFunction(UserDefinedFunction udf, RequestOptions options)
Ersetzt eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der ersetzten benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<MediaResponse >
updateMedia(String mediaLink, InputStream mediaStream, MediaOptions options)
Updates eines Mediums über den Medienlink.
Observable<ResourceResponse <Attachment>>
upsertAttachment(String documentLink, Attachment attachment, RequestOptions options)
Upsert eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der upsertierten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Attachment>>
upsertAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Upsert eine Anlage für den Mediendatenstrom
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der upsertierten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Document>>
upsertDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Upsert ein Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherhaltenen Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Permission>>
upsertPermission(String userLink, Permission permission, RequestOptions options)
Upsert eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der berechtigung "upserted". Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <StoredProcedure >>
upsertStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Upsert eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält bei erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <Trigger>>
upsertTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Führt einen Trigger hoch.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit dem upsertierten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <User>>
upsertUser(String databaseLink, User user, RequestOptions options)
Upsert einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherhaltenen Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Observable<ResourceResponse <UserDefinedFunction >>
upsertUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Upsert eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Details zur Methode
close
public void close()
Schließen Sie diese AsyncDocumentClient instance, und bereinigen Sie die Ressourcen.
createAttachment
public Observable> createAttachment(String documentLink, Attachment attachment, RequestOptions options)
Erstellt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
documentLink
- der Dokumentlink.
attachment
- die zu erstellende Anlage.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten Anlage oder einem Fehler enthält.
createAttachment
public Observable> createAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Erstellt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
documentLink
- der Dokumentlink.
mediaStream
- der Mediendatenstrom zum Erstellen der Anlage.
options
- die Medienoptionen.
requestOptions
- die Anforderungsoptionen
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten Anlage oder einem Fehler enthält.
createCollection
public Observable> createCollection(String databaseLink, DocumentCollection collection, RequestOptions options)
Erstellt eine Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Auflistung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
databaseLink
- der Datenbanklink.
collection
- die Auflistung.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten Auflistung oder einem Fehler enthält.
createDatabase
public Observable> createDatabase(Database database, RequestOptions options)
Erstellt eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
database
- die Datenbank.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten Datenbank oder einem Fehler enthält.
createDocument
public Observable> createDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Erstellt ein Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentsammlung.
document
- das Dokument, das als POJO- oder Document-Objekt dargestellt wird.
options
- die Anforderungsoptionen.
disableAutomaticIdGeneration
- das Flag zum Deaktivieren der automatischen ID-Generierung.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem erstellten Dokument oder einem Fehler enthält.
createPermission
public Observable> createPermission(String userLink, Permission permission, RequestOptions options)
Erstellt eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten Berechtigung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
userLink
- der Benutzerlink.
permission
- die Berechtigung zum Erstellen.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort mit der erstellten Berechtigung oder einem Fehler enthält.
createStoredProcedure
public Observable> createStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Erstellt eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der erstellten gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
storedProcedure
- die zu erstellende gespeicherte Prozedur.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten gespeicherten Prozedur oder einem Fehler enthält.
createTrigger
public Observable> createTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Erstellt einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält bei erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit dem erstellten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
trigger
- der Trigger.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort mit dem erstellten Trigger oder einem Fehler enthält.
createUser
public Observable> createUser(String databaseLink, User user, RequestOptions options)
Erstellt einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem erstellten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
databaseLink
- der Datenbanklink.
user
- der zu erstellende Benutzer.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Einzelne-Ressourcenantwort mit dem erstellten Benutzer oder einen Fehler enthält.
createUserDefinedFunction
public Observable> createUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Erstellt eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der erstellten benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
udf
- die benutzerdefinierte Funktion.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der erstellten benutzerdefinierten Funktion oder einem Fehler enthält.
deleteAttachment
public Observable> deleteAttachment(String attachmentLink, RequestOptions options)
Löscht eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für die gelöschte Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
attachmentLink
- der Anlagelink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort für die gelöschte Anlage oder einen Fehler enthält.
deleteCollection
public Observable> deleteCollection(String collectionLink, RequestOptions options)
Löscht eine Dokumentsammlung über den Sammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für die gelöschte Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für die gelöschte Datenbank oder einen Fehler enthält.
deleteConflict
public Observable> deleteConflict(String conflictLink, RequestOptions options)
Löscht einen Konflikt.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für den gelöschten Konflikt. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
conflictLink
- konfliktlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für den gelöschten Konflikt oder einen Fehler enthält.
deleteDatabase
public Observable> deleteDatabase(String databaseLink, RequestOptions options)
Löscht eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der gelöschten Datenbank. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
databaseLink
- der Datenbanklink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der gelöschten Datenbank oder einem Fehler enthält.
deleteDocument
public Observable> deleteDocument(String documentLink, RequestOptions options)
Löscht ein Dokument anhand des Dokumentlinks.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für das gelöschte Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
documentLink
- der Dokumentlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für das gelöschte Dokument oder einen Fehler enthält.
deletePermission
public Observable> deletePermission(String permissionLink, RequestOptions options)
Löscht eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte Berechtigung. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
permissionLink
- der Berechtigungslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort für die gelöschte Berechtigung oder einen Fehler enthält.
deleteStoredProcedure
public Observable> deleteStoredProcedure(String storedProcedureLink, RequestOptions options)
Löscht eine gespeicherte Prozedur durch den Link für die gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte gespeicherte Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
storedProcedureLink
- der Link für die gespeicherte Prozedur.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für die gelöschte gespeicherte Prozedur oder einen Fehler enthält.
deleteTrigger
public Observable> deleteTrigger(String triggerLink, RequestOptions options)
Löscht einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für den gelöschten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
triggerLink
- der Triggerlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort für den gelöschten Trigger oder einen Fehler enthält.
deleteUser
public Observable> deleteUser(String userLink, RequestOptions options)
Löscht einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort für den gelöschten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
userLink
- der Benutzerlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort für den gelöschten Benutzer oder einen Fehler enthält.
deleteUserDefinedFunction
public Observable> deleteUserDefinedFunction(String udfLink, RequestOptions options)
Löscht eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort für die gelöschte benutzerdefinierte Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
udfLink
- der benutzerdefinierte Funktionslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für die gelöschte benutzerdefinierte Funktion oder einen Fehler enthält.
executeStoredProcedure
public Observable executeStoredProcedure(String storedProcedureLink, Object[] procedureParams)
Führt eine gespeicherte Prozedur über den Link für die gespeicherte Prozedur aus.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der Antwort der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
storedProcedureLink
- der Link für die gespeicherte Prozedur.
procedureParams
- das Array von Prozedurparameterwerten.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Antwort der gespeicherten Prozedur oder eines Fehlers enthält.
executeStoredProcedure
public Observable executeStoredProcedure(String storedProcedureLink, RequestOptions options, Object[] procedureParams)
Führt eine gespeicherte Prozedur über den Link für die gespeicherte Prozedur aus.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der Antwort der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
storedProcedureLink
- der Link für die gespeicherte Prozedur.
options
- die Anforderungsoptionen.
procedureParams
- das Array von Prozedurparameterwerten.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Antwort der gespeicherten Prozedur oder eines Fehlers enthält.
getConnectionPolicy
public ConnectionPolicy getConnectionPolicy()
Ruft die Verbindungsrichtlinie ab.
Gibt zurück:
Die Verbindungsrichtlinie
getDatabaseAccount
public Observable getDatabaseAccount()
Ruft Datenbankkontoinformationen ab.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem Datenbankkonto. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort mit dem Datenbankkonto oder einen Fehler enthält.
getReadEndpoint
public URI getReadEndpoint()
Ruft den aktuellen Leseendpunkt ab, der basierend auf Verfügbarkeit und Einstellung ausgewählt wurde.
Gibt zurück:
der Leseendpunkt-URI
getServiceEndpoint
public URI getServiceEndpoint()
Ruft den Standardendpunkt des Dienstendpunkts ab, der vom Benutzer während der Erstellung übergeben wird.
Gibt zurück:
Der Dienstendpunkt-URI
getWriteEndpoint
public URI getWriteEndpoint()
Ruft den aktuellen Schreibendpunkt ab, der basierend auf Verfügbarkeit und Einstellung ausgewählt wurde.
Gibt zurück:
der Schreibendpunkt-URI
monitor
public static void monitor(MeterRegistry registry)
Fügt eine Verbrauchseinheitsregistrierung zum Melden von Direct TCP-Metriken hinzu.
Parameter:
registry
- Eine Verbrauchseinheitsregistrierung, die zum Melden von Direct TCP-Metriken verwendet werden soll
queryAttachments
public Observable> queryAttachments(String documentLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Anlagen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Anlagen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
documentLink
- der Dokumentlink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen Anlagen oder einen Fehler enthält.
queryAttachments
public Observable> queryAttachments(String documentLink, String query, FeedOptions options)
Abfragen von Anlagen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Anlagen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
documentLink
- der Dokumentlink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen Anlagen oder einen Fehler enthält.
queryCollections
public Observable> queryCollections(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Sammlungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
ein , das Observable eine oder mehrere Feedantwortseiten der abgerufenen Auflistungen oder einen Fehler enthält.
queryCollections
public Observable> queryCollections(String databaseLink, String query, FeedOptions options)
Abfragen von Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Sammlungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , das Observable eine oder mehrere Feedantwortseiten der abgerufenen Auflistungen oder einen Fehler enthält.
queryConflicts
public Observable> queryConflicts(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Konflikten.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Konflikte. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der erhaltenen Konflikte oder einen Fehler enthält.
queryConflicts
public Observable> queryConflicts(String collectionLink, String query, FeedOptions options)
Abfragen von Konflikten.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Konflikte. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der erhaltenen Konflikte oder einen Fehler enthält.
queryDatabases
public Observable> queryDatabases(SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der abgerufenen Datenbanken. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der abgerufenen Datenbanken oder einen Fehler enthält.
queryDatabases
public Observable> queryDatabases(String query, FeedOptions options)
Abfragen von Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten von Lesedatenbanken oder einen Fehler enthält.
queryDocumentChangeFeed
public Observable> queryDocumentChangeFeed(String collectionLink, ChangeFeedOptions changeFeedOptions)
Abfragen von Dokumentenänderungsfeeds in einer Dokumentsammlung. Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentauflistung.
changeFeedOptions
- die Änderungsfeedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der abgerufenen Dokumente oder einen Fehler enthält.
queryDocuments
public Observable> queryDocuments(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Dokumenten in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentauflistung.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der abgerufenen Dokumente oder einen Fehler enthält.
queryDocuments
public Observable> queryDocuments(String collectionLink, String query, FeedOptions options)
Abfragen von Dokumenten in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der erhaltenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentauflistung.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten des abgerufenen Dokuments oder einen Fehler enthält.
queryOffers
public Observable> queryOffers(SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Angeboten in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten mit erhaltenen Angeboten. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
querySpec
- die Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
ein , das Observable eine oder mehrere Feedantwortseiten der erhaltenen Angebote oder einen Fehler enthält.
queryOffers
public Observable> queryOffers(String query, FeedOptions options)
Abfragen von Angeboten in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten mit erhaltenen Angeboten. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , das Observable eine oder mehrere Feedantwortseiten der erhaltenen Angebote oder einen Fehler enthält.
queryPermissions
public Observable> queryPermissions(String permissionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen von Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
permissionLink
- der Berechtigungslink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen oder einen Fehler enthält.
queryPermissions
public Observable> queryPermissions(String permissionLink, String query, FeedOptions options)
Abfragen von Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
permissionLink
- der Berechtigungslink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der erhaltenen Berechtigungen oder einen Fehler enthält.
queryStoredProcedures
public Observable> queryStoredProcedures(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen gespeicherter Prozeduren in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren oder einen Fehler enthält.
queryStoredProcedures
public Observable> queryStoredProcedures(String collectionLink, String query, FeedOptions options)
Abfragen gespeicherter Prozeduren in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen gespeicherten Prozeduren oder einen Fehler enthält.
queryTriggers
public Observable> queryTriggers(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfrage nach Triggern.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Trigger. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen Trigger oder einen Fehler enthält.
queryTriggers
public Observable> queryTriggers(String collectionLink, String query, FeedOptions options)
Abfrage nach Triggern.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Trigger. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
ein , Observable das eine oder mehrere Feedantwortseiten der abgerufenen Trigger oder einen Fehler enthält.
queryUserDefinedFunctions
public Observable> queryUserDefinedFunctions(String collectionLink, SqlQuerySpec querySpec, FeedOptions options)
Abfrage für benutzerdefinierte Funktionen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen oder einen Fehler enthält.
queryUserDefinedFunctions
public Observable> queryUserDefinedFunctions(String collectionLink, String query, FeedOptions options)
Abfrage für benutzerdefinierte Funktionen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der abgerufenen benutzerdefinierten Funktionen oder einen Fehler enthält.
queryUsers
public Observable> queryUsers(String databaseLink, SqlQuerySpec querySpec, FeedOptions options)
Abfragen für Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
querySpec
- die SQL-Abfragespezifikation.
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der abgerufenen Benutzer oder einen Fehler enthält.
queryUsers
public Observable> queryUsers(String databaseLink, String query, FeedOptions options)
Abfragen für Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
query
- die Abfrage.
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der abgerufenen Benutzer oder einen Fehler enthält.
readAttachment
public Observable> readAttachment(String attachmentLink, RequestOptions options)
Liest eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Leseanlage. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
attachmentLink
- Der Anhangslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Leseanlage oder einem Fehler enthält.
readAttachments
public Observable> readAttachments(String documentLink, FeedOptions options)
Liest alle Anlagen in einem Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseanlagen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
documentLink
- der Dokumentlink.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der Leseanlagen oder einen Fehler enthält.
readCollection
public Observable> readCollection(String collectionLink, RequestOptions options)
Liest eine Dokumentsammlung über den Sammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Leseauflistung. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Leseauflistung oder einem Fehler enthält.
readCollections
public Observable> readCollections(String databaseLink, FeedOptions options)
Liest alle Dokumentsammlungen in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Leseauflistungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
options
- die Gebührenoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der Leseauflistungen oder einen Fehler enthält.
readConflict
public Observable> readConflict(String conflictLink, RequestOptions options)
Liest einen Konflikt.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem Lesekonflikt. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
conflictLink
- der Konfliktlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem Lesekonflikt oder einem Fehler enthält.
readConflicts
public Observable> readConflicts(String collectionLink, FeedOptions options)
Liest alle Konflikte in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Lesekonflikte. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der Lesekonflikte oder einen Fehler enthält.
readDatabase
public Observable> readDatabase(String databaseLink, RequestOptions options)
Liest eine Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der Lesedatenbank. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Lesedatenbank oder einem Fehler enthält.
readDatabases
public Observable> readDatabases(FeedOptions options)
Liest alle Datenbanken.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der Lesedatenbanken. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten von Lesedatenbanken oder einen Fehler enthält.
readDocument
public Observable> readDocument(String documentLink, RequestOptions options)
Liest ein Dokument anhand des Dokumentlinks.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem gelesenen Dokument. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
documentLink
- der Dokumentlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem Lesedokument oder einem Fehler enthält.
readDocuments
public Observable> readDocuments(String collectionLink, FeedOptions options)
Liest alle Dokumente in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantworten der gelesenen Dokumente. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der gelesenen Dokumente oder einen Fehler enthält.
readMedia
public Observable readMedia(String mediaLink)
Liest ein Medium über den Medienlink.
Parameter:
mediaLink
- der Medienlink.
Gibt zurück:
die Medienantwort.
readOffer
public Observable> readOffer(String offerLink)
Liest ein Angebot.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem Leseangebot. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
offerLink
- der Angebotslink.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource mit dem Leseangebot oder einem Fehler enthält.
readOffers
public Observable> readOffers(FeedOptions options)
Liest Angebote.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseangebote. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der Leseangebote oder einen Fehler enthält.
readPartitionKeyRanges
public Observable> readPartitionKeyRanges(String collectionLink, FeedOptions options)
Liest alle Partitionsschlüsselbereiche in einer Dokumentsammlung. Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der abgerufenen Partitionsschlüsselbereiche. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentauflistung.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der abgerufenen Partitionsschlüsselbereiche oder einen Fehler enthält.
readPermission
public Observable> readPermission(String permissionLink, RequestOptions options)
Liest eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit leseberechtigung. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
permissionLink
- der Berechtigungslink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Leseberechtigung oder einem Fehler enthält.
readPermissions
public Observable> readPermissions(String permissionLink, FeedOptions options)
Liest alle Berechtigungen.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Leseberechtigungen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
permissionLink
- der Berechtigungslink.
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der Leseberechtigungen oder einen Fehler enthält.
readStoredProcedure
public Observable> readStoredProcedure(String storedProcedureLink, RequestOptions options)
Liest eine gespeicherte Prozedur über den Link für gespeicherte Prozeduren.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der gelesenen gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
storedProcedureLink
- Der Link für die gespeicherte Prozedur.
options
- die Anforderungsoptionen.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource mit der gespeicherten Prozedur oder einem Fehler enthält.
readStoredProcedures
public Observable> readStoredProcedures(String collectionLink, FeedOptions options)
Liest alle gespeicherten Prozeduren in einem Dokumentsammlungslink.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der gelesenen gespeicherten Prozeduren. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der gelesenen gespeicherten Prozeduren oder einen Fehler enthält.
readTrigger
public Observable> readTrigger(String triggerLink, RequestOptions options)
Liest einen Trigger über den Triggerlink.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort für den Lesetrigger. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
triggerLink
- der Triggerlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource für den Lesetrigger oder einen Fehler enthält.
readTriggers
public Observable> readTriggers(String collectionLink, FeedOptions options)
Liest alle Trigger in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der Lesetrigger. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Feedoptionen.
Gibt zurück:
eine , Observable die eine oder mehrere Feedantwortseiten der Lesetrigger oder einen Fehler enthält.
readUser
public Observable> readUser(String userLink, RequestOptions options)
Liest einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem gelesenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
userLink
- Der Benutzerlink.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem Lesebenutzer oder einem Fehler enthält.
readUserDefinedFunction
public Observable> readUserDefinedFunction(String udfLink, RequestOptions options)
Liest eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort für die benutzerdefinierte Funktion read. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
udfLink
- der benutzerdefinierte Funktionslink.
options
- die Anforderungsoptionen.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource für die benutzerdefinierte Lesefunktion oder einen Fehler enthält.
readUserDefinedFunctions
public Observable> readUserDefinedFunctions(String collectionLink, FeedOptions options)
Liest alle benutzerdefinierten Funktionen in einer Dokumentsammlung.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der benutzerdefinierten Lesefunktionen. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collectionLink
- der Sammlungslink.
options
- die Feedoptionen.
Gibt zurück:
ein , das Observable eine oder mehrere Feedantwortseiten der gelesenen benutzerdefinierten Funktionen oder einen Fehler enthält.
readUsers
public Observable> readUsers(String databaseLink, FeedOptions options)
Liest alle Benutzer in einer Datenbank.
Nach dem Abonnement wird der Vorgang ausgeführt. Enthält Observable eine oder mehrere Feedantwortseiten der gelesenen Benutzer. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
databaseLink
- der Datenbanklink.
options
- die Feedoptionen.
Gibt zurück:
eine Observable , die eine oder mehrere Feedantwortseiten der gelesenen Benutzer oder einen Fehler enthält.
replaceAttachment
public Observable> replaceAttachment(Attachment attachment, RequestOptions options)
Ersetzt eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Anlage. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
attachment
- die zu verwendende Anlage.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der ersetzten Anlage oder einem Fehler enthält.
replaceCollection
public Observable> replaceCollection(DocumentCollection collection, RequestOptions options)
Ersetzt eine Dokumentauflistung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Dokumentauflistung. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
collection
- die zu verwendende Dokumentauflistung.
options
- die Anforderungsoptionen.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource mit der ersetzten Dokumentauflistung oder einem Fehler enthält.
replaceDocument
public Observable> replaceDocument(Document document, RequestOptions options)
Ersetzt ein Dokument durch das übergebene Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Dokument. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
document
- das zu ersetzende Dokument (mit der Dokument-ID).
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem ersetzten Dokument oder einem Fehler enthält.
replaceDocument
public Observable> replaceDocument(String documentLink, Object document, RequestOptions options)
Ersetzt ein Dokument mithilfe eines POJO-Objekts.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Dokument. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
documentLink
- der Dokumentlink.
document
- das Dokument, das als POJO- oder Document-Objekt dargestellt wird.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem ersetzten Dokument oder einem Fehler enthält.
replaceOffer
public Observable> replaceOffer(Offer offer)
Ersetzt ein Angebot.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit dem ersetzten Angebot. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
offer
- das zu verwendende Angebot.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem ersetzten Angebot oder einem Fehler enthält.
replacePermission
public Observable> replacePermission(Permission permission, RequestOptions options)
Ersetzt eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten Berechtigung. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
permission
- die zu verwendende Berechtigung.
options
- die Anforderungsoptionen.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource mit der ersetzten Berechtigung oder einem Fehler enthält.
replaceStoredProcedure
public Observable> replaceStoredProcedure(StoredProcedure storedProcedure, RequestOptions options)
Ersetzt eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreichem Abschluss enthält eine einzelne Ressourcenantwort mit der ersetzten gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable fehler.
Parameter:
storedProcedure
- die zu verwendende gespeicherte Prozedur.
options
- die Anforderungsoptionen.
Gibt zurück:
ein , Observable das die Antwort einer einzelnen Ressource mit der ersetzten gespeicherten Prozedur oder einem Fehler enthält.
replaceTrigger
public Observable> replaceTrigger(Trigger trigger, RequestOptions options)
Ersetzt einen Trigger.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält bei erfolgreicher Ausführung eine einzelne Ressourcenantwort mit dem ersetzten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
trigger
- der zu verwendende Trigger.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem ersetzten Trigger oder einem Fehler enthält.
replaceUser
public Observable> replaceUser(User user, RequestOptions options)
Ersetzt einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem ersetzten Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
user
- der zu verwendende Benutzer.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort mit dem ersetzten Benutzer oder einen Fehler enthält.
replaceUserDefinedFunction
public Observable> replaceUserDefinedFunction(UserDefinedFunction udf, RequestOptions options)
Ersetzt eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Bei Observable erfolgreicher Ausführung enthält eine einzelne Ressourcenantwort mit der ersetzten benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
udf
- die benutzerdefinierte Funktion.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die einzelne Ressourcenantwort mit der ersetzten benutzerdefinierten Funktion oder einem Fehler enthält.
updateMedia
public Observable updateMedia(String mediaLink, InputStream mediaStream, MediaOptions options)
Updates eines Mediums über den Medienlink.
Parameter:
mediaLink
- die Medienverbindung.
mediaStream
- der hochzuladende Medienstream.
options
- die Medienoptionen.
Gibt zurück:
die Medienantwort.
upsertAttachment
public Observable> upsertAttachment(String documentLink, Attachment attachment, RequestOptions options)
Upsert eine Anlage.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der upsertierten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
documentLink
- der Dokumentlink.
attachment
- die Anlage zu upsert.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der aktualisierten Anlage oder einem Fehler enthält.
upsertAttachment
public Observable> upsertAttachment(String documentLink, InputStream mediaStream, MediaOptions options, RequestOptions requestOptions)
Upsert eine Anlage für den Mediendatenstrom
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der upsertierten Anlage. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
documentLink
- der Dokumentlink.
mediaStream
- der Mediendatenstrom zum Upserting der Anlage.
options
- die Medienoptionen.
requestOptions
- die Anforderungsoptionen
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der aktualisierten Anlage oder einem Fehler enthält.
upsertDocument
public Observable> upsertDocument(String collectionLink, Object document, RequestOptions options, boolean disableAutomaticIdGeneration)
Upsert ein Dokument.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherhaltenen Dokument. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Link zur übergeordneten Dokumentsammlung.
document
- das Dokument, das als POJO- oder Document-Objekt dargestellt wird, um ein Upsert-Objekt zu erstellen.
options
- die Anforderungsoptionen.
disableAutomaticIdGeneration
- das Flag zum Deaktivieren der automatischen ID-Generierung.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem aktualisierten Dokument oder einem Fehler enthält.
upsertPermission
public Observable> upsertPermission(String userLink, Permission permission, RequestOptions options)
Upsert eine Berechtigung.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit der berechtigung "upserted". Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
userLink
- der Benutzerlink.
permission
- die Berechtigung zum Upsertieren.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der Berechtigung "Upserted" oder einem Fehler enthält.
upsertStoredProcedure
public Observable> upsertStoredProcedure(String collectionLink, StoredProcedure storedProcedure, RequestOptions options)
Upsert eine gespeicherte Prozedur.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält bei erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der gespeicherten Prozedur. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
storedProcedure
- die gespeicherte Prozedur, die upsert werden soll.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der gespeicherten Prozedur oder einem Fehler enthält.
upsertTrigger
public Observable> upsertTrigger(String collectionLink, Trigger trigger, RequestOptions options)
Führt einen Trigger hoch.
Nach dem Abonnement wird der Vorgang ausgeführt. Der Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit dem upsertierten Trigger. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
trigger
- der Trigger, um upsert zu werden.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem upsertierten Trigger oder einem Fehler enthält.
upsertUser
public Observable> upsertUser(String databaseLink, User user, RequestOptions options)
Upsert einen Benutzer.
Nach dem Abonnement wird der Vorgang ausgeführt. Nach Observable erfolgreicher Fertigstellung enthält eine einzelne Ressourcenantwort mit dem hocherhaltenen Benutzer. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
databaseLink
- der Datenbanklink.
user
- der Benutzer, der upsert werden soll.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit dem aktualisierten Benutzer oder einem Fehler enthält.
upsertUserDefinedFunction
public Observable> upsertUserDefinedFunction(String collectionLink, UserDefinedFunction udf, RequestOptions options)
Upsert eine benutzerdefinierte Funktion.
Nach dem Abonnement wird der Vorgang ausgeführt. Die Observable enthält nach erfolgreicher Fertigstellung eine einzelne Ressourcenantwort mit der benutzerdefinierten Funktion. Im Falle eines Fehlers wird der Observable Fehler angezeigt.
Parameter:
collectionLink
- der Sammlungslink.
udf
- die benutzerdefinierte Funktion, die upsert werden soll.
options
- die Anforderungsoptionen.
Gibt zurück:
eine Observable , die die Antwort einer einzelnen Ressource mit der benutzerdefinierten Funktion oder einem Fehler enthält.
Gilt für:
Azure SDK for Java