Oktatóanyag: Mintaadatok betöltése a Cassandra-táblához készült API-ba az Azure Cosmos DB-ben

A KÖVETKEZŐKRE VONATKOZIK: Cassandra

Fejlesztőként előfordulhat, hogy kulcs-érték párokat használó alkalmazásokkal rendelkezik. Az Azure Cosmos DB-beli Cassandra-fiók API-jának használatával kulcs-/értékadatokat tárolhat és kezelhet. Ez az oktatóanyag bemutatja, hogyan töltheti be a minta felhasználói adatokat egy Táblába egy Azure Cosmos DB-beli Cassandra-fiók API-jában egy Java-alkalmazással. A Java-alkalmazás a Java-illesztőprogramot használja, és betölti a felhasználói adatokat, például a felhasználói azonosítót, a felhasználónevet és a felhasználó városát.

Ez az oktatóanyag a következő feladatokat mutatja be:

• Adatok betöltése Cassandra-táblába
• Az alkalmazás futtatása

Ha nem rendelkezik Azure-előfizetéssel, a kezdés előtt hozzon létre egy ingyenes fiókot .

Előfeltételek

• Ez a cikk egy többrészes oktatóanyag része. Mielőtt elkezdené ezt a dokumentumot, mindenképpen hozza létre a Cassandra-fiókhoz, a kulcstérhez és a táblához tartozó API-t.

Adatok betöltése a táblába

Az alábbi lépésekkel töltheti be az adatokat a Cassandra-táblához készült API-ba:

1. Nyissa meg a "UserRepository.java" fájlt az "src\main\java\com\azure\cosmosdb\cassandra" mappában, és fűzze hozzá a kódot a user_id, user_name és user_bcity mezők táblázatba való beszúrásához:

   /**
   * 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. Nyissa meg a "UserProfile.java" fájlt az "src\main\java\com\azure\cosmosdb\cassandra" mappában. Ez az osztály tartalmazza a fő metódust, amely meghívja a korábban definiált createKeyspace és createTable metódusokat. Most fűzze hozzá a következő kódot, hogy beszúrjon néhány mintaadatot a Cassandra api-táblájába.

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

Az alkalmazás futtatása

Nyisson meg egy parancssort vagy terminálablakot, és módosítsa a mappa elérési útját arra a helyre, ahol a projektet létrehozta. Futtassa az "mvn clean install" parancsot a cosmosdb-cassandra-examples.jar fájl létrehozásához a célmappában, és futtassa az alkalmazást.

cd "cassandra-demo"

mvn clean install

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

Ezután megnyithatja az Adatkezelőt az Azure Portalon, hogy ellenőrizze, hozzá lettek-e adva a felhasználói adatok a táblához.

Következő lépések

Ebben az oktatóanyagban megtanulta, hogyan tölthet be mintaadatokat egy Azure Cosmos DB-beli Cassandra-fiókhoz készült API-ba. Továbbléphet a következő cikkre:

Adatok lekérdezése a Cassandra-fiók API-jából