Tutorial: Mengkueri data dari API untuk akun Cassandra di Azure Cosmos DB

Artikel
08/15/2024

BERLAKU UNTUK: Cassandra

Sebagai developer, Anda mungkin memiliki aplikasi yang menggunakan pasangan kunci/nilai. Anda dapat menggunakan API untuk akun Cassandra di Azure Cosmos DB untuk menyimpan dan mengkueri data kunci/nilai. Tutorial ini menunjukkan cara mengkueri data pengguna dari API untuk akun Cassandra di Azure Cosmos DB dengan menggunakan aplikasi Java. Aplikasi Java menggunakan Java driver dan mengkueri data pengguna seperti ID pengguna, nama pengguna, dan kota pengguna.

Tutorial ini mencakup tugas-tugas berikut:

Mengkueri data dari tabel Cassandra
Menjalankan aplikasi

Jika Anda tidak memiliki langganan Azure, buat akun gratis sebelum memulai.

Prasyarat

Artikel ini termasuk dalam tutorial yang berisi beberapa bagian. Sebelum memulai, pastikan untuk menyelesaikan langkah-langkah sebelumnya untuk membuat API untuk akun Cassandra, keyspace, tabel, dan memuat data sampel ke dalam tabel.

Mengkueri data

Gunakan langkah-langkah berikut untuk mengkueri data dari API Anda untuk akun Cassandra:

Buka file UserRepository.java di bawah folder src\main\java\com\azure\cosmosdb\cassandra. Tambahkan blok kode berikut. Kode ini menyediakan tiga metode:

Untuk mengkueri semua pengguna dalam database
Untuk mengkueri pengguna tertentu yang difilter menurut ID pengguna
Untuk menghapus tabel

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

Buka file UserProfile.java di bawah folder src\main\java\com\azure\cosmosdb\cassandra. Kelas ini berisi metode utama yang memanggil createKeyspace dan createTable, menyisipkan metode data yang Anda tentukan sebelumnya. Sekarang tambahkan kode berikut yang meminta semua pengguna atau pengguna tertentu:
```
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();
```

Menjalankan aplikasi Java

Buka prompt perintah atau jendela terminal. Tempelkan blok kode berikut.

Kode ini mengubah direktori (cd) ke jalur folder tempat Anda membuat proyek. Kemudian, kode menjalankan perintah mvn clean install untuk membuat file cosmosdb-cassandra-examples.jar dalam folder target. Akhirnya, kode menjalankan aplikasi Java.
```
cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
```
Sekarang, di portal Azure, buka Data Explorer dan konfirmasi bahwa tabel pengguna dihapus.

Membersihkan sumber daya

Saat tidak lagi diperlukan, Anda dapat menghapus grup sumber daya, akun Azure Cosmos DB, dan semua sumber daya terkait. Untuk melakukannya, pilih grup sumber daya untuk komputer virtual, pilih Hapus, lalu konfirmasi nama grup sumber daya yang akan dihapus.

Langkah berikutnya

Dalam tutorial ini, Anda telah mempelajari cara mengkueri data dari API untuk akun Cassandra di Azure Cosmos DB. Sekarang Anda dapat melanjutkan ke artikel berikutnya:

Memigrasikan data ke API untuk akun Cassandra

Bagikan melalui