Compartilhar via


Tutorial: Carregar dados de exemplo em uma tabela 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 gerenciar dados de chave/valor. Este tutorial mostra como carregar dados de usuário de exemplo para uma tabela em uma conta da API para Cassandra no Azure Cosmos DB usando um aplicativo Java. O aplicativo Java usa o driver Java e carrega 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:

  • Carregue dados em uma tabela do Cassandra.
  • Execute o aplicativo.

Pré-requisitos

Carregar dados na tabela

Para carregar dados na tabela API do Cassandra, siga estas etapas:

  1. Abra o UserRepository.java arquivo na src\main\java\com\azure\cosmosdb\cassandra pasta. Acrescente o código para inserir o user_id, user_namee user_bcity campos na tabela.

    /**
    * Insert a row into user table
    *
    * @param id   user_id
    * @param name user_name
    * @param city user_bcity
    */
    public void insertUser(PreparedStatement statement, int id, String name, String city) {
         BoundStatement boundStatement = new BoundStatement(statement);
         session.execute(boundStatement.bind(id, name, city));
    }
    
    /**
    * Create a PrepareStatement to insert a row to user table
    *
    * @return PreparedStatement
    */
    public PreparedStatement prepareInsertStatement() {
       final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
    return session.prepare(insertStatement);
    }
    
  2. Abra o UserProfile.java arquivo na src\main\java\com\azure\cosmosdb\cassandra pasta. Essa classe contém o método principal que chama os métodos createKeyspace e createTable que você definiu anteriormente. Agora, acrescente o código a seguir para inserir alguns dados de exemplo na tabela da API do Cassandra.

    //Insert rows into user table
    PreparedStatement preparedStatement = repository.prepareInsertStatement();
      repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
      repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
      repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
      repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
      repository.insertUser(preparedStatement, 5, "PeterS", "Everett");
    

Executar o aplicativo

Abra um prompt de comando ou uma janela de terminal e altere o caminho da pasta para onde você criou o projeto. Execute o mvn clean install comando para gerar o cosmosdb-cassandra-examples.jar arquivo dentro da pasta de destino e executar o aplicativo.

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

Agora você pode abrir o Data Explorer no portal do Azure para confirmar se as informações do usuário foram adicionadas à tabela.

Próxima etapa

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