Lindorm:Menghubungkan ke LindormTable dengan driver Java Cassandra CQL

Prasyarat

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

• Driver Java Cassandra CQL telah diinstal. Instal Driver Cassandra CQL.

• Alamat IP klien Anda telah ditambahkan ke daftar putih instans Lindorm. Konfigurasikan daftar putih.

• Anda telah memperoleh titik akhir CQL Connection. Di Konsol Lindorm, buka detail instans > Endpoints > tab LindormTable > Cassandra-compatible address untuk mendapatkan alamat privat atau publik (nama pengguna dan kata sandi default: root). Lihat endpoints.

Prosedur

1. Konfigurasikan parameter koneksi.

    String[] contactPoints = new String[]{
         "<host>"
    };
    Cluster

   Catatan

   • host: Alamat CQL Connection dari Konsol Lindorm. Contoh: ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com.

   • username: Nama akun instans Lindorm. Default: root.

   • password: Kata sandi akun instans Lindorm. Jika lupa, atur ulang melalui Cluster Management System pada LindormTable. Ubah kata sandi pengguna.

2. Gunakan API Java Cassandra CQL untuk mengakses tabel lebar Lindorm.

   • Operasi DDL

      // Buat keyspace dan tentukan strategi serta faktor replikasinya.
         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-nya.
         session.execute(
                     "CREATE TABLE IF NOT EXISTS testKeyspace.testTable ("
                             + "id int PRIMARY KEY,"
                             + "name text,"
                             + "age int,"
                             + "address text"
                             + ");");    
      // Kosongkan tabel.
         session.execute("TRUNCATE TABLE testKeyspace.testTable;");
      // Hapus tabel.
         session.execute("DROP TABLE testKeyspace.testTable ");

   • Operasi DML

         // Lakukan operasi insert.
         session.execute(
                     "INSERT INTO testKeyspace.testTable (id, name, age, address) "
                             + "VALUES ("
                             + "1,"
                             + "'testname',"
                             + "11,"
                             + "'hangzhou');");
         // Lakukan operasi select. `select *` mengambil semua kolom. Untuk mengambil data dari kolom tertentu, sebutkan nama kolom tersebut.
         ResultSet res = session.execute(
                     "SELECT * FROM testKeyspace.testTable ;");
         // Untuk mengambil data dari setiap kolom:
         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 session.
         session.close();
         // Tutup cluster.
         cluster.close();