Lindorm：Hubungkan ke dan gunakan LindormTable dengan driver Java Cassandra CQL

Prasyarat

• Lingkungan Java telah diinstal dengan JDK 1.8 atau versi yang lebih baru.

• Driver Java Cassandra CQL telah diinstal. Untuk petunjuk lengkap, lihat Install the Cassandra CQL Driver.

• Alamat IP klien telah ditambahkan ke daftar putih untuk instans Lindorm Anda. Untuk langkah-langkah selengkapnya, lihat Set a whitelist.

• Anda telah memperoleh CQL Connection untuk mesin tabel lebar Lindorm. Untuk informasi selengkapnya, lihat View Connection Addresses.

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

   • host: Dapatkan CQL Connection untuk LindormTable dari Konsol Lindorm. Contohnya, ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com.

   • username: Username untuk instans Lindorm. Username default adalah root.

   • password: Password untuk username instans Lindorm. Jika lupa password, Anda dapat mengubahnya di Cluster Management System LindormTable. Untuk informasi selengkapnya, lihat Change a user password.

2. Gunakan API Java Cassandra CQL untuk mengakses LindormTable. Contoh berikut menunjukkan cara melakukan operasi umum.

   • Operasi DDL

     // Buat keyspace. Tentukan strategi replikasi dan faktor replikasi.
         session.execute(
                     "CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication "
                             + "= {'class':'SimpleStrategy', 'replication_factor':1};");
     
      // Buat tabel. Tentukan primary key, cluster key, dan regular key.
         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

     // Masukkan data.
         session.execute(
                     "INSERT INTO testKeyspace.testTable (id, name, age, address) "
                             + "VALUES ("
                             + "1,"
                             + "'testname',"
                             + "11,"
                             + "'hangzhou');");
         // Kueri semua kolom. Anda juga dapat menentukan nama kolom untuk mengkueri kolom tertentu.
         ResultSet res = session.execute(
                     "SELECT * FROM testKeyspace.testTable ;");
     
         // Ambil 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();
         // Matikan kluster.
         cluster.close();