Kurz: Dotazování dat z rozhraní API pro účet Cassandra ve službě Azure Cosmos DB

Článek
06/01/2023

PLATÍ PRO: Cassandra

Jako vývojáři můžete mít aplikace, které používají páry klíč/hodnota. K ukládání a dotazování dat klíč/hodnota můžete použít rozhraní API pro účet Cassandra ve službě Azure Cosmos DB. Tento kurz ukazuje, jak dotazovat uživatelská data z rozhraní API pro účet Cassandra ve službě Azure Cosmos DB pomocí aplikace v Javě. Aplikace Java používá ovladač Java a dotazuje se na uživatelská data, jako je ID uživatele, uživatelské jméno a město uživatele.

Tento kurz se zabývá následujícími úkony:

Dotazování dat z tabulky Cassandra
Spuštění aplikace

Pokud nemáte předplatné Azure, vytvořte si před zahájením bezplatného účtu .

Požadavky

Tento článek patří do vícedílného kurzu. Než začnete, nezapomeňte dokončit předchozí kroky k vytvoření rozhraní API pro účet Cassandra, prostor klíčů, tabulku a načtení ukázkových dat do tabulky.

Dotazování dat

K dotazování dat z vašeho rozhraní API pro účet Cassandra použijte následující postup:

Otevřete soubor UserRepository.java ve složce src\main\java\com\azure\cosmosdb\cassandra. Připojte následující blok kódu. Tento kód obsahuje tři metody:

Dotazování všech uživatelů v databázi
Dotazování konkrétního uživatele vyfiltrovaného podle ID uživatele
Odstranění tabulky

/**
* 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);
}

Otevřete soubor UserProfile.java ve složce src\main\java\com\azure\cosmosdb\cassandra. Tato třída obsahuje hlavní metodu, která volá createKeyspace a createTable, tj. metody vložení dat, které jste definovali dříve. Teď přidejte následující kód, který se dotazuje na všechny uživatele nebo na konkrétního uživatele:
```
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();
```

Spuštění aplikace v Javě

Otevřete příkazový řádek nebo okno terminálu. Vložte následující blok kódu.

Tento kód změní adresář (cd) na cestu ke složce, ve které jste projekt vytvořili. Pak spustí příkaz mvn clean install, který v cílové složce vygeneruje soubor cosmosdb-cassandra-examples.jar. A nakonec spustí aplikaci v Javě.
```
cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
```
Teď na webu Azure Portal otevřete Průzkumníka dat a potvrďte, že uživatelská tabulka je odstraněná.

Vyčištění prostředků

Pokud už je nepotřebujete, můžete odstranit skupinu prostředků, účet služby Azure Cosmos DB a všechny související prostředky. Uděláte to tak, že vyberete skupinu prostředků virtuálního počítače, vyberete Odstranit a pak potvrďte název skupiny prostředků, kterou chcete odstranit.

Další kroky

V tomto kurzu jste se naučili dotazovat data z účtu rozhraní API pro Cassandra ve službě Azure Cosmos DB. Teď můžete přejít k dalšímu článku:

Migrace dat do rozhraní API pro účet Cassandra