Lindorm：Menggunakan driver klien Cassandra untuk Java dalam mengembangkan aplikasi

Prasyarat

• Java Development Kit (JDK) versi 1.8 atau lebih baru telah diinstal.

• Driver klien Cassandra untuk Java telah diinstal melalui CQL. Untuk informasi lebih lanjut, lihat Instal Driver Klien Cassandra.

• Alamat IP klien Anda telah ditambahkan ke daftar putih instance Lindorm. Untuk informasi lebih lanjut, lihat Konfigurasi Daftar Putih.

• LindormTable endpoint for Cassandra SQL telah diperoleh. Untuk informasi lebih lanjut, lihat Lihat Titik Akhir.

Prosedur

1. Konfigurasikan parameter koneksi.

    String[] contactPoints = new String[]{
         "<host>"
    };
     
    Cluster cluster = Cluster.builder()
         .addContactPoints(contactPoints)      
         .withAuthProvider(new PlainTextAuthProvider(username, password))
         .build();
    cluster.init();
    Session session = cluster.connect();

   Catatan

   • Ganti <host> dengan LindormTable endpoint for Cassandra SQL yang diperoleh dari konsol Lindorm. Contoh: ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com.

   • Ganti username dengan nama pengguna yang digunakan untuk terhubung ke instance Lindorm. Nama pengguna default adalah root.

   • Ganti password dengan kata sandi yang digunakan untuk terhubung ke instance Lindorm. Jika Anda lupa kata sandi, Anda dapat mengubahnya melalui cluster management system LindormTable. Untuk informasi lebih lanjut, lihat Ubah Kata Sandi Pengguna.

2. Gunakan operasi API dari driver klien Cassandra untuk Java guna mengakses tabel lebar Lindorm melalui CQL. Potongan kode berikut memberikan contoh cara mengakses tabel lebar Lindorm:

   • Operasi DDL

     // Buat keyspace. Konfigurasikan strategi replikasi dan faktor replikasi untuk keyspace.
         session.execute(
                     "CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication "
                             + "= {'class':'SimpleStrategy', 'replication_factor':1};");
     
      // Buat tabel dan tentukan primary key, cluster key, dan regular key untuk tabel tersebut.
         session.execute(
                     "CREATE TABLE IF NOT EXISTS testKeyspace.testTable ("
                             + "id int PRIMARY KEY,"
                             + "name text,"
                             + "age int,"
                             + "address text"
                             + ");");    
     
      // Bersihkan tabel.
         session.execute("TRUNCATE TABLE testKeyspace.testTable;");
      // Hapus tabel.
         session.execute("DROP TABLE testKeyspace.testTable ");

   • Operasi DML

     // Jalankan pernyataan INSERT.
         session.execute(
                     "INSERT INTO testKeyspace.testTable (id, name, age, address) "
                             + "VALUES ("
                             + "1,"
                             + "'testname',"
                             + "11,"
                             + "'hangzhou');");
         // Jalankan pernyataan SELECT. Jika Anda ingin meminta semua kolom dalam tabel, gunakan SELECT *. Anda juga dapat menentukan kolom yang ingin Anda minta.
         ResultSet res = session.execute(
                     "SELECT * FROM testKeyspace.testTable ;");
     
         // Jika Anda ingin meminta data setiap kolom, jalankan pernyataan berikut:
         for (Row row : res)
         {
             int id = row.getInt("id");
             String name = row.getString("name");
             int age = row.getInt("age");
             String address = row.getString("address");
         }
     
         // Tutup sesi.
         session.close();
         // Matikan kluster.
         cluster.close();