Lindorm:Cassandra CQL Java sürücüsü ile LindormTable'a bağlanma

Önkoşullar

• Java Development Kit (JDK) 1,8 veya sonraki bir sürüm yüklü olmalıdır.

• Cassandra CQL Java sürücüsü yüklü olmalıdır. Cassandra CQL Sürücüsünü Yükleme.

• İstemci IP adresinizi Lindorm örneğinin izin listesine ekleyin. İzin listesi yapılandırma.

• [KV化][2026-02-10] 原界面词"CQL连接"(uicontrol)替换为美杜莎conref引用

  CQL Connection uç noktasını edinin. Lindorm konsolunda örnek ayrıntıları > Endpoints > LindormTable sekmesi > Cassandra-compatible address yolunu izleyerek özel veya genel adresi alın (varsayılan kullanıcı adı ve parola: root). Uç noktaları görüntüleme.

Yordam

1. Bağlantı parametrelerini yapılandırın.

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

   Not

   • [KV化][2026-02-10] 原界面词"CQL连接"(uicontrol)替换为美杜莎conref引用

     host: Lindorm konsolundaki CQL Connection adresidir. Örnek: ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com.

   • username: Lindorm örnek hesap adıdır. Varsayılan değer: root.

   • [KV化][2026-02-10] 原界面词"集群管理系统"(uicontrol)替换为美杜莎conref引用

     password: Lindorm örnek hesap parolasıdır. Parolanızı unuttuysanız LindormTable içindeki Cluster Management System üzerinden sıfırlayın. Kullanıcı parolasını değiştirme.

2. Cassandra CQL Java API'sini kullanarak Lindorm geniş tablolarına erişin.

   • DDL işlemleri

      // Create a keyspace and specify its strategy and replication factor.
         session.execute(
                     "CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication "
                             + "= {'class':'SimpleStrategy', 'replication_factor':1};");
      // Create a table and specify its primary key, cluster key, and regular key.
         session.execute(
                     "CREATE TABLE IF NOT EXISTS testKeyspace.testTable ("
                             + "id int PRIMARY KEY,"
                             + "name text,"
                             + "age int,"
                             + "address text"
                             + ");");    
      // Truncate the table.
         session.execute("TRUNCATE TABLE testKeyspace.testTable;");
      // Drop the table.
         session.execute("DROP TABLE testKeyspace.testTable ");

   • DML işlemleri

         // Perform an insert operation.
         session.execute(
                     "INSERT INTO testKeyspace.testTable (id, name, age, address) "
                             + "VALUES ("
                             + "1,"
                             + "'testname',"
                             + "11,"
                             + "'hangzhou');");
         // Perform a select operation. `select *` retrieves all columns. To retrieve data from specific columns, specify their names.
         ResultSet res = session.execute(
                     "SELECT * FROM testKeyspace.testTable ;");
         // To retrieve data from each column:
         for (Row row : res)
         {
             int id = row.getInt("id");
             String name = row.getString("name");
             int age = row.getInt("age");
             String address = row.getString("address");
         }
         // Close the session.
         session.close();
         // Close the cluster.
         cluster.close();