Tutorial: Memuat data sampel ke dalam API untuk tabel Cassandra di Azure Cosmos DB

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 mengelola data kunci/nilai. Tutorial ini menunjukkan cara memuat data pengguna sampel ke tabel di API untuk akun Cassandra di Azure Cosmos DB dengan menggunakan aplikasi Java. Aplikasi Java menggunakan Java driver dan memuat data pengguna seperti ID pengguna, nama pengguna, dan kota pengguna.

Tutorial ini mencakup tugas-tugas berikut:

• Memuat data ke dalam 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 Anda mulai dengan dokumen ini, pastikan untuk membuat API untuk akun Cassandra, keyspace, dan tabel.

Memuat data ke dalam tabel

Gunakan langkah-langkah berikut untuk memuat data ke dalam API Anda untuk tabel Cassandra:

1. Buka file “UserRepository.java” di bawah bidang “src\main\java\com\azure\cosmosdb\cassandra” folder and append the code to insert the user_id, user_name and user_bcity ke dalam tabel:

   /**
   * Insert a row into user table
   *
   * @param id   user_id
   * @param name user_name
   * @param city user_bcity
   */
   public void insertUser(PreparedStatement statement, int id, String name, String city) {
        BoundStatement boundStatement = new BoundStatement(statement);
        session.execute(boundStatement.bind(id, name, city));
   }
   
   /**
   * Create a PrepareStatement to insert a row to user table
   *
   * @return PreparedStatement
   */
   public PreparedStatement prepareInsertStatement() {
      final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
   return session.prepare(insertStatement);
   }
   

2. Buka file "UserProfile.java" di bawah folder "src\main\java\com\azure\cosmosdb\cassandra". Kelas ini berisi metode utama yang memanggil metode createKeyspace dan createTable yang Anda tentukan sebelumnya. Sekarang tambahkan kode berikut untuk menyisipkan beberapa data sampel ke dalam api untuk tabel Cassandra.

   //Insert rows into user table
   PreparedStatement preparedStatement = repository.prepareInsertStatement();
     repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
     repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
     repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
     repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
     repository.insertUser(preparedStatement, 5, "PeterS", "Everett");
   

Menjalankan aplikasi

Buka prompt perintah atau jendela terminal dan ubah jalur folder ke tempat Anda membuat proyek. Jalankan perintah "pasang bersih mvn" untuk menghasilkan file cosmosdb-cassandra-examples.jar dalam folder target dan jalankan aplikasi.

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

Sekarang Anda dapat membuka Data Explorer di portal Microsoft Azure untuk mengonfirmasi bahwa informasi pengguna ditambahkan ke tabel.

Langkah berikutnya

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

Mengkueri data dari API untuk akun Cassandra