Esercitazione: Caricare dati di esempio in una tabella di API Cassandra in Azure Cosmos DB

SI APPLICA A: API Cassandra

Gli sviluppatori possono avere applicazioni che usano coppie chiave/valore. È possibile usare un account dell'API Cassandra in Azure Cosmos DB per archiviare e gestire i dati chiave/valore. Questa esercitazione illustra come caricare i dati utente di esempio in una tabella in un account di API Cassandra in Azure Cosmos DB usando un'applicazione Java. L'applicazione Java usa il driver Java e carica i dati utente, tra cui ID utente, nome utente e città dell'utente.

Questa esercitazione illustra le attività seguenti:

  • Caricare i dati in una tabella di Cassandra
  • Eseguire l'app

Se non si ha una sottoscrizione di Azure, creare un account gratuito prima di iniziare.

Prerequisiti

Caricare i dati nella tabella

Usare la procedura seguente per caricare i dati nella tabella dell'API Cassandra:

  1. Aprire il file "UserRepository.java" nella cartella "src\main\java\com\azure\cosmosdb\cassandra" e aggiungere il codice per inserire i campi user_id, user_name e user_bcity nella tabella:

    /**
    * 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. Aprire il file "UserProfile.java" nella cartella "src\main\java\com\azure\cosmosdb\cassandra". Questa classe contiene il metodo principale che chiama i metodi createKeyspace e createTable definiti in precedenza. A questo punto aggiungere il codice seguente per inserire alcuni dati di esempio nella tabella di API 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");
    

Eseguire l'app

Aprire un prompt dei comandi o una finestra del terminale e modificare il percorso della cartella con il percorso in cui è stato creato il progetto. Eseguire il comando "mvn clean install" per generare il file cosmosdb-cassandra-examples.jar all'interno della cartella di destinazione ed eseguire l'applicazione.

cd "cassandra-demo"

mvn clean install

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

È ora possibile aprire Esplora dati nel portale di Azure per confermare che le informazioni dell'utente siano state aggiunte alla tabella.

Passaggi successivi

In questa esercitazione si è appreso come caricare i dati utente di esempio in un account dell'API Cassandra in Azure Cosmos DB. È possibile passare all'articolo successivo:

Query data from the Cassandra API account (Eseguire query sui dati dall'account di API Cassandra)