Tutoriel : Charger des exemples de données dans une API pour la table Cassandra dans Azure Cosmos DB

S’APPLIQUE À : Cassandre

En tant que développeur, vous pouvez avoir des applications qui utilisent des paires clé/valeur. Vous pouvez utiliser une API pour un compte Cassandra dans Azure Cosmos DB pour stocker et gérer des données clé/valeur. Ce tutoriel vous montre comment charger des exemples de données utilisateur dans une table d’une API pour un compte Cassandra dans Azure Cosmos DB à l’aide d’une application Java. L’application Java utilise le pilote Java et charge les données utilisateur telles que l’ID utilisateur, le nom d’utilisateur et la ville utilisateur.

Ce tutoriel décrit les tâches suivantes :

• Chargez des données dans une table Cassandra.
• Exécutez l’application.

Prérequis

• Si vous n’avez pas d’abonnement Azure, créez un compte gratuit avant de commencer.
• Cet article appartient à un didacticiel en plusieurs parties. Avant de commencer avec cet article, veillez à créer l’API pour le compte Cassandra, l’espace de clés et la table.

Charger des données dans la table

Pour charger des données dans votre API pour la table Cassandra, procédez comme suit :

1. Ouvrez le UserRepository.java fichier sous le src\main\java\com\azure\cosmosdb\cassandra dossier. Ajoutez le code pour insérer les champs user_id, user_name et user_bcity dans la table.

   /**
   * 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. Ouvrez le UserProfile.java fichier sous le src\main\java\com\azure\cosmosdb\cassandra dossier. Cette classe contient la méthode principale qui appelle les méthodes createKeyspace et createTable que vous avez définies précédemment. Ajoutez maintenant le code suivant pour insérer des exemples de données dans la table d’API pour 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");
   

Exécuter l’application

Ouvrez une invite de commandes ou une fenêtre de terminal et remplacez le chemin du dossier par l’emplacement où vous avez créé le projet. Exécutez la mvn clean install commande pour générer le cosmosdb-cassandra-examples.jar fichier dans le dossier cible et exécutez l’application.

cd "cassandra-demo"

mvn clean install

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

Vous pouvez maintenant ouvrir l’Explorateur de données dans le portail Azure pour vérifier que les informations utilisateur ont été ajoutées à la table.

Étape suivante

Dans ce tutoriel, vous avez appris à charger des exemples de données dans une API pour un compte Cassandra dans Azure Cosmos DB. Vous pouvez maintenant passer à l’article suivant :

Interroger des données à partir du compte d’API pour Cassandra