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

APLICA-SE A: Cassandra

Como desenvolvedor, é possível ter aplicativos que usam os pares de chave/valor. Você pode usar uma conta da API para 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 conta da API para Cassandra no Azure Cosmos DB usando um aplicativo Java. O aplicativo Java usa o driver Java e consulta dados do usuário, como a ID do usuário, o nome de usuário e a cidade do usuário.

Este tutorial cobre as seguintes tarefas:

Pré-requisitos

• Se você não tiver uma assinatura do Azure, crie uma conta gratuita antes de começar.
• Este artigo pertence a um tutorial de várias partes. Antes de começar, conclua as etapas anteriores para criar a conta, o keyspace e a tabela da API do Cassandra. Carregue também dados de exemplo na tabela.

Consultar dados

Para consultar dados da sua conta da API para Cassandra, siga estas etapas:

1. 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.
   • Consulte um usuário específico filtrado pela ID do usuário.
   • 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);
   }
   

2. Abra o arquivo UserProfile.java na pasta src\main\java\com\azure\cosmosdb\cassandra. Essa classe contém o método principal que chama os métodos de inserção de dados createKeyspace e createTable que você definiu anteriormente. 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

1. 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
   

2. Agora, no portal do Azure, abra o Data Explorer e confirme se a tabela de usuário está excluída.

Limpar os recursos

Quando os recursos 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, 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óxima etapa

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