Samouczek: ładowanie przykładowych danych do interfejsu API dla tabeli Cassandra w usłudze Azure Cosmos DB

  • Artykuł

DOTYCZY: Cassandra

Jako deweloper być może masz aplikacje, które używają par klucz-wartość. Za pomocą interfejsu API dla konta Cassandra w usłudze Azure Cosmos DB można przechowywać dane klucza/wartości i zarządzać nimi. W tym samouczku pokazano, jak załadować przykładowe dane użytkownika do tabeli w interfejsie API dla konta Cassandra w usłudze Azure Cosmos DB przy użyciu aplikacji Java. Aplikacja języka Java używa sterownika języka Java i ładuje dane użytkownika, takie jak identyfikator, nazwa i miasto użytkownika.

Ten samouczek obejmuje następujące zadania:

  • Ładowanie danych do tabeli Cassandra
  • Uruchamianie aplikacji

Jeśli nie masz subskrypcji platformy Azure, przed rozpoczęciem utwórz bezpłatne konto .

Wymagania wstępne

Ładowanie danych do tabel

Wykonaj następujące kroki, aby załadować dane do interfejsu API dla tabeli Cassandra:

  1. Otwórz plik „UserRepository.java” w folderze „src\main\java\com\azure\cosmosdb\cassandra” i dołącz kod wstawiający pola user_id, user_name i user_bcity do tabeli:

    /**
* 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. Otwórz plik „UserProfile.java” w folderze „src\main\java\com\azure\cosmosdb\cassandra”. Ta klasa zawiera metodę main wywołującą metody createKeyspace i createTable zdefiniowane wcześniej. Teraz dołącz następujący kod, aby wstawić przykładowe dane do interfejsu API dla tabeli 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");

Uruchamianie aplikacji

Otwórz wiersz polecenia lub okno terminalu i zmień ścieżkę na folder, w którym utworzono projekt. Uruchom polecenie „mvn clean install”, aby wygenerować plik cosmosdb-cassandra-examples.jar w folderze docelowym, a następnie uruchom aplikację.

cd "cassandra-demo"

mvn clean install

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

Teraz możesz otworzyć Eksploratora danych w witrynie Azure Portal, aby upewnić się, że informacje użytkownika zostały dodane do tabeli.

Następne kroki

W tym samouczku przedstawiono sposób ładowania przykładowych danych do interfejsu API dla konta Cassandra w usłudze Azure Cosmos DB. Teraz możesz przejść do następnego artykułu:

Wykonywanie zapytań dotyczących danych z interfejsu API dla konta Cassandra