Tutorial: Consulta de datos de una cuenta de API para Cassandra en Azure Cosmos DB

Artículo
06/01/2023

SE APLICA A: Cassandra

Como desarrollador, puede que tenga aplicaciones que usan pares clave/valor. Puede usar una cuenta de la API para Cassandra en Azure Cosmos DB para almacenar y consultar los datos de esos pares clave/valor. En este tutorial se explica cómo consultar datos de usuario de una cuenta de API para Cassandra en Azure Cosmos DB mediante una aplicación Java. La aplicación Java emplea el controlador de Java y consulta datos de usuario, como el identificador, el nombre o la ciudad de este.

En este tutorial se describen las tareas siguientes:

Consulta de datos de una tabla de Cassandra
Ejecución la aplicación

Si no tiene una suscripción a Azure, cree una cuenta gratuita antes de empezar.

Requisitos previos

Este artículo pertenece a un tutorial de varias partes. Antes de empezar, asegúrese de completar los pasos anteriores para crear la cuenta de API para Cassandra, el espacio de claves, la tabla y cargar datos de ejemplo en la tabla.

Consultar datos

Use los pasos siguientes para consultar los datos de su cuenta de API para Cassandra:

Abra el archivo UserRepository.java en la carpeta src\main\java\com\azure\cosmosdb\cassandra. Anexe el bloque de código siguiente. Este código proporciona tres métodos:

Para consultar todos los usuarios de la base de datos
Para consultar un usuario específico, filtrado por identificador de usuario
Para eliminar una tabla

/**
* Select all rows from user table
*/
public void selectAllUsers() {

  final String query = "SELECT * FROM uprofile.user";
  List<Row> rows = session.execute(query).all();

  for (Row row : rows) {
     LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity"));
  }
}

/**
* Select a row from user table
*
* @param id user_id
*/
public void selectUser(int id) {
   final String query = "SELECT * FROM uprofile.user where user_id = 3";
   Row row = session.execute(query).one();

   LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity"));
}

/**
* Delete user table.
*/
public void deleteTable() {
  final String query = "DROP TABLE IF EXISTS uprofile.user";
  session.execute(query);
}

Abra el archivo UserProfile.java en la carpeta src\main\java\com\azure\cosmosdb\cassandra. Esta clase contiene el método principal que llama a los métodos de inserción de datos createKeyspace y createTable definidos anteriormente. Ahora, anexe el código siguiente que consulta todos los usuarios o un usuario específico:
```
LOGGER.info("Select all users");
repository.selectAllUsers();

LOGGER.info("Select a user by id (3)");
repository.selectUser(3);

LOGGER.info("Delete the users profile table");
repository.deleteTable();
```

Ejecución de la aplicación Java

Abra un símbolo del sistema o una ventana de terminal. Pegue el bloque de código siguiente.

Este código cambia el directorio (cd) a la ruta de acceso de la carpeta donde creó el proyecto. A continuación, se ejecuta el comando mvn clean install para generar el archivo cosmosdb-cassandra-examples.jar en la carpeta de destino. Finalmente, se ejecuta la aplicación de Java.
```
cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
```
Ahora, en Azure Portal, abra el Explorador de datos y confirme que se ha eliminado la tabla de usuario.

Limpieza de recursos

Cuando ya no los necesite, puede eliminar el grupo de recursos, la cuenta de Azure Cosmos DB y todos los recursos relacionados. Para ello, seleccione el grupo de recursos de la máquina virtual, seleccione Eliminar y luego confirme el nombre del grupo de recursos que va a eliminar.

Pasos siguientes

En este tutorial ha aprendido a consultar datos de una cuenta de API para Cassandra en Azure Cosmos DB. Avance al siguiente artículo:

Migración de datos a la cuenta de API para Cassandra