Tutorial: consultar dados de uma conta da API do Azure Cosmos DB para Cassandra

Artigo
06/01/2023

APLICA-SE A: Cassandra

Como desenvolvedor, é possível ter aplicativos que usam os pares de chave/valor. Você pode usar uma conta da API do Azure Cosmos DB para Cassandra para armazenar e consultar dados de chave/valor. Este tutorial mostra como consultar dados de usuário de uma conta da API do Azure Cosmos DB para Cassandra usando um aplicativo Java. O aplicativo Java usa o driver Java e consulta dados do usuário, como ID, nome e cidade do usuário.

Este tutorial cobre as seguintes tarefas:

Consultar dados de uma tabela do Cassandra
Executar o aplicativo

Se você não tiver uma assinatura do Azure, crie uma conta gratuita antes de começar.

Pré-requisitos

Este artigo pertence a um tutorial com várias partes. Antes de começar, certifique-se de concluir as etapas anteriores para criar a conta da API para Cassandra, keyspace, tabela e carregar dados de exemplo na tabela.

Consultar dados

Use as seguintes etapas para consultar dados de sua conta de API para Cassandra:

Abra o arquivo UserRepository.java na pasta src\main\java\com\azure\cosmosdb\cassandra. Acrescente o seguinte bloco de código. Esse código fornece três métodos:

Para consultar todos os usuários no banco de dados
Para consultar um usuário específico, filtrado por ID de usuário
Para excluir uma tabela

/**
* 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 o arquivo UserProfile.java na pasta src\main\java\com\azure\cosmosdb\cassandra. Essa classe contém o método principal que chama createKeyspace e createTable. Insira os métodos de dados definidos anteriormente. Agora, acrescente o seguinte código que consulta todos os usuários ou um usuário 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();
```

Executar o aplicativo Java

Abra um prompt de comando ou uma janela de terminal. Cole o seguinte bloco de código.

Esse código altera o diretório (cd) para o caminho da pasta onde você criou o projeto. Em seguida, ele executa o comando mvn clean install para gerar o arquivo cosmosdb-cassandra-examples.jar dentro da pasta de destino. Por fim, ele executa o aplicativo Java.
```
cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
```
Agora, no portal do Azure, abra o Data Explorer e confirme se a tabela de usuário foi excluída.

Limpar os recursos

Quando já não forem necessários, você pode excluir o grupo de recursos, a conta do Azure Cosmos DB e todos os recursos relacionados. Para fazer isso, escolha o grupo de recursos da máquina virtual, escolha Excluir e, em seguida, confirme o nome do grupo de recursos que será excluído.

Próximas etapas

Neste tutorial, você aprendeu a consultar dados de uma conta da API do Azure Cosmos DB para Cassandra. Prossiga agora para o próximo artigo:

Migrar seus dados para uma conta de API para Cassandra

Share via