Tutorial: Carga de datos de muestra en una tabla de la API para Cassandra en Azure Cosmos DB

SE APLICA A: Cassandra

Como desarrollador, puede que tenga aplicaciones que usan pares clave/valor. Puede usar una cuenta de API para Cassandra en Azure Cosmos DB para almacenar y administrar los datos de los pares clave/valor. En este tutorial se explica cómo cargar datos de usuario de ejemplo en una tabla de una cuenta de API para Cassandra en Azure Cosmos DB mediante una aplicación Java. La aplicación Java emplea el controlador de Java para cargar datos del usuario, como el identificador, el nombre o la ciudad del usuario.

En este tutorial se describen las tareas siguientes:

• Carga de datos en una tabla de Cassandra
• Ejecución la aplicación

Si no tiene una suscripción a Azure, cree una cuenta gratuita antes de empezar.

Requisitos previos

• Este artículo pertenece a un tutorial de varias partes. Antes de empezar con este documento, no olvide crear la cuenta, el espacio de claves y la tabla de API para Cassandra.

Carga de datos en la tabla

Siga estos pasos para cargar datos en la tabla de API para Cassandra:

1. Abra el archivo "UserRepository.java", que se encuentra en la carpeta "src\main\java\com\azure\cosmosdb\cassandra", y anexe el código para insertar los campos user_id, user_name y user_bcity en la tabla:

   Java

   /**
   * Insert a row into user table
   *
   * @param id   user_id
   * @param name user_name
   * @param city user_bcity
   */
   public void insertUser(PreparedStatement statement, int id, String name, String city) {
        BoundStatement boundStatement = new BoundStatement(statement);
        session.execute(boundStatement.bind(id, name, city));
   }
   
   /**
   * Create a PrepareStatement to insert a row to user table
   *
   * @return PreparedStatement
   */
   public PreparedStatement prepareInsertStatement() {
      final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
   return session.prepare(insertStatement);
   }
   

2. Abra el archivo "UserProfile.java", que se encuentra en la carpeta "src\main\java\com\azure\cosmosdb\cassandra". Esta clase contiene el método principal que llama a los métodos createKeyspace y createTable definidos anteriormente. Ahora, anexe el código siguiente para insertar algunos datos de ejemplo en la tabla de API para Cassandra.

   Java

   //Insert rows into user table
   PreparedStatement preparedStatement = repository.prepareInsertStatement();
     repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
     repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
     repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
     repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
     repository.insertUser(preparedStatement, 5, "PeterS", "Everett");
   

Ejecución la aplicación

Abra un símbolo del sistema o la ventana de terminal y cambie la ruta de acceso a la carpeta en la que ha creado el proyecto. Ejecute el comando "mvn clean install" para generar el archivo cosmosdb-cassandra-examples.jar dentro de la carpeta de destino y ejecute la aplicación.

Bash

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

Ya puede abrir el Explorador de datos en Azure Portal para confirmar que la información del usuario se agrega a la tabla.

Pasos siguientes

En este tutorial ha aprendido a cargar datos de ejemplo a una cuenta de API para Cassandra en Azure Cosmos DB. Avance al siguiente artículo:

Consulta de los datos de la cuenta de la API para Cassandra