共用方式為

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

適用於： 卡珊德拉

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

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

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

必要條件

  • 如尚未擁有 Azure 訂用帳戶，請在開始之前先建立免費帳戶。
  • 本教學文章屬於多部分教程。 開始之前，請務必完成先前的步驟，以建立 Cassandra 帳戶、keyspace 和數據表的 API。 同時 將範例數據載入數據表。

查詢資料

若要從 API 查詢 Cassandra 帳戶的數據，請遵循下列步驟：

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

    • 查詢資料庫中的所有使用者。
    • 查詢依使用者識別碼篩選的特定使用者。
    • 刪除資料表。
    /**
* 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. 開啟 UserProfile.java 資料夾下的 src\main\java\com\azure\cosmosdb\cassandra 檔案。 這個類別包含呼叫createKeyspace和createTable您稍早定義之插入資料方法的主要方法。 附加下列程式代碼，以查詢所有使用者或特定使用者：

    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

  • Last updated on