Zelfstudie: Voorbeeldgegevens laden in een API voor Cassandra-tabel in Azure Cosmos DB

VAN TOEPASSING OP: Cassandra

Als ontwikkelaar hebt u mogelijk toepassingen die gebruikmaken van sleutel-/waardeparen. U kunt API voor Cassandra-account in Azure Cosmos DB gebruiken om sleutel-/waardegegevens op te slaan en te beheren. Deze zelfstudie laat zien hoe u voorbeeldgegevens van gebruikers laadt naar een tabel in een API voor Cassandra-account in Azure Cosmos DB met behulp van een Java-toepassing. De Java-toepassing maakt gebruik van het Java-stuurprogramma en laadt gebruikersgegevens zoals gebruikers-id, gebruikersnaam, en woonplaats van de gebruiker.

Deze zelfstudie bestaat uit de volgende taken:

• Gegevens laden in een Cassandra-tabel
• De app uitvoeren

Als u nog geen abonnement op Azure hebt, maakt u een gratis account aan voordat u begint.

Vereisten

• Dit artikel maakt deel uit van een meerdelige zelfstudie. Voordat u met dit document begint, moet u de API voor het Cassandra-account, de keyspace en de tabel maken.

Gegevens laden in de tabel

Gebruik de volgende stappen om gegevens te laden in uw API voor Cassandra-tabel:

1. Open het bestand UserRepository.java in de map src\main\java\com\azure\cosmosdb\cassandra en voeg de code toe om de velden user_id, user_name en user_bcity in de tabel in te voegen:

   /**
   * 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. Open het bestand UserProfile.java in de map src\main\java\com\azure\cosmosdb\cassandra. Deze klasse bevat de belangrijkste methode waarmee de methoden createKeyspace en createTable die u eerder hebt gedefinieerd, worden aangeroepen. Voeg nu de volgende code toe om enkele voorbeeldgegevens in te voegen in de API voor Cassandra-tabel.

   //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");
   

De app uitvoeren

Open een opdrachtprompt of terminalvenster en wijzig het mappad in het pad waar u het project hebt gemaakt. Voer de opdracht mvn clean install uit om het bestand cosmosdb-cassandra-examples.jar in de doelmap te genereren, en voer de toepassing uit.

cd "cassandra-demo"

mvn clean install

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

U kunt nu Data Explorer openen in de Azure-portal openen om te bevestigen dat de gegevens van de gebruiker aan de tabel worden toegevoegd.

Volgende stappen

In deze zelfstudie hebt u geleerd hoe u voorbeeldgegevens laadt naar een API voor een Cassandra-account in Azure Cosmos DB. U kunt nu verdergaan met het volgende artikel:

Query's uitvoeren op gegevens uit de API voor Cassandra-account