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

SE APLICA A: Casandra

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

En este tutorial se describen las tareas siguientes:

• Cargar datos en una tabla de Cassandra.
• Ejecute la aplicación.

Requisitos previos

• Si no tiene una suscripción a Azure, cree una cuenta gratuita antes de empezar.
• Este artículo pertenece a un tutorial de varias partes. Antes de empezar con este artículo, asegúrese de crear la API para la cuenta de Cassandra, el espacio de claves y la tabla.

Carga de datos en la tabla

Para cargar datos en su tabla de la API para Cassandra, siga estos pasos:

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

   /**
   * 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 UserProfile.java archivo en la src\main\java\com\azure\cosmosdb\cassandra carpeta . Esta clase contiene el método principal que llama a los métodos createKeyspace y createTable que definió anteriormente. Ahora, anexe el código siguiente para insertar algunos datos de ejemplo en la tabla de API para Cassandra.

   //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 una ventana de comandos o de terminal y cambie la ruta de acceso a la carpeta donde creó el proyecto. Ejecute el mvn clean install comando para generar el cosmosdb-cassandra-examples.jar archivo dentro de la carpeta de destino y ejecutar la aplicación.

cd "cassandra-demo"

mvn clean install

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

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

Paso siguiente

En este tutorial, ha aprendido a cargar datos de ejemplo en 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