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

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.

Požadavky

• Pokud nemáte předplatné Azure, vytvořte si bezplatný účet před zahájením.
• Tento článek patří do kurzu s více částmi. Než začnete, nezapomeňte dokončit předchozí kroky a vytvořit rozhraní API pro účet Cassandra, prostor klíčů a tabulku. Také načtěte ukázková data do tabulky.

Zadávání dotazů na data

Pokud chcete dotazovat data z účtu API pro Cassandra, postupujte takto:

1. 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 poskytuje tři metody pro:

   • Zadejte dotaz na všechny uživatele v databázi.
   • Zadejte dotaz na konkrétního uživatele filtrovaného podle ID uživatele.
   • Odstraní tabulku.

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

2. 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 vkládá datové metody, které jste definovali dříve. Připojte následující kód, který se dotazuje na všechny uživatele nebo 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ě

1. 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
   

2. Teď na webu Azure Portal otevřete Průzkumníka dat a potvrďte, že je tabulka uživatelů odstraněná.

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

Pokud už prostředky 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ší krok

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:

Migrovat data do rozhraní API pro účet Cassandra