Dela via


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

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: