教學課程：從 Azure Cosmos DB 中的 Cassandra API 帳戶查詢資料

適用於： Cassandra

身為開發人員，您可能有使用索引鍵/值組的應用程式。 您可以使用 Azure Cosmos DB 中的 Cassandra API 帳戶來儲存和查詢索引鍵/值資料。 本教學課程顯示如何使用 Java 應用程式，從 Azure Cosmos DB 中的 Cassandra API 帳戶查詢使用者資料。 Java 應用程式會使用 Java 驅動程式並查詢使用者資料，例如使用者識別碼、使用者名稱和使用者所在城市。

本教學課程涵蓋下列工作：

• 從 Cassandra 資料表查詢資料
• 執行應用程式

如果您沒有 Azure 訂用帳戶，請在開始前建立免費帳戶 。

必要條件

• 本文為多部分教學課程的一部分。 在開始之前，請務必完成上述步驟來建立 Cassandra API 帳戶、Keyspace、資料表，並將範例資料載入到資料表。

查詢資料

若要從您的 Cassandra API 帳戶查詢資料，請使用下列步驟：

1. 開啟 src\main\java\com\azure\cosmosdb\cassandra 資料夾下的 UserRepository.java 檔案。 附加下列程式碼區塊。 此程式碼提供三種方法：

   • 查詢資料庫中的所有使用者
   • 查詢依使用者識別碼篩選的特定使用者
   • 刪除資料表

   /**
   * 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. 開啟 src\main\java\com\azure\cosmosdb\cassandra 資料夾下的 UserProfile.java 檔案。 此類別包含會呼叫您先前所定義 createKeyspace、createTable 和 insert data 方法的主要方法。 現在，附加查詢所有使用者或特定使用者的下列程式碼：

   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();
   

執行 Java 應用程式

1. 開啟命令提示字元或終端機視窗。 貼上下列程式碼區塊。

   此程式碼會將目錄 (cd) 變更為您建立專案的資料夾路徑。 然後，會執行 mvn clean install 命令來在目標資料夾內產生 cosmosdb-cassandra-examples.jar 檔案。 最後，會執行 Java 應用程式。

   cd "cassandra-demo"
   
   mvn clean install
   
   java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
   

2. 現在，在 Azure 入口網站中，開啟 [資料總管] 並確認已刪除使用者資料表。

清除資源

若不再需要，您可以刪除資源群組、Azure Cosmos DB 帳戶和所有相關資源。 請選取虛擬機器的資源群組，選取 [刪除]，然後確認要刪除的資源群組名稱，即可刪除資源。

下一步

在本教學課程中，您已了解如何從 Azure Cosmos DB 中的 Cassandra API 帳戶查詢資料。 您現在可以繼續進行下一篇文章：

將資料移轉至 Cassandra API 帳戶