Sdílet prostřednictvím

Kurz: Načtení ukázkových dat do tabulky API for Cassandra ve službě Azure Cosmos DB

  • Článek

PLATÍ PRO: Cassandra

Jako vývojář můžete mít aplikace, které používají páry klíč/hodnota. K ukládání a správě dat klíče a hodnoty můžete použít rozhraní API pro účet Cassandra ve službě Azure Cosmos DB. V tomto kurzu se dozvíte, jak načíst ukázková uživatelská data do tabulky v účtu rozhraní API pro Cassandra ve službě Azure Cosmos DB pomocí aplikace v Javě. Aplikace v Javě používá ovladač Javy a načítá uživatelská data, jako je ID uživatele, uživatelské jméno a město uživatele.

Tento kurz se zabývá následujícími úkony:

  • Načtení dat do tabulky Cassandra
  • Spustit aplikaci

Pokud ještě nemáte předplatné Azure, vytvořte si bezplatný účet před tím, než začnete.

Požadavky

Načtení dat do tabulky

Pomocí následujícího postupu načtěte data do tabulky API pro Cassandra:

  1. Otevřete soubor "UserRepository.java" ve složce "src\main\java\com\azure\cosmosdb\cassandra" a připojte kód pro vložení user_id, user_name a user_bcity polí do tabulky:

    /**
* 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. Otevřete soubor "UserProfile.java" ve složce "src\main\java\com\azure\cosmosdb\cassandra". Tato třída obsahuje hlavní metodu, která volá metody createKeyspace a createTable, které jste definovali dříve. Teď přidejte následující kód, který vloží ukázková data do tabulky API for 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");

Spustit aplikaci

Otevřete příkazový řádek nebo okno terminálu a změňte cestu ke složce na místo, kde jste projekt vytvořili. Spuštěním příkazu "mvn clean install" vygenerujte soubor cosmosdb-cassandra-examples.jar v cílové složce a spusťte aplikaci.

cd "cassandra-demo"

mvn clean install

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

Teď můžete na portálu Azure Portal otevřít Průzkumníka dat a potvrdit, že se informace o uživateli přidaly do tabulky.

Další kroky

V tomto kurzu jste se naučili načíst ukázková data do účtu API pro Cassandra ve službě Azure Cosmos DB. Teď můžete přejít k dalšímu článku:

Dotazování dat z účtu API pro Cassandra