Självstudie: Läsa in exempeldata i en API för Cassandra-tabell i Azure Cosmos DB

GÄLLER FÖR: Kassandra

Som utvecklare kan du ha program som använder nyckel/värde-par. Du kan använda API för Cassandra-konto i Azure Cosmos DB för att lagra och hantera nyckel-/värdedata. Den här självstudien visar hur du läser in exempelanvändardata till en tabell i ett API för Cassandra-konto i Azure Cosmos DB med hjälp av ett Java-program. Java-programmet använder Java-drivrutinen och läser in användardata såsom användar-ID, användarnamn och användarens stad.

Den här självstudien omfattar följande uppgifter:

• Läsa in data till en Cassandra-tabell
• Kör appen

Om du inte har en Azure-prenumeration kan du skapa ett kostnadsfritt konto innan du börjar.

Förutsättningar

• Den här artikeln tillhör en självstudiekursen i flera delar. Innan du börjar med det här dokumentet måste du skapa API:et för Cassandra-kontot, nyckelområdet och tabellen.

Läsa in data i tabellen

Använd följande steg för att läsa in data i din API för Cassandra-tabellen:

1. Öppna filen ”UserRepository.java” under mappen ”src\main\java\com\azure\cosmosdb\cassandra” och lägg till koden för att infoga fälten user_id, user_name och user_bcity i tabellen:

   /**
   * 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. Öppna filen ”UserProfile.java” under mappen ”src\main\java\com\azure\cosmosdb\cassandra”. Den här klassen innehåller huvudmetoden som anropar metoderna createKeyspace och createTable som du definierade tidigare. Lägg nu till följande kod för att infoga exempeldata i tabellen API för 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");
   

Kör appen

Öppna en kommandotolk eller ett terminalfönster och ändra mappsökvägen till den plats där du skapade projektet. Kör kommandot ”mvn clean install” för att generera filen cosmosdb-cassandra-examples.jar i målmappen och köra programmet.

cd "cassandra-demo"

mvn clean install

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

Nu kan du öppna Datautforskaren på Azure-portalen och bekräfta att användarinformationen har lagts till i tabellen.

Nästa steg

I den här självstudien har du lärt dig hur du läser in exempeldata till ett API för Cassandra-konto i Azure Cosmos DB. Nu kan du fortsätta till nästa artikel:

Fråga efter data från API:et för Cassandra-kontot