Tutorial: Abfragen von Daten in einem API für Cassandra-Konto in Azure Cosmos DB

Artikel
06/01/2023

GILT FÜR: Cassandra

Als Entwickler besitzen Sie möglicherweise Anwendungen, die Schlüssel/Wert-Paare verwenden. Sie können ein API für Cassandra-Konto in Azure Cosmos DB zum Speichern und Abfragen der Schlüssel-Wert-Daten verwenden. In diesem Tutorial wird das Abfragen von Benutzerdaten in einem API für Cassandra-Konto in Azure Cosmos DB mithilfe einer Java-Anwendung gezeigt. Die Java-Anwendung verwendet den Java-Treiber und fragt Benutzerdaten wie Benutzer-ID, Benutzername und Benutzerort ab.

Dieses Tutorial enthält die folgenden Aufgaben:

Abfragen von Daten aus einer Cassandra-Tabelle
Ausführen der App

Wenn Sie kein Azure-Abonnement besitzen, können Sie ein kostenloses Konto erstellen, bevor Sie beginnen.

Voraussetzungen

Dieser Artikel gehört zu einem mehrteiligen Tutorial. Bevor Sie beginnen, führen Sie die vorherigen Schritte zum Erstellen des API für Cassandra-Kontos, Keyspace oder der Tabelle und zum Laden von Beispieldaten in die Tabelle aus.

Daten abfragen

Führen Sie zum Abfragen von Daten aus Ihrem API für Cassandra-Konto die folgenden Schritte aus:

Öffnen Sie die Datei UserRepository.java unter dem Ordner src\main\java\com\azure\cosmosdb\cassandra. Fügen Sie folgenden Codeblock an. Dieser Code bietet drei Methoden:

Abfragen aller Benutzer in der Datenbank
Abfragen eines bestimmten Benutzers, gefiltert nach Benutzer-ID
So löschen Sie eine Tabelle

/**
* Select all rows from user table
*/
public void selectAllUsers() {

  final String query = "SELECT * FROM uprofile.user";
  List<Row> rows = session.execute(query).all();

  for (Row row : rows) {
     LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity"));
  }
}

/**
* Select a row from user table
*
* @param id user_id
*/
public void selectUser(int id) {
   final String query = "SELECT * FROM uprofile.user where user_id = 3";
   Row row = session.execute(query).one();

   LOGGER.info("Obtained row: {} | {} | {} ", row.getInt("user_id"), row.getString("user_name"), row.getString("user_bcity"));
}

/**
* Delete user table.
*/
public void deleteTable() {
  final String query = "DROP TABLE IF EXISTS uprofile.user";
  session.execute(query);
}

Öffnen Sie die Datei UserProfile.java unter dem Ordner src\main\java\com\azure\cosmosdb\cassandra. Diese Klasse enthält die main-Methode, die die Methoden zum Einfügen von Daten createKeyspace und createTable aufruft, die Sie zuvor definiert haben. Fügen Sie nun den folgenden Code an, der alle Benutzer oder einen bestimmten Benutzer abfragt:
```
LOGGER.info("Select all users");
repository.selectAllUsers();

LOGGER.info("Select a user by id (3)");
repository.selectUser(3);

LOGGER.info("Delete the users profile table");
repository.deleteTable();
```

Ausführen der Java-App

Öffnen Sie eine Eingabeaufforderung oder ein Terminalfenster. Fügen Sie folgenden Codeblock ein.

Dieser Code ändert das Verzeichnis (cd) in den Ordnerpfad, in dem das Projekt erstellt wurde. Anschließend führt er den Befehl mvn clean install zum Generieren der Datei cosmosdb-cassandra-examples.jar im Zielordner aus. Abschließend führt er die Java-Anwendung aus.
```
cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile
```
Öffnen Sie nun im Azure-Portal den Daten-Explorer, und vergewissern Sie sich, dass die Benutzertabelle gelöscht ist.

Bereinigen von Ressourcen

Wenn die Ressourcengruppe, das Azure Cosmos DB-Konto und die dazugehörigen Ressourcen nicht mehr benötigt werden, können Sie sie löschen. Wählen Sie dazu die Ressourcengruppe für den virtuellen Computer und anschließend Löschen aus, und bestätigen Sie den Namen der zu löschenden Ressourcengruppe.

Nächste Schritte

In diesem Tutorial haben Sie gelernt, Ihre Daten aus einem API für Cassandra-Konto in Azure Cosmos DB abzufragen. Sie können jetzt mit dem nächsten Artikel fortfahren:

Migrieren von Daten in ein API für Cassandra-Konto

Freigeben über