CosmosAsyncDatabase Clase
- java.
lang. Object - com.
azure. cosmos. CosmosAsyncDatabase
- com.
public class CosmosAsyncDatabase
Realizar bases de datos de lectura y eliminación, actualizar el rendimiento de la base de datos y realizar operaciones en recursos secundarios
Resumen del método
Métodos heredados de java.lang.Object
Detalles del método
createClientEncryptionKey
public Mono
Crea una clave de cifrado de cliente después de la suscripción que se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de recurso con la clave de cifrado de cliente creada. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor de Cosmos.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor de Cosmos.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor de Cosmos con propiedades de rendimiento personalizadas.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.createContainer(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainer(
containerProperties,
throughput,
options
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor de Cosmos.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainer
public Mono
Crea un contenedor de Cosmos.
ThroughputProperties throughputProperties =
ThroughputProperties.createAutoscaledThroughput(autoscaledThroughput);
cosmosAsyncDatabase.createContainer(
containerId,
partitionKeyPath,
throughputProperties
)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Crea un contenedor de Cosmos si no existe en el servicio.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado o existente. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Crea un contenedor de Cosmos si no existe en el servicio.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Las propiedades de rendimiento solo se usarán si el contenedor especificado no existe y se creará un nuevo contenedor.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado o existente. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Crea un contenedor de Cosmos si no existe en el servicio.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createContainerIfNotExists
public Mono
Crea un contenedor de Cosmos si no existe en el servicio.
CosmosContainerProperties containerProperties =
new CosmosContainerProperties(containerId, partitionKeyDefinition);
cosmosAsyncDatabase.createContainerIfNotExists(containerProperties, throughputProperties)
.subscribe(
cosmosContainerResponse -> System.out.println(cosmosContainerResponse),
throwable -> System.out.println("Failed to create container: " + throwable)
);
Las propiedades de rendimiento solo se usarán si el contenedor especificado no existe y se creará un nuevo contenedor.
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de contenedor de Cosmos con el contenedor creado. En caso de error, se producirá un Mono error.
Parameters:
Returns:
createUser
public Mono
Crea un usuario Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de recurso con el usuario creado. En caso de error, se producirá un Mono error.
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.createUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to create user: " + throwable)
);
Parameters:
Returns:
delete
public Mono
Elimina la base de datos de Cosmos actual.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de base de datos cosmos con la base de datos eliminada. En caso de error, se producirá un Mono error.
Returns:
delete
public Mono
Elimina la base de datos de Cosmos actual al especificar opciones de solicitud adicionales.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.delete().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de base de datos cosmos con la base de datos eliminada. En caso de error, se producirá un Mono error.
Parameters:
Returns:
getClientEncryptionKey
public CosmosAsyncClientEncryptionKey getClientEncryptionKey(String id)
Obtiene un objeto CosmosAsyncClientEncryptionKey sin realizar una llamada de servicio.
Parameters:
Returns:
getContainer
public CosmosAsyncContainer getContainer(String id)
Obtiene un objeto CosmosAsyncContainer sin realizar una llamada de servicio.
Parameters:
Returns:
getId
public String getId()
Obtenga el identificador de CosmosAsyncDatabase.
Returns:
getUser
public CosmosAsyncUser getUser(String id)
Obtiene el usuario.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consulta de claves de cifrado de cliente cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de las claves de cifrado de cliente obtenidas. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consulta de claves de cifrado de cliente cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de las claves de cifrado de cliente obtenidas. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consulta de claves de cifrado de cliente cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de las claves de cifrado de cliente obtenidas. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryClientEncryptionKeys
public CosmosPagedFlux
Consulta de claves de cifrado de cliente cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de las claves de cifrado de cliente obtenidas. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consulta de contenedores de Cosmos en una base de datos de Cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consulta de contenedores de Cosmos en una base de datos de Cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consulta de contenedores de Cosmos en una base de datos de Cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryContainers
public CosmosPagedFlux
Consulta de contenedores de Cosmos en una base de datos de Cosmos.
cosmosAsyncDatabase.queryContainers("SELECT * FROM DB_NAME")
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consulta de usuarios de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los usuarios obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consulta de usuarios de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los usuarios obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consulta de usuarios de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los usuarios obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
queryUsers
public CosmosPagedFlux
Consulta de usuarios de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los usuarios obtenidos. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
read
public Mono
Lee una base de datos. Capture los detalles y las propiedades de una base de datos en función de su identificador único.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Una Mono vez finalizada correctamente, contendrá una única respuesta de la base de datos cosmos con la base de datos de lectura. En caso de error, se producirá un Mono error.
Returns:
read
public Mono
Lee una base de datos. Capture los detalles y las propiedades de una base de datos en función de su identificador único.
CosmosAsyncDatabase database = cosmosAsyncClient
.getDatabase("<YOUR DATABASE NAME>");
database.read().subscribe(databaseResponse -> {
System.out.println(databaseResponse);
},
throwable -> {
throwable.printStackTrace();
});
Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una respuesta de base de datos cosmos con la base de datos de lectura. En caso de error, se producirá un Mono error.
Parameters:
Returns:
readAllClientEncryptionKeys
public CosmosPagedFlux
Lee todas las claves de cifrado de cliente de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> contendrá una o varias respuestas de fuente de las claves de cifrado de cliente de Cosmos de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Returns:
readAllClientEncryptionKeys
public CosmosPagedFlux
Lee todas las claves de cifrado de cliente de Cosmos en una base de datos.
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> contendrá una o varias respuestas de fuente de las claves de cifrado de cliente de Cosmos de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
readAllContainers
public CosmosPagedFlux
Lee todos los contenedores de Cosmos.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Returns:
readAllContainers
public CosmosPagedFlux
Lee todos los contenedores de Cosmos.
cosmosAsyncDatabase.readAllContainers()
.byPage()
.flatMap(containerPropertiesFeedResponse -> {
for (CosmosContainerProperties properties : containerPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> Contendrá una o varias respuestas de fuente de los contenedores de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Parameters:
Returns:
readAllUsers
public CosmosPagedFlux
Lee todos los usuarios de Cosmos de una base de datos.
cosmosAsyncDatabase.readAllUsers()
.byPage()
.flatMap(userPropertiesFeedResponse -> {
for (CosmosUserProperties properties : userPropertiesFeedResponse.getResults()) {
System.out.println(properties);
}
return Flux.empty();
})
.subscribe();
Después de la suscripción, se realizará la operación. CosmosPagedFlux<T> contendrá una o varias respuestas de fuente de los usuarios de Cosmos de lectura. En caso de error, se producirá un CosmosPagedFlux<T> error.
Returns:
readThroughput
public Mono
Obtiene el rendimiento de la base de datos.
cosmosAsyncDatabase.readThroughput()
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Returns:
replaceThroughput
public Mono
Establece el rendimiento aprovisionado para un contenedor en la medida de solicitudes por unidad en el servicio Azure Cosmos.
ThroughputProperties autoscaledThroughput = ThroughputProperties
.createAutoscaledThroughput(autoScaleMaxThroughput);
cosmosAsyncDatabase.replaceThroughput(autoscaledThroughput)
.subscribe(throughputResponse -> {
System.out.println(throughputResponse);
},
throwable -> {
throwable.printStackTrace();
});
Parameters:
Returns:
upsertUser
public Mono
Upsert a un usuario. Upsert creará un nuevo usuario si no existe o reemplazará el existente si lo hace. Después de la suscripción, se realizará la operación. Cuando Mono se complete correctamente, contendrá una única respuesta de recurso con el usuario creado. En caso de error, se producirá un Mono error.
String userId = "userId";
CosmosUserProperties userProperties = new CosmosUserProperties();
userProperties.setId(userId);
cosmosAsyncDatabase.upsertUser(userProperties)
.subscribe(
userResponse -> System.out.println(userResponse),
throwable -> System.out.println("Failed to upsert user: " + throwable)
);
Parameters:
Returns:
Se aplica a
Azure SDK for Java
Comentarios
Próximamente: A lo largo de 2024 iremos eliminando gradualmente GitHub Issues como mecanismo de comentarios sobre el contenido y lo sustituiremos por un nuevo sistema de comentarios. Para más información, vea: https://aka.ms/ContentUserFeedback.
Enviar y ver comentarios de