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

Článek
06/13/2024

PLATÍ PRO: Cassandra

Jako vývojář můžete mít aplikace, které používají páry klíč/hodnota. K ukládání a dotazování dat klíče a hodnoty můžete použít rozhraní API pro účet Cassandra ve službě Azure Cosmos DB. V tomto kurzu se dozvíte, jak dotazovat uživatelská data z účtu API pro Cassandra ve službě Azure Cosmos DB pomocí aplikace v Javě. Aplikace v Javě používá ovladač Javy 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
Spustit aplikaci

Pokud ještě nemáte předplatné Azure, vytvořte si bezplatný účet před tím, než začnete.

Požadavky

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

Zadávání dotazů na data

K dotazování dat z vašeho účtu API pro 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, kam 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ů pro virtuální počítač, vyberete Odstranit a pak potvrdíte název skupiny prostředků, která se má odstranit.

Další kroky

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

Migrace dat do účtu Cassandra do rozhraní API

Sdílet prostřednictvím