SqlResourcesClientImpl.java
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// Code generated by Microsoft (R) AutoRest Code Generator.
package com.azure.resourcemanager.cosmos.implementation;
import com.azure.core.annotation.BodyParam;
import com.azure.core.annotation.Delete;
import com.azure.core.annotation.ExpectedResponses;
import com.azure.core.annotation.Get;
import com.azure.core.annotation.HeaderParam;
import com.azure.core.annotation.Headers;
import com.azure.core.annotation.Host;
import com.azure.core.annotation.HostParam;
import com.azure.core.annotation.PathParam;
import com.azure.core.annotation.Post;
import com.azure.core.annotation.Put;
import com.azure.core.annotation.QueryParam;
import com.azure.core.annotation.ReturnType;
import com.azure.core.annotation.ServiceInterface;
import com.azure.core.annotation.ServiceMethod;
import com.azure.core.annotation.UnexpectedResponseExceptionType;
import com.azure.core.http.rest.PagedFlux;
import com.azure.core.http.rest.PagedIterable;
import com.azure.core.http.rest.PagedResponse;
import com.azure.core.http.rest.PagedResponseBase;
import com.azure.core.http.rest.Response;
import com.azure.core.http.rest.RestProxy;
import com.azure.core.management.exception.ManagementException;
import com.azure.core.management.polling.PollResult;
import com.azure.core.util.Context;
import com.azure.core.util.FluxUtil;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.PollerFlux;
import com.azure.core.util.polling.SyncPoller;
import com.azure.resourcemanager.cosmos.fluent.SqlResourcesClient;
import com.azure.resourcemanager.cosmos.fluent.models.SqlContainerGetResultsInner;
import com.azure.resourcemanager.cosmos.fluent.models.SqlDatabaseGetResultsInner;
import com.azure.resourcemanager.cosmos.fluent.models.SqlStoredProcedureGetResultsInner;
import com.azure.resourcemanager.cosmos.fluent.models.SqlTriggerGetResultsInner;
import com.azure.resourcemanager.cosmos.fluent.models.SqlUserDefinedFunctionGetResultsInner;
import com.azure.resourcemanager.cosmos.fluent.models.ThroughputSettingsGetResultsInner;
import com.azure.resourcemanager.cosmos.models.SqlContainerCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.SqlContainerListResult;
import com.azure.resourcemanager.cosmos.models.SqlDatabaseCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.SqlDatabaseListResult;
import com.azure.resourcemanager.cosmos.models.SqlStoredProcedureCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.SqlStoredProcedureListResult;
import com.azure.resourcemanager.cosmos.models.SqlTriggerCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.SqlTriggerListResult;
import com.azure.resourcemanager.cosmos.models.SqlUserDefinedFunctionCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.SqlUserDefinedFunctionListResult;
import com.azure.resourcemanager.cosmos.models.ThroughputSettingsUpdateParameters;
import java.nio.ByteBuffer;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
/** An instance of this class provides access to all the operations defined in SqlResourcesClient. */
public final class SqlResourcesClientImpl implements SqlResourcesClient {
private final ClientLogger logger = new ClientLogger(SqlResourcesClientImpl.class);
/** The proxy service used to perform REST calls. */
private final SqlResourcesService service;
/** The service client containing this operation class. */
private final CosmosDBManagementClientImpl client;
/**
* Initializes an instance of SqlResourcesClientImpl.
*
* @param client the instance of the service client containing this operation class.
*/
SqlResourcesClientImpl(CosmosDBManagementClientImpl client) {
this.service =
RestProxy.create(SqlResourcesService.class, client.getHttpPipeline(), client.getSerializerAdapter());
this.client = client;
}
/**
* The interface defining all the services for CosmosDBManagementClientSqlResources to be used by the proxy service
* to perform REST calls.
*/
@Host("{$host}")
@ServiceInterface(name = "CosmosDBManagementCl")
private interface SqlResourcesService {
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlDatabaseListResult>> listSqlDatabases(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlDatabaseGetResultsInner>> getSqlDatabase(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> createUpdateSqlDatabase(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Delete(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteSqlDatabase(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/throughputSettings/default")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<ThroughputSettingsGetResultsInner>> getSqlDatabaseThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/throughputSettings/default")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> updateSqlDatabaseThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") ThroughputSettingsUpdateParameters updateThroughputParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/throughputSettings/default"
+ "/migrateToAutoscale")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToAutoscale(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/throughputSettings/default"
+ "/migrateToManualThroughput")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToManualThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlContainerListResult>> listSqlContainers(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlContainerGetResultsInner>> getSqlContainer(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> createUpdateSqlContainer(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Delete(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteSqlContainer(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/throughputSettings/default")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<ThroughputSettingsGetResultsInner>> getSqlContainerThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/throughputSettings/default")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> updateSqlContainerThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") ThroughputSettingsUpdateParameters updateThroughputParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/throughputSettings/default/migrateToAutoscale")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToAutoscale(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Post(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/throughputSettings/default/migrateToManualThroughput")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToManualThroughput(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/storedProcedures")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlStoredProcedureListResult>> listSqlStoredProcedures(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/storedProcedures/{storedProcedureName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlStoredProcedureGetResultsInner>> getSqlStoredProcedure(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("storedProcedureName") String storedProcedureName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/storedProcedures/{storedProcedureName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> createUpdateSqlStoredProcedure(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("storedProcedureName") String storedProcedureName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json")
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Delete(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/storedProcedures/{storedProcedureName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteSqlStoredProcedure(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("storedProcedureName") String storedProcedureName,
@QueryParam("api-version") String apiVersion,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/userDefinedFunctions")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlUserDefinedFunctionListResult>> listSqlUserDefinedFunctions(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/userDefinedFunctions/{userDefinedFunctionName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlUserDefinedFunctionGetResultsInner>> getSqlUserDefinedFunction(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("userDefinedFunctionName") String userDefinedFunctionName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/userDefinedFunctions/{userDefinedFunctionName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> createUpdateSqlUserDefinedFunction(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("userDefinedFunctionName") String userDefinedFunctionName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json")
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Delete(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}"
+ "/userDefinedFunctions/{userDefinedFunctionName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteSqlUserDefinedFunction(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("userDefinedFunctionName") String userDefinedFunctionName,
@QueryParam("api-version") String apiVersion,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}/triggers")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlTriggerListResult>> listSqlTriggers(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Get(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}/triggers"
+ "/{triggerName}")
@ExpectedResponses({200})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<SqlTriggerGetResultsInner>> getSqlTrigger(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("triggerName") String triggerName,
@QueryParam("api-version") String apiVersion,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Content-Type: application/json"})
@Put(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}/triggers"
+ "/{triggerName}")
@ExpectedResponses({200, 202})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> createUpdateSqlTrigger(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("triggerName") String triggerName,
@QueryParam("api-version") String apiVersion,
@BodyParam("application/json") SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
@HeaderParam("Accept") String accept,
Context context);
@Headers({"Accept: application/json;q=0.9", "Content-Type: application/json"})
@Delete(
"/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB"
+ "/databaseAccounts/{accountName}/sqlDatabases/{databaseName}/containers/{containerName}/triggers"
+ "/{triggerName}")
@ExpectedResponses({202, 204})
@UnexpectedResponseExceptionType(ManagementException.class)
Mono<Response<Flux<ByteBuffer>>> deleteSqlTrigger(
@HostParam("$host") String endpoint,
@PathParam("subscriptionId") String subscriptionId,
@PathParam("resourceGroupName") String resourceGroupName,
@PathParam("accountName") String accountName,
@PathParam("databaseName") String databaseName,
@PathParam("containerName") String containerName,
@PathParam("triggerName") String triggerName,
@QueryParam("api-version") String apiVersion,
Context context);
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlDatabaseGetResultsInner>> listSqlDatabasesSinglePageAsync(
String resourceGroupName, String accountName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.listSqlDatabases(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
apiVersion,
accept,
context))
.<PagedResponse<SqlDatabaseGetResultsInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlDatabaseGetResultsInner>> listSqlDatabasesSinglePageAsync(
String resourceGroupName, String accountName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.listSqlDatabases(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
apiVersion,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<SqlDatabaseGetResultsInner> listSqlDatabasesAsync(String resourceGroupName, String accountName) {
return new PagedFlux<>(() -> listSqlDatabasesSinglePageAsync(resourceGroupName, accountName));
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<SqlDatabaseGetResultsInner> listSqlDatabasesAsync(
String resourceGroupName, String accountName, Context context) {
return new PagedFlux<>(() -> listSqlDatabasesSinglePageAsync(resourceGroupName, accountName, context));
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlDatabaseGetResultsInner> listSqlDatabases(String resourceGroupName, String accountName) {
return new PagedIterable<>(listSqlDatabasesAsync(resourceGroupName, accountName));
}
/**
* Lists the SQL databases under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the SQL databases and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlDatabaseGetResultsInner> listSqlDatabases(
String resourceGroupName, String accountName, Context context) {
return new PagedIterable<>(listSqlDatabasesAsync(resourceGroupName, accountName, context));
}
/**
* Gets the SQL database under an existing Azure Cosmos DB database account with the provided name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL database under an existing Azure Cosmos DB database account with the provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<SqlDatabaseGetResultsInner>> getSqlDatabaseWithResponseAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the SQL database under an existing Azure Cosmos DB database account with the provided name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL database under an existing Azure Cosmos DB database account with the provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<SqlDatabaseGetResultsInner>> getSqlDatabaseWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context);
}
/**
* Gets the SQL database under an existing Azure Cosmos DB database account with the provided name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL database under an existing Azure Cosmos DB database account with the provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlDatabaseGetResultsInner> getSqlDatabaseAsync(
String resourceGroupName, String accountName, String databaseName) {
return getSqlDatabaseWithResponseAsync(resourceGroupName, accountName, databaseName)
.flatMap(
(Response<SqlDatabaseGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the SQL database under an existing Azure Cosmos DB database account with the provided name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL database under an existing Azure Cosmos DB database account with the provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlDatabaseGetResultsInner getSqlDatabase(
String resourceGroupName, String accountName, String databaseName) {
return getSqlDatabaseAsync(resourceGroupName, accountName, databaseName).block();
}
/**
* Gets the SQL database under an existing Azure Cosmos DB database account with the provided name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL database under an existing Azure Cosmos DB database account with the provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<SqlDatabaseGetResultsInner> getSqlDatabaseWithResponse(
String resourceGroupName, String accountName, String databaseName, Context context) {
return getSqlDatabaseWithResponseAsync(resourceGroupName, accountName, databaseName, context).block();
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> createUpdateSqlDatabaseWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (createUpdateSqlDatabaseParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlDatabaseParameters is required and cannot be null."));
} else {
createUpdateSqlDatabaseParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.createUpdateSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
createUpdateSqlDatabaseParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> createUpdateSqlDatabaseWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (createUpdateSqlDatabaseParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlDatabaseParameters is required and cannot be null."));
} else {
createUpdateSqlDatabaseParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.createUpdateSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
createUpdateSqlDatabaseParameters,
accept,
context);
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<SqlDatabaseGetResultsInner>, SqlDatabaseGetResultsInner>
beginCreateUpdateSqlDatabaseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlDatabaseWithResponseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters);
return this
.client
.<SqlDatabaseGetResultsInner, SqlDatabaseGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlDatabaseGetResultsInner.class,
SqlDatabaseGetResultsInner.class,
Context.NONE);
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<SqlDatabaseGetResultsInner>, SqlDatabaseGetResultsInner>
beginCreateUpdateSqlDatabaseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlDatabaseWithResponseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters, context);
return this
.client
.<SqlDatabaseGetResultsInner, SqlDatabaseGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlDatabaseGetResultsInner.class,
SqlDatabaseGetResultsInner.class,
context);
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlDatabaseGetResultsInner>, SqlDatabaseGetResultsInner> beginCreateUpdateSqlDatabase(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters) {
return beginCreateUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlDatabaseGetResultsInner>, SqlDatabaseGetResultsInner> beginCreateUpdateSqlDatabase(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
Context context) {
return beginCreateUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters, context)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlDatabaseGetResultsInner> createUpdateSqlDatabaseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters) {
return beginCreateUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<SqlDatabaseGetResultsInner> createUpdateSqlDatabaseAsync(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
Context context) {
return beginCreateUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlDatabaseGetResultsInner createUpdateSqlDatabase(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters) {
return createUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param createUpdateSqlDatabaseParameters Parameters to create and update Cosmos DB SQL database.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB SQL database.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlDatabaseGetResultsInner createUpdateSqlDatabase(
String resourceGroupName,
String accountName,
String databaseName,
SqlDatabaseCreateUpdateParameters createUpdateSqlDatabaseParameters,
Context context) {
return createUpdateSqlDatabaseAsync(
resourceGroupName, accountName, databaseName, createUpdateSqlDatabaseParameters, context)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteSqlDatabaseWithResponseAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
return FluxUtil
.withContext(
context ->
service
.deleteSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteSqlDatabaseWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
context = this.client.mergeContext(context);
return service
.deleteSqlDatabase(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
context);
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteSqlDatabaseAsync(
String resourceGroupName, String accountName, String databaseName) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlDatabaseWithResponseAsync(resourceGroupName, accountName, databaseName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteSqlDatabaseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlDatabaseWithResponseAsync(resourceGroupName, accountName, databaseName, context);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlDatabase(
String resourceGroupName, String accountName, String databaseName) {
return beginDeleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName).getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlDatabase(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginDeleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName, context).getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteSqlDatabaseAsync(String resourceGroupName, String accountName, String databaseName) {
return beginDeleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteSqlDatabaseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginDeleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlDatabase(String resourceGroupName, String accountName, String databaseName) {
deleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName).block();
}
/**
* Deletes an existing Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlDatabase(String resourceGroupName, String accountName, String databaseName, Context context) {
deleteSqlDatabaseAsync(resourceGroupName, accountName, databaseName, context).block();
}
/**
* Gets the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the provided
* name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the
* provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<ThroughputSettingsGetResultsInner>> getSqlDatabaseThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlDatabaseThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the provided
* name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the
* provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<ThroughputSettingsGetResultsInner>> getSqlDatabaseThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlDatabaseThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context);
}
/**
* Gets the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the provided
* name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the
* provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> getSqlDatabaseThroughputAsync(
String resourceGroupName, String accountName, String databaseName) {
return getSqlDatabaseThroughputWithResponseAsync(resourceGroupName, accountName, databaseName)
.flatMap(
(Response<ThroughputSettingsGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the provided
* name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the
* provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner getSqlDatabaseThroughput(
String resourceGroupName, String accountName, String databaseName) {
return getSqlDatabaseThroughputAsync(resourceGroupName, accountName, databaseName).block();
}
/**
* Gets the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the provided
* name.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL database under an existing Azure Cosmos DB database account with the
* provided name.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<ThroughputSettingsGetResultsInner> getSqlDatabaseThroughputWithResponse(
String resourceGroupName, String accountName, String databaseName, Context context) {
return getSqlDatabaseThroughputWithResponseAsync(resourceGroupName, accountName, databaseName, context).block();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> updateSqlDatabaseThroughputWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (updateThroughputParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter updateThroughputParameters is required and cannot be null."));
} else {
updateThroughputParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.updateSqlDatabaseThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
updateThroughputParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> updateSqlDatabaseThroughputWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (updateThroughputParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter updateThroughputParameters is required and cannot be null."));
} else {
updateThroughputParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.updateSqlDatabaseThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
updateThroughputParameters,
accept,
context);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlDatabaseThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
updateSqlDatabaseThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlDatabaseThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
updateSqlDatabaseThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlDatabaseThroughput(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return beginUpdateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters)
.getSyncPoller();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlDatabaseThroughput(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return beginUpdateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters, context)
.getSyncPoller();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> updateSqlDatabaseThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return beginUpdateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> updateSqlDatabaseThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return beginUpdateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner updateSqlDatabaseThroughput(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return updateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters)
.block();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL database.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner updateSqlDatabaseThroughput(
String resourceGroupName,
String accountName,
String databaseName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return updateSqlDatabaseThroughputAsync(
resourceGroupName, accountName, databaseName, updateThroughputParameters, context)
.block();
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToAutoscaleWithResponseAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.migrateSqlDatabaseToAutoscale(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToAutoscaleWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.migrateSqlDatabaseToAutoscale(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context);
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToAutoscaleAsync(String resourceGroupName, String accountName, String databaseName) {
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlDatabaseToAutoscaleWithResponseAsync(resourceGroupName, accountName, databaseName);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlDatabaseToAutoscaleWithResponseAsync(resourceGroupName, accountName, databaseName, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToAutoscale(String resourceGroupName, String accountName, String databaseName) {
return beginMigrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName).getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToAutoscale(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginMigrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName, context)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> migrateSqlDatabaseToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName) {
return beginMigrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> migrateSqlDatabaseToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginMigrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlDatabaseToAutoscale(
String resourceGroupName, String accountName, String databaseName) {
return migrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName).block();
}
/**
* Migrate an Azure Cosmos DB SQL database from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlDatabaseToAutoscale(
String resourceGroupName, String accountName, String databaseName, Context context) {
return migrateSqlDatabaseToAutoscaleAsync(resourceGroupName, accountName, databaseName, context).block();
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToManualThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.migrateSqlDatabaseToManualThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> migrateSqlDatabaseToManualThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.migrateSqlDatabaseToManualThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context);
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName) {
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlDatabaseToManualThroughputWithResponseAsync(resourceGroupName, accountName, databaseName);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlDatabaseToManualThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToManualThroughput(String resourceGroupName, String accountName, String databaseName) {
return beginMigrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlDatabaseToManualThroughput(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginMigrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName, context)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> migrateSqlDatabaseToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName) {
return beginMigrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> migrateSqlDatabaseToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
return beginMigrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlDatabaseToManualThroughput(
String resourceGroupName, String accountName, String databaseName) {
return migrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName).block();
}
/**
* Migrate an Azure Cosmos DB SQL database from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlDatabaseToManualThroughput(
String resourceGroupName, String accountName, String databaseName, Context context) {
return migrateSqlDatabaseToManualThroughputAsync(resourceGroupName, accountName, databaseName, context).block();
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlContainerGetResultsInner>> listSqlContainersSinglePageAsync(
String resourceGroupName, String accountName, String databaseName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.listSqlContainers(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context))
.<PagedResponse<SqlContainerGetResultsInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlContainerGetResultsInner>> listSqlContainersSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.listSqlContainers(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
apiVersion,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<SqlContainerGetResultsInner> listSqlContainersAsync(
String resourceGroupName, String accountName, String databaseName) {
return new PagedFlux<>(() -> listSqlContainersSinglePageAsync(resourceGroupName, accountName, databaseName));
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<SqlContainerGetResultsInner> listSqlContainersAsync(
String resourceGroupName, String accountName, String databaseName, Context context) {
return new PagedFlux<>(
() -> listSqlContainersSinglePageAsync(resourceGroupName, accountName, databaseName, context));
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlContainerGetResultsInner> listSqlContainers(
String resourceGroupName, String accountName, String databaseName) {
return new PagedIterable<>(listSqlContainersAsync(resourceGroupName, accountName, databaseName));
}
/**
* Lists the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the containers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlContainerGetResultsInner> listSqlContainers(
String resourceGroupName, String accountName, String databaseName, Context context) {
return new PagedIterable<>(listSqlContainersAsync(resourceGroupName, accountName, databaseName, context));
}
/**
* Gets the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<SqlContainerGetResultsInner>> getSqlContainerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<SqlContainerGetResultsInner>> getSqlContainerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context);
}
/**
* Gets the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlContainerGetResultsInner> getSqlContainerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return getSqlContainerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName)
.flatMap(
(Response<SqlContainerGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlContainerGetResultsInner getSqlContainer(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return getSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName).block();
}
/**
* Gets the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<SqlContainerGetResultsInner> getSqlContainerWithResponse(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return getSqlContainerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName, context)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> createUpdateSqlContainerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (createUpdateSqlContainerParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlContainerParameters is required and cannot be null."));
} else {
createUpdateSqlContainerParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.createUpdateSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
createUpdateSqlContainerParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> createUpdateSqlContainerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (createUpdateSqlContainerParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlContainerParameters is required and cannot be null."));
} else {
createUpdateSqlContainerParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.createUpdateSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
createUpdateSqlContainerParameters,
accept,
context);
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<SqlContainerGetResultsInner>, SqlContainerGetResultsInner>
beginCreateUpdateSqlContainerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlContainerWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, createUpdateSqlContainerParameters);
return this
.client
.<SqlContainerGetResultsInner, SqlContainerGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlContainerGetResultsInner.class,
SqlContainerGetResultsInner.class,
Context.NONE);
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<SqlContainerGetResultsInner>, SqlContainerGetResultsInner>
beginCreateUpdateSqlContainerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlContainerWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
createUpdateSqlContainerParameters,
context);
return this
.client
.<SqlContainerGetResultsInner, SqlContainerGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlContainerGetResultsInner.class,
SqlContainerGetResultsInner.class,
context);
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlContainerGetResultsInner>, SqlContainerGetResultsInner>
beginCreateUpdateSqlContainer(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters) {
return beginCreateUpdateSqlContainerAsync(
resourceGroupName, accountName, databaseName, containerName, createUpdateSqlContainerParameters)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlContainerGetResultsInner>, SqlContainerGetResultsInner>
beginCreateUpdateSqlContainer(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
Context context) {
return beginCreateUpdateSqlContainerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
createUpdateSqlContainerParameters,
context)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlContainerGetResultsInner> createUpdateSqlContainerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters) {
return beginCreateUpdateSqlContainerAsync(
resourceGroupName, accountName, databaseName, containerName, createUpdateSqlContainerParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<SqlContainerGetResultsInner> createUpdateSqlContainerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
Context context) {
return beginCreateUpdateSqlContainerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
createUpdateSqlContainerParameters,
context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlContainerGetResultsInner createUpdateSqlContainer(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters) {
return createUpdateSqlContainerAsync(
resourceGroupName, accountName, databaseName, containerName, createUpdateSqlContainerParameters)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param createUpdateSqlContainerParameters Parameters to create and update Cosmos DB container.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB container.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlContainerGetResultsInner createUpdateSqlContainer(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
SqlContainerCreateUpdateParameters createUpdateSqlContainerParameters,
Context context) {
return createUpdateSqlContainerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
createUpdateSqlContainerParameters,
context)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteSqlContainerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
return FluxUtil
.withContext(
context ->
service
.deleteSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteSqlContainerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
context = this.client.mergeContext(context);
return service
.deleteSqlContainer(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
context);
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteSqlContainerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlContainerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteSqlContainerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlContainerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName, context);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlContainer(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginDeleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlContainer(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginDeleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName, context)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteSqlContainerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginDeleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteSqlContainerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginDeleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlContainer(
String resourceGroupName, String accountName, String databaseName, String containerName) {
deleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName).block();
}
/**
* Deletes an existing Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlContainer(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
deleteSqlContainerAsync(resourceGroupName, accountName, databaseName, containerName, context).block();
}
/**
* Gets the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<ThroughputSettingsGetResultsInner>> getSqlContainerThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlContainerThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<ThroughputSettingsGetResultsInner>> getSqlContainerThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlContainerThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context);
}
/**
* Gets the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> getSqlContainerThroughputAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return getSqlContainerThroughputWithResponseAsync(resourceGroupName, accountName, databaseName, containerName)
.flatMap(
(Response<ThroughputSettingsGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner getSqlContainerThroughput(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return getSqlContainerThroughputAsync(resourceGroupName, accountName, databaseName, containerName).block();
}
/**
* Gets the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the RUs per second of the SQL container under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<ThroughputSettingsGetResultsInner> getSqlContainerThroughputWithResponse(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return getSqlContainerThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.block();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> updateSqlContainerThroughputWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (updateThroughputParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter updateThroughputParameters is required and cannot be null."));
} else {
updateThroughputParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.updateSqlContainerThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
updateThroughputParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> updateSqlContainerThroughputWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (updateThroughputParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter updateThroughputParameters is required and cannot be null."));
} else {
updateThroughputParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.updateSqlContainerThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
updateThroughputParameters,
accept,
context);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlContainerThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
updateSqlContainerThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlContainerThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
updateSqlContainerThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlContainerThroughput(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return beginUpdateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters)
.getSyncPoller();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginUpdateSqlContainerThroughput(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return beginUpdateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters, context)
.getSyncPoller();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> updateSqlContainerThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return beginUpdateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> updateSqlContainerThroughputAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return beginUpdateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner updateSqlContainerThroughput(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters) {
return updateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters)
.block();
}
/**
* Update RUs per second of an Azure Cosmos DB SQL container.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param updateThroughputParameters Parameters to update Cosmos DB resource throughput.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner updateSqlContainerThroughput(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
ThroughputSettingsUpdateParameters updateThroughputParameters,
Context context) {
return updateSqlContainerThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, updateThroughputParameters, context)
.block();
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToAutoscaleWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.migrateSqlContainerToAutoscale(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToAutoscaleWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.migrateSqlContainerToAutoscale(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context);
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlContainerToAutoscaleWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlContainerToAutoscaleWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToAutoscale(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginMigrateSqlContainerToAutoscaleAsync(resourceGroupName, accountName, databaseName, containerName)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToAutoscale(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginMigrateSqlContainerToAutoscaleAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> migrateSqlContainerToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginMigrateSqlContainerToAutoscaleAsync(resourceGroupName, accountName, databaseName, containerName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> migrateSqlContainerToAutoscaleAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginMigrateSqlContainerToAutoscaleAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlContainerToAutoscale(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return migrateSqlContainerToAutoscaleAsync(resourceGroupName, accountName, databaseName, containerName).block();
}
/**
* Migrate an Azure Cosmos DB SQL container from manual throughput to autoscale.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlContainerToAutoscale(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return migrateSqlContainerToAutoscaleAsync(resourceGroupName, accountName, databaseName, containerName, context)
.block();
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToManualThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.migrateSqlContainerToManualThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> migrateSqlContainerToManualThroughputWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.migrateSqlContainerToManualThroughput(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context);
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlContainerToManualThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
Context.NONE);
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
migrateSqlContainerToManualThroughputWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, context);
return this
.client
.<ThroughputSettingsGetResultsInner, ThroughputSettingsGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
ThroughputSettingsGetResultsInner.class,
ThroughputSettingsGetResultsInner.class,
context);
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToManualThroughput(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginMigrateSqlContainerToManualThroughputAsync(
resourceGroupName, accountName, databaseName, containerName)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<ThroughputSettingsGetResultsInner>, ThroughputSettingsGetResultsInner>
beginMigrateSqlContainerToManualThroughput(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginMigrateSqlContainerToManualThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.getSyncPoller();
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<ThroughputSettingsGetResultsInner> migrateSqlContainerToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return beginMigrateSqlContainerToManualThroughputAsync(
resourceGroupName, accountName, databaseName, containerName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<ThroughputSettingsGetResultsInner> migrateSqlContainerToManualThroughputAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return beginMigrateSqlContainerToManualThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlContainerToManualThroughput(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return migrateSqlContainerToManualThroughputAsync(resourceGroupName, accountName, databaseName, containerName)
.block();
}
/**
* Migrate an Azure Cosmos DB SQL container from autoscale to manual throughput.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB resource throughput.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public ThroughputSettingsGetResultsInner migrateSqlContainerToManualThroughput(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return migrateSqlContainerToManualThroughputAsync(
resourceGroupName, accountName, databaseName, containerName, context)
.block();
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlStoredProcedureGetResultsInner>> listSqlStoredProceduresSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.listSqlStoredProcedures(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.<PagedResponse<SqlStoredProcedureGetResultsInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlStoredProcedureGetResultsInner>> listSqlStoredProceduresSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.listSqlStoredProcedures(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<SqlStoredProcedureGetResultsInner> listSqlStoredProceduresAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedFlux<>(
() -> listSqlStoredProceduresSinglePageAsync(resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<SqlStoredProcedureGetResultsInner> listSqlStoredProceduresAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedFlux<>(
() ->
listSqlStoredProceduresSinglePageAsync(
resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlStoredProcedureGetResultsInner> listSqlStoredProcedures(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedIterable<>(
listSqlStoredProceduresAsync(resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the storedProcedures and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlStoredProcedureGetResultsInner> listSqlStoredProcedures(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedIterable<>(
listSqlStoredProceduresAsync(resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Gets the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL storedProcedure under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<SqlStoredProcedureGetResultsInner>> getSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL storedProcedure under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<SqlStoredProcedureGetResultsInner>> getSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
accept,
context);
}
/**
* Gets the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL storedProcedure under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlStoredProcedureGetResultsInner> getSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
return getSqlStoredProcedureWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName)
.flatMap(
(Response<SqlStoredProcedureGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL storedProcedure under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlStoredProcedureGetResultsInner getSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
return getSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName)
.block();
}
/**
* Gets the SQL storedProcedure under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL storedProcedure under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<SqlStoredProcedureGetResultsInner> getSqlStoredProcedureWithResponse(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
return getSqlStoredProcedureWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName, context)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> createUpdateSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
if (createUpdateSqlStoredProcedureParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlStoredProcedureParameters is required and cannot be null."));
} else {
createUpdateSqlStoredProcedureParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.createUpdateSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
createUpdateSqlStoredProcedureParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> createUpdateSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
if (createUpdateSqlStoredProcedureParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlStoredProcedureParameters is required and cannot be null."));
} else {
createUpdateSqlStoredProcedureParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.createUpdateSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
createUpdateSqlStoredProcedureParameters,
accept,
context);
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<SqlStoredProcedureGetResultsInner>, SqlStoredProcedureGetResultsInner>
beginCreateUpdateSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlStoredProcedureWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters);
return this
.client
.<SqlStoredProcedureGetResultsInner, SqlStoredProcedureGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlStoredProcedureGetResultsInner.class,
SqlStoredProcedureGetResultsInner.class,
Context.NONE);
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<SqlStoredProcedureGetResultsInner>, SqlStoredProcedureGetResultsInner>
beginCreateUpdateSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlStoredProcedureWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters,
context);
return this
.client
.<SqlStoredProcedureGetResultsInner, SqlStoredProcedureGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlStoredProcedureGetResultsInner.class,
SqlStoredProcedureGetResultsInner.class,
context);
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlStoredProcedureGetResultsInner>, SqlStoredProcedureGetResultsInner>
beginCreateUpdateSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters) {
return beginCreateUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlStoredProcedureGetResultsInner>, SqlStoredProcedureGetResultsInner>
beginCreateUpdateSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
Context context) {
return beginCreateUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters,
context)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlStoredProcedureGetResultsInner> createUpdateSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters) {
return beginCreateUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<SqlStoredProcedureGetResultsInner> createUpdateSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
Context context) {
return beginCreateUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters,
context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlStoredProcedureGetResultsInner createUpdateSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters) {
return createUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param createUpdateSqlStoredProcedureParameters Parameters to create and update Cosmos DB storedProcedure.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB storedProcedure.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlStoredProcedureGetResultsInner createUpdateSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
SqlStoredProcedureCreateUpdateParameters createUpdateSqlStoredProcedureParameters,
Context context) {
return createUpdateSqlStoredProcedureAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
createUpdateSqlStoredProcedureParameters,
context)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
return FluxUtil
.withContext(
context ->
service
.deleteSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteSqlStoredProcedureWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (storedProcedureName == null) {
return Mono
.error(new IllegalArgumentException("Parameter storedProcedureName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
context = this.client.mergeContext(context);
return service
.deleteSqlStoredProcedure(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
storedProcedureName,
apiVersion,
context);
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlStoredProcedureWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlStoredProcedureWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName, context);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
return beginDeleteSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
return beginDeleteSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName, context)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
return beginDeleteSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteSqlStoredProcedureAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
return beginDeleteSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName) {
deleteSqlStoredProcedureAsync(resourceGroupName, accountName, databaseName, containerName, storedProcedureName)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL storedProcedure.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param storedProcedureName Cosmos DB storedProcedure name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlStoredProcedure(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String storedProcedureName,
Context context) {
deleteSqlStoredProcedureAsync(
resourceGroupName, accountName, databaseName, containerName, storedProcedureName, context)
.block();
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlUserDefinedFunctionGetResultsInner>> listSqlUserDefinedFunctionsSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.listSqlUserDefinedFunctions(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.<PagedResponse<SqlUserDefinedFunctionGetResultsInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlUserDefinedFunctionGetResultsInner>> listSqlUserDefinedFunctionsSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.listSqlUserDefinedFunctions(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<SqlUserDefinedFunctionGetResultsInner> listSqlUserDefinedFunctionsAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedFlux<>(
() ->
listSqlUserDefinedFunctionsSinglePageAsync(
resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<SqlUserDefinedFunctionGetResultsInner> listSqlUserDefinedFunctionsAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedFlux<>(
() ->
listSqlUserDefinedFunctionsSinglePageAsync(
resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlUserDefinedFunctionGetResultsInner> listSqlUserDefinedFunctions(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedIterable<>(
listSqlUserDefinedFunctionsAsync(resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the userDefinedFunctions and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlUserDefinedFunctionGetResultsInner> listSqlUserDefinedFunctions(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedIterable<>(
listSqlUserDefinedFunctionsAsync(resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Gets the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<SqlUserDefinedFunctionGetResultsInner>> getSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<SqlUserDefinedFunctionGetResultsInner>> getSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
accept,
context);
}
/**
* Gets the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlUserDefinedFunctionGetResultsInner> getSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
return getSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName)
.flatMap(
(Response<SqlUserDefinedFunctionGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlUserDefinedFunctionGetResultsInner getSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
return getSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName)
.block();
}
/**
* Gets the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL userDefinedFunction under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<SqlUserDefinedFunctionGetResultsInner> getSqlUserDefinedFunctionWithResponse(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
return getSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName, context)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> createUpdateSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
if (createUpdateSqlUserDefinedFunctionParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlUserDefinedFunctionParameters is required and cannot be null."));
} else {
createUpdateSqlUserDefinedFunctionParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.createUpdateSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
createUpdateSqlUserDefinedFunctionParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> createUpdateSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
if (createUpdateSqlUserDefinedFunctionParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlUserDefinedFunctionParameters is required and cannot be null."));
} else {
createUpdateSqlUserDefinedFunctionParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.createUpdateSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
createUpdateSqlUserDefinedFunctionParameters,
accept,
context);
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<SqlUserDefinedFunctionGetResultsInner>, SqlUserDefinedFunctionGetResultsInner>
beginCreateUpdateSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters);
return this
.client
.<SqlUserDefinedFunctionGetResultsInner, SqlUserDefinedFunctionGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlUserDefinedFunctionGetResultsInner.class,
SqlUserDefinedFunctionGetResultsInner.class,
Context.NONE);
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<SqlUserDefinedFunctionGetResultsInner>, SqlUserDefinedFunctionGetResultsInner>
beginCreateUpdateSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters,
context);
return this
.client
.<SqlUserDefinedFunctionGetResultsInner, SqlUserDefinedFunctionGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlUserDefinedFunctionGetResultsInner.class,
SqlUserDefinedFunctionGetResultsInner.class,
context);
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlUserDefinedFunctionGetResultsInner>, SqlUserDefinedFunctionGetResultsInner>
beginCreateUpdateSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters) {
return beginCreateUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlUserDefinedFunctionGetResultsInner>, SqlUserDefinedFunctionGetResultsInner>
beginCreateUpdateSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
Context context) {
return beginCreateUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters,
context)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlUserDefinedFunctionGetResultsInner> createUpdateSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters) {
return beginCreateUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<SqlUserDefinedFunctionGetResultsInner> createUpdateSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
Context context) {
return beginCreateUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters,
context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlUserDefinedFunctionGetResultsInner createUpdateSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters) {
return createUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param createUpdateSqlUserDefinedFunctionParameters Parameters to create and update Cosmos DB
* userDefinedFunction.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB userDefinedFunction.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlUserDefinedFunctionGetResultsInner createUpdateSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
SqlUserDefinedFunctionCreateUpdateParameters createUpdateSqlUserDefinedFunctionParameters,
Context context) {
return createUpdateSqlUserDefinedFunctionAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
createUpdateSqlUserDefinedFunctionParameters,
context)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
return FluxUtil
.withContext(
context ->
service
.deleteSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteSqlUserDefinedFunctionWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (userDefinedFunctionName == null) {
return Mono
.error(
new IllegalArgumentException("Parameter userDefinedFunctionName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
context = this.client.mergeContext(context);
return service
.deleteSqlUserDefinedFunction(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
userDefinedFunctionName,
apiVersion,
context);
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlUserDefinedFunctionWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName, context);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
return beginDeleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
return beginDeleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName, context)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
return beginDeleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteSqlUserDefinedFunctionAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
return beginDeleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName) {
deleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL userDefinedFunction.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param userDefinedFunctionName Cosmos DB userDefinedFunction name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlUserDefinedFunction(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String userDefinedFunctionName,
Context context) {
deleteSqlUserDefinedFunctionAsync(
resourceGroupName, accountName, databaseName, containerName, userDefinedFunctionName, context)
.block();
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlTriggerGetResultsInner>> listSqlTriggersSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.listSqlTriggers(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context))
.<PagedResponse<SqlTriggerGetResultsInner>>map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<PagedResponse<SqlTriggerGetResultsInner>> listSqlTriggersSinglePageAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.listSqlTriggers(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
apiVersion,
accept,
context)
.map(
res ->
new PagedResponseBase<>(
res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null));
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedFlux<SqlTriggerGetResultsInner> listSqlTriggersAsync(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedFlux<>(
() -> listSqlTriggersSinglePageAsync(resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
private PagedFlux<SqlTriggerGetResultsInner> listSqlTriggersAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedFlux<>(
() -> listSqlTriggersSinglePageAsync(resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlTriggerGetResultsInner> listSqlTriggers(
String resourceGroupName, String accountName, String databaseName, String containerName) {
return new PagedIterable<>(listSqlTriggersAsync(resourceGroupName, accountName, databaseName, containerName));
}
/**
* Lists the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the List operation response, that contains the triggers and their properties.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable<SqlTriggerGetResultsInner> listSqlTriggers(
String resourceGroupName, String accountName, String databaseName, String containerName, Context context) {
return new PagedIterable<>(
listSqlTriggersAsync(resourceGroupName, accountName, databaseName, containerName, context));
}
/**
* Gets the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL trigger under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<SqlTriggerGetResultsInner>> getSqlTriggerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.getSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Gets the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL trigger under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<SqlTriggerGetResultsInner>> getSqlTriggerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.getSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
accept,
context);
}
/**
* Gets the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL trigger under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlTriggerGetResultsInner> getSqlTriggerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
return getSqlTriggerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName, triggerName)
.flatMap(
(Response<SqlTriggerGetResultsInner> res) -> {
if (res.getValue() != null) {
return Mono.just(res.getValue());
} else {
return Mono.empty();
}
});
}
/**
* Gets the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL trigger under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlTriggerGetResultsInner getSqlTrigger(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
return getSqlTriggerAsync(resourceGroupName, accountName, databaseName, containerName, triggerName).block();
}
/**
* Gets the SQL trigger under an existing Azure Cosmos DB database account.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the SQL trigger under an existing Azure Cosmos DB database account.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Response<SqlTriggerGetResultsInner> getSqlTriggerWithResponse(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
return getSqlTriggerWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, triggerName, context)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> createUpdateSqlTriggerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
if (createUpdateSqlTriggerParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlTriggerParameters is required and cannot be null."));
} else {
createUpdateSqlTriggerParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
return FluxUtil
.withContext(
context ->
service
.createUpdateSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
createUpdateSqlTriggerParameters,
accept,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> createUpdateSqlTriggerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
if (createUpdateSqlTriggerParameters == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter createUpdateSqlTriggerParameters is required and cannot be null."));
} else {
createUpdateSqlTriggerParameters.validate();
}
final String apiVersion = "2020-09-01";
final String accept = "application/json";
context = this.client.mergeContext(context);
return service
.createUpdateSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
createUpdateSqlTriggerParameters,
accept,
context);
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<SqlTriggerGetResultsInner>, SqlTriggerGetResultsInner>
beginCreateUpdateSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters) {
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlTriggerWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters);
return this
.client
.<SqlTriggerGetResultsInner, SqlTriggerGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlTriggerGetResultsInner.class,
SqlTriggerGetResultsInner.class,
Context.NONE);
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<SqlTriggerGetResultsInner>, SqlTriggerGetResultsInner>
beginCreateUpdateSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
createUpdateSqlTriggerWithResponseAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters,
context);
return this
.client
.<SqlTriggerGetResultsInner, SqlTriggerGetResultsInner>getLroResult(
mono,
this.client.getHttpPipeline(),
SqlTriggerGetResultsInner.class,
SqlTriggerGetResultsInner.class,
context);
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlTriggerGetResultsInner>, SqlTriggerGetResultsInner> beginCreateUpdateSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters) {
return beginCreateUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<SqlTriggerGetResultsInner>, SqlTriggerGetResultsInner> beginCreateUpdateSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
Context context) {
return beginCreateUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters,
context)
.getSyncPoller();
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<SqlTriggerGetResultsInner> createUpdateSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters) {
return beginCreateUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<SqlTriggerGetResultsInner> createUpdateSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
Context context) {
return beginCreateUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters,
context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlTriggerGetResultsInner createUpdateSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters) {
return createUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters)
.block();
}
/**
* Create or update an Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param createUpdateSqlTriggerParameters Parameters to create and update Cosmos DB trigger.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return an Azure Cosmos DB trigger.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SqlTriggerGetResultsInner createUpdateSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
SqlTriggerCreateUpdateParameters createUpdateSqlTriggerParameters,
Context context) {
return createUpdateSqlTriggerAsync(
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
createUpdateSqlTriggerParameters,
context)
.block();
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Response<Flux<ByteBuffer>>> deleteSqlTriggerWithResponseAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
return FluxUtil
.withContext(
context ->
service
.deleteSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
context))
.subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Response<Flux<ByteBuffer>>> deleteSqlTriggerWithResponseAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
if (this.client.getEndpoint() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getEndpoint() is required and cannot be null."));
}
if (this.client.getSubscriptionId() == null) {
return Mono
.error(
new IllegalArgumentException(
"Parameter this.client.getSubscriptionId() is required and cannot be null."));
}
if (resourceGroupName == null) {
return Mono
.error(new IllegalArgumentException("Parameter resourceGroupName is required and cannot be null."));
}
if (accountName == null) {
return Mono.error(new IllegalArgumentException("Parameter accountName is required and cannot be null."));
}
if (databaseName == null) {
return Mono.error(new IllegalArgumentException("Parameter databaseName is required and cannot be null."));
}
if (containerName == null) {
return Mono.error(new IllegalArgumentException("Parameter containerName is required and cannot be null."));
}
if (triggerName == null) {
return Mono.error(new IllegalArgumentException("Parameter triggerName is required and cannot be null."));
}
final String apiVersion = "2020-09-01";
context = this.client.mergeContext(context);
return service
.deleteSqlTrigger(
this.client.getEndpoint(),
this.client.getSubscriptionId(),
resourceGroupName,
accountName,
databaseName,
containerName,
triggerName,
apiVersion,
context);
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public PollerFlux<PollResult<Void>, Void> beginDeleteSqlTriggerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlTriggerWithResponseAsync(resourceGroupName, accountName, databaseName, containerName, triggerName);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, Context.NONE);
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private PollerFlux<PollResult<Void>, Void> beginDeleteSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
context = this.client.mergeContext(context);
Mono<Response<Flux<ByteBuffer>>> mono =
deleteSqlTriggerWithResponseAsync(
resourceGroupName, accountName, databaseName, containerName, triggerName, context);
return this
.client
.<Void, Void>getLroResult(mono, this.client.getHttpPipeline(), Void.class, Void.class, context);
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlTrigger(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
return beginDeleteSqlTriggerAsync(resourceGroupName, accountName, databaseName, containerName, triggerName)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public SyncPoller<PollResult<Void>, Void> beginDeleteSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
return beginDeleteSqlTriggerAsync(
resourceGroupName, accountName, databaseName, containerName, triggerName, context)
.getSyncPoller();
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono<Void> deleteSqlTriggerAsync(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
return beginDeleteSqlTriggerAsync(resourceGroupName, accountName, databaseName, containerName, triggerName)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
* @return the completion.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
private Mono<Void> deleteSqlTriggerAsync(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
return beginDeleteSqlTriggerAsync(
resourceGroupName, accountName, databaseName, containerName, triggerName, context)
.last()
.flatMap(this.client::getLroFinalResultOrError);
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlTrigger(
String resourceGroupName, String accountName, String databaseName, String containerName, String triggerName) {
deleteSqlTriggerAsync(resourceGroupName, accountName, databaseName, containerName, triggerName).block();
}
/**
* Deletes an existing Azure Cosmos DB SQL trigger.
*
* @param resourceGroupName The name of the resource group. The name is case insensitive.
* @param accountName Cosmos DB database account name.
* @param databaseName Cosmos DB database name.
* @param containerName Cosmos DB container name.
* @param triggerName Cosmos DB trigger name.
* @param context The context to associate with this operation.
* @throws IllegalArgumentException thrown if parameters fail the validation.
* @throws ManagementException thrown if the request is rejected by server.
* @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
public void deleteSqlTrigger(
String resourceGroupName,
String accountName,
String databaseName,
String containerName,
String triggerName,
Context context) {
deleteSqlTriggerAsync(resourceGroupName, accountName, databaseName, containerName, triggerName, context)
.block();
}
}