Oktatóanyag: Adatok lekérdezése egy Api-ból Cassandra-fiókból 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-ben a Cassandra-fiók api-jának használatával tárolhatja és lekérdezheti a kulcs-/értékadatokat. Ez az oktatóanyag bemutatja, hogyan kérdezhet le felhasználói adatokat egy Azure Cosmos DB-fiókhoz készült API-ból Java-alkalmazással. A Java-alkalmazás a Java-illesztőprogramot használja, és lekérdezi 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 lekérdezése Cassandra-táblából
- Az alkalmazás futtatása
Ha nem rendelkezik Azure-előfizetéssel, mindössze néhány perc alatt létrehozhat egy ingyenes fiókot a virtuális gép létrehozásának megkezdése előtt.
Előfeltételek
- Ez a cikk egy többrészes oktatóanyag része. Mielőtt hozzákezd, végezze el az előző lépéseket a Cassandra-fiókhoz, a kulcstérhez, a táblához és a mintaadatok táblázatba való betöltéséhez.
Adatok lekérdezése
A Cassandra-fiók API-jából az alábbi lépésekkel kérdezhet le adatokat:
Nyissa meg az
src\main\java\com\azure\cosmosdb\cassandra
mappában lévőUserRepository.java
fájlt. Fűzze hozzá a fájlhoz a következő kódblokkot. Ez a kód a következő három metódust biztosítja:- Az adatbázis összes felhasználójának lekérdezése
- Felhasználói azonosító alapján szűrt konkrét felhasználó lekérdezése
- Tábla törlése
/** * Select all rows from user table */ public void selectAllUsers() { final String query = "SELECT * FROM uprofile.user"; List<Row> rows = session.execute(query).all(); for (Row row : rows) { LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity")); } } /** * Select a row from user table * * @param id user_id */ public void selectUser(int id) { final String query = "SELECT * FROM uprofile.user where user_id = 3"; Row row = session.execute(query).one(); LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity")); } /** * Delete user table. */ public void deleteTable() { final String query = "DROP TABLE IF EXISTS uprofile.user"; session.execute(query); }
Nyissa meg az
src\main\java\com\azure\cosmosdb\cassandra
mappában lévőUserProfile.java
fájlt. Ez az osztály tartalmazza a createKeyspace és a createTable parancsokat meghívó fő metódust. Szúrja be a korábban meghatározott adatmetódusokat. Most fűzze hozzá a következő kódot, amely lekérdezi az összes felhasználót vagy egy adott felhasználót:LOGGER.info("Select all users"); repository.selectAllUsers(); LOGGER.info("Select a user by id (3)"); repository.selectUser(3); LOGGER.info("Delete the users profile table"); repository.deleteTable();
A Java-alkalmazás futtatása
Nyisson meg egy parancssort vagy terminálablakot. Illessze be az alábbi kódblokkot.
Ez a kód a könyvtárat (cd) arra a mappaútvonalra módosítja, ahol a projektet létrehozta. Ezután futtatja az
mvn clean install
parancsot acosmosdb-cassandra-examples.jar
fájl célmappán belüli létrehozásához. Végül futtatja a Java-alkalmazást.cd "cassandra-demo" mvn clean install java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
Nyissa meg az Azure Portalon az Adatkezelőt, és ellenőrizze, hogy a felhasználói tábla törlődött-e.
Az erőforrások eltávolítása
Ha már nincs rájuk szükség, törölheti az erőforráscsoportot, az Azure Cosmos DB-fiókot és az összes kapcsolódó erőforrást. Ehhez válassza ki a virtuális gép erőforráscsoportját, válassza a Törlés lehetőséget, majd erősítse meg a törölni kívánt erőforráscsoport nevét.
Következő lépések
Ebben az oktatóanyagban megtanulta, hogyan kérdezhet le adatokat egy Api for Cassandra-fiókból az Azure Cosmos DB-ben. Továbbléphet a következő cikkre: