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

DOTYCZY: Kasandra

Jako deweloper być może masz aplikacje, które używają par klucz-wartość. Do przechowywania danych klucza/wartości i zarządzania nimi można użyć interfejsu API dla konta Cassandra w usłudze Azure Cosmos DB. 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 Java używa sterownika Java i ładuje dane użytkownika, takie jak identyfikator użytkownika, nazwa użytkownika i miasto użytkownika.

Ten samouczek obejmuje następujące zadania:

Wymagania wstępne

• Jeśli nie masz subskrypcji Azure, przed rozpoczęciem utwórz darmowe konto.
• Ten artykuł należy do wieloczęściowego samouczka. Przed rozpoczęciem pracy z tym artykułem upewnij się, że utworzono interfejs API dla konta, przestrzeni kluczy i tabeli Cassandra.

Ładowanie danych do tabel

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

1. UserRepository.java Otwórz plik w folderze src\main\java\com\azure\cosmosdb\cassandra . Dołącz kod, aby wstawić user_idpola , user_namei 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. UserProfile.java Otwórz plik w folderze src\main\java\com\azure\cosmosdb\cassandra . Klasa ta zawiera metodę `main`, która wywołuje zdefiniowane wcześniej metody createKeyspace oraz createTable. 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");
   

Uruchom aplikację

Otwórz wiersz polecenia lub okno terminalu i zmień ścieżkę folderu na miejsce utworzenia projektu. Uruchom polecenie , mvn clean install aby wygenerować cosmosdb-cassandra-examples.jar plik w folderze docelowym i uruchomić 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 potwierdzić, że informacje o użytkowniku zostały dodane do tabeli.

Następny krok

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: