Lindorm:Conexión a LindormTable con el controlador Java de Cassandra CQL

Requisitos previos

• Tiene instalado Java Development Kit (JDK) 1.8 o una versión posterior.

• Instaló el controlador Java de Cassandra CQL. Install the Cassandra CQL Driver.

• Agregó la dirección IP de su cliente a la lista blanca de la instancia de Lindorm. Configure a whitelist.

• [Transformación KV][10-02-2026] La etiqueta de interfaz original "CQL Connection" (uicontrol) se reemplazó por una referencia conref de Medusa.

  Obtuvo el endpoint de CQL Connection. En la consola de Lindorm, vaya a los detalles de la instancia > Endpoints > pestaña LindormTable > Cassandra-compatible address para obtener la dirección privada o pública (nombre de usuario y contraseña predeterminados: root). View endpoints.

Procedimiento

1. Configure los parámetros de conexión.

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

   Nota

   • [Transformación KV][10-02-2026] La etiqueta de interfaz original "CQL Connection" (uicontrol) se reemplazó por una referencia conref de Medusa.

     host: la dirección de CQL Connection que obtuvo en la consola de Lindorm. Ejemplo: ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com.

   • username: el nombre de la cuenta de la instancia de Lindorm. Valor predeterminado: root.

   • [Transformación KV][10-02-2026] La etiqueta de interfaz original "Cluster Management System" (uicontrol) se reemplazó por una referencia conref de Medusa.

     password: la contraseña de la cuenta de la instancia de Lindorm. Si la olvidó, restablézcala en el Cluster Management System de LindormTable. Change user password.

2. Use la API de Java de Cassandra CQL para acceder a las tablas anchas de Lindorm.

   • Operaciones DDL

      // 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 ");

   • Operaciones DML

         // 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();