Tutorial: Carregar dados de exemplo em uma tabela de API para Cassandra no Azure Cosmos DB

Artigo
06/13/2024

APLICA-SE A: Cassandra

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

Este tutorial abrange as seguintes tarefas:

Carregar dados em 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 com este documento, certifique-se de criar a API para a conta, o espaço de chave e a tabela da Cassandra.

Carregar dados para a tabela

Use as seguintes etapas para carregar dados em sua tabela API for Cassandra:

Abra o arquivo "UserRepository.java" na pasta "src\main\java\com\azure\cosmosdb\cassandra" e acrescente o código para inserir os campos user_id, user_name e user_bcity 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);
}

Abra o arquivo "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 e createTable definidos anteriormente. Agora, acrescente o código a seguir para inserir alguns dados de exemplo na tabela API for 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 a aplicação

Abra um prompt de comando ou janela de terminal e altere o caminho da pasta para onde você criou o projeto. Execute o comando "mvn clean install" para gerar o arquivo cosmosdb-cassandra-examples.jar 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, pode abrir o Data Explorer no portal do Azure para verificar se as informações de utilizador foram adicionadas à tabela.

Próximos passos

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

Consultar dados da API para a conta Cassandra

Partilhar via