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

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 typu klíč/hodnota 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 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čtěte data do tabulky Cassandra.
• Spustit aplikaci.

Požadavky

• Pokud nemáte předplatné Azure, vytvořte si bezplatný účet před zahájením.
• Tento článek patří do kurzu s více částmi. Než začnete s tímto článkem, nezapomeňte vytvořit rozhraní API pro účet Cassandra, prostor klíčů a tabulku.

Načtení dat do tabulky

Pokud chcete načíst data do tabulky API pro Cassandra, postupujte takto:

1. UserRepository.java Otevřete soubor ve src\main\java\com\azure\cosmosdb\cassandra složce. Připojte kód, který vloží user_idpole , user_namea user_bcity pole 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. UserProfile.java Otevřete soubor ve src\main\java\com\azure\cosmosdb\cassandra složce. 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, kam jste projekt vytvořili. Spuštěním mvn clean install příkazu vygenerujte cosmosdb-cassandra-examples.jar soubor 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

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

Další krok

V tomto kurzu jste zjistili, jak načíst ukázková data do účtu API for 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