Självstudie: Ladda in exempeldata i ett 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 ett API för Cassandra-konto i Azure Cosmos DB för att lagra och hantera nyckel-/värdedata. Den här handledningen visar hur du laddar upp exempelanvändardata till en API-tabell för Cassandra-kontot i Azure Cosmos DB med hjälp av ett Java-program. Java-programmet använder Java-drivrutinen och läser in användardata, till exempel användar-ID, användarnamn och användarstad.

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

• Läs in data i en Cassandra-tabell.
• Kör appen.

Förutsättningar

• Om du inte har en Azure-prenumeration, skapa ett gratis konto innan du börjar.
• Den här artikeln tillhör en flerdelad handledning. Innan du börjar med den här artikeln måste du skapa API:et för Cassandra-kontot, nyckelområdet och tabellen.

Läsa in data i tabellen

Följ dessa steg om du vill läsa in data i din API för Cassandra-tabellen:

1. UserRepository.java Öppna filen under mappen src\main\java\com\azure\cosmosdb\cassandra . Lägg till koden för att infoga fälten user_id, user_nameoch 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. UserProfile.java Öppna filen 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 där du skapade projektet. mvn clean install Kör kommandot för att generera cosmosdb-cassandra-examples.jar filen i målmappen och kör 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 i Azure-portalen för att bekräfta att användarinformationen har lagts till i tabellen.

Nästa steg

I den här handledningen har du lärt dig hur du läser in exempeldata till ett API för ett 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