Tutorial: Consultar dados de uma API para conta Cassandra no Azure Cosmos DB

Artigo
08/15/2024

APLICA-SE A: Cassandra

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

Este tutorial abrange as seguintes tarefas:

Consultar dados de uma tabela Cassandra
Executar a aplicação

Se não tiver uma subscrição 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 API para a conta Cassandra, o espaço de chave, a tabela e carregar dados de exemplo na tabela.

Consultar os dados

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

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

Para consultar todos os utilizadores na base de dados
Para consultar um utilizador específico, filtrado por ID de utilizador
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 ficheiro UserProfile.java na pasta src\main\java\com\azure\cosmosdb\cassandra. Esta classe contém o método principal que chama os métodos createKeyspace, createTable e inserir dados definidos anteriormente. Agora, anexe o código seguinte, que consulta todos os utilizadores ou um utilizador 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 a aplicação Java

Abra uma linha de comandos ou 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, executa o comando mvn clean install para gerar o ficheiro cosmosdb-cassandra-examples.jar na pasta de destino. Por fim, executa a aplicação 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 verifique se a tabela de utilizador foi eliminada.

Clean up resources (Limpar recursos)

Quando eles não forem mais necessários, você poderá excluir o grupo de recursos, a conta do Azure Cosmos DB e todos os recursos relacionados. Para fazer isso, selecione o grupo de recursos para a máquina virtual, selecione Excluir e confirme o nome do grupo de recursos a ser excluído.

Próximos passos

Neste tutorial, você aprendeu como consultar dados de uma API para a conta Cassandra no Azure Cosmos DB. Pode agora avançar para o artigo seguinte:

Migrar dados para a API da conta Cassandra

Partilhar via