Szybki start: biblioteka NoSQL usługi Azure Cosmos DB dla języka Java

DOTYCZY: NoSQL

Rozpocznij pracę z biblioteką klienta usługi Azure Cosmos DB for NoSQL dla języka Java, aby wykonywać zapytania o dane w kontenerach i wykonywać typowe operacje na poszczególnych elementach. Wykonaj następujące kroki, aby wdrożyć minimalne rozwiązanie w środowisku przy użyciu interfejsu wiersza polecenia dla deweloperów platformy Azure.

Dokumentacja interfejsu API — pakiet | kodu | źródłowego biblioteki (Maven) | Interfejs wiersza polecenia dla deweloperów platformy Azure

Wymagania wstępne

Konfigurowanie

Wdróż kontener projektowy w swoim środowisku. Następnie użyj interfejsu wiersza polecenia dla deweloperów platformy Azure (azd), aby utworzyć konto usługi Azure Cosmos DB for NoSQL i wdrożyć konteneryzowaną przykładową aplikację. Przykładowa aplikacja używa biblioteki klienta do zarządzania, tworzenia, odczytywania i wykonywania zapytań dotyczących przykładowych danych.

Otwieranie w usłudze GitHub Codespaces

Otwórz w kontenerze deweloperskim

Ważne

Konta usługi GitHub obejmują uprawnienia do magazynowania i godzin podstawowych bez ponoszenia kosztów. Aby uzyskać więcej informacji, zobacz uwzględnione godziny magazynowania i rdzeni dla kont usługi GitHub.

  1. Otwórz terminal w katalogu głównym projektu.

  2. Uwierzytelnianie w interfejsie wiersza polecenia dla deweloperów platformy Azure przy użyciu polecenia azd auth login. Wykonaj kroki określone przez narzędzie, aby uwierzytelnić się w interfejsie wiersza polecenia przy użyciu preferowanych poświadczeń platformy Azure.

    azd auth login
    
  3. Użyj azd init polecenia , aby zainicjować projekt.

    azd init
    
  4. Podczas inicjowania skonfiguruj unikatową nazwę środowiska.

    Napiwek

    Nazwa środowiska będzie również używana jako nazwa docelowej grupy zasobów. W tym przewodniku Szybki start rozważ użycie polecenia msdocs-cosmos-db-.

  5. Wdróż konto usługi Azure Cosmos DB przy użyciu polecenia azd up. Szablony Bicep wdrażają również przykładową aplikację internetową.

    azd up
    
  6. Podczas procesu aprowizacji wybierz subskrypcję i żądaną lokalizację. Poczekaj na zakończenie procesu aprowizacji. Proces może potrwać około pięciu minut.

  7. Po zakończeniu aprowizacji zasobów platformy Azure adres URL uruchomionej aplikacji internetowej zostanie uwzględniony w danych wyjściowych.

    Deploying services (azd deploy)
    
      (✓) Done: Deploying service web
    - Endpoint: <https://[container-app-sub-domain].azurecontainerapps.io>
    
    SUCCESS: Your application was provisioned and deployed to Azure in 5 minutes 0 seconds.
    
  8. Użyj adresu URL w konsoli, aby przejść do aplikacji internetowej w przeglądarce. Obserwuj dane wyjściowe uruchomionej aplikacji.

    Zrzut ekranu przedstawiający uruchomioną aplikację internetową.

Instalowanie biblioteki klienta

Biblioteka klienta jest dostępna za pośrednictwem narzędzia Maven jako azure-spring-data-cosmos pakietu.

  1. Przejdź do /src/web folderu i otwórz plik pom.xml .

  2. Jeśli jeszcze nie istnieje, dodaj wpis dla azure-spring-data-cosmos pakietu.

    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-spring-data-cosmos</artifactId>
    </dependency>
    
  3. Ponadto dodaj kolejną zależność dla azure-identity pakietu, jeśli jeszcze nie istnieje.

    <dependency>
        <groupId>com.azure</groupId>
        <artifactId>azure-identity</artifactId>
    </dependency>
    

Model obiektów

Nazwa/nazwisko opis
EnableCosmosRepositories Ten typ to dekorator metody używany do konfigurowania repozytorium w celu uzyskania dostępu do usługi Azure Cosmos DB for NoSQL.
CosmosRepository Ta klasa jest podstawową klasą klienta i służy do zarządzania danymi w kontenerze.
CosmosClientBuilder Ta klasa jest fabryką używaną do tworzenia klienta używanego przez repozytorium.
Query Ten typ jest dekoratorem metody używanym do określania zapytania wykonywanego przez repozytorium.

Przykłady kodu

Przykładowy kod w szablonie używa bazy danych o nazwie i kontenera o nazwie cosmicworksproducts. Kontener products zawiera szczegóły, takie jak nazwa, kategoria, ilość, unikatowy identyfikator i flaga sprzedaży dla każdego produktu. Kontener używa /category właściwości jako klucza partycji logicznej.

Uwierzytelnianie użytkownika

Żądania aplikacji do większości usług platformy Azure muszą być autoryzowane. DefaultAzureCredential Użyj typu jako preferowanego sposobu implementacji połączenia bez hasła między aplikacjami i usługą Azure Cosmos DB for NoSQL. DefaultAzureCredential obsługuje wiele metod uwierzytelniania i określa, która metoda powinna być używana w czasie wykonywania.

Ważne

Możesz również autoryzować żądania do usług platformy Azure przy użyciu haseł, parametry połączenia lub innych poświadczeń bezpośrednio. Należy jednak zachować ostrożność przy użyciu tego podejścia. Deweloperzy muszą być sumienni, aby nigdy nie ujawniać tych wpisów tajnych w niezabezpieczonej lokalizacji. Każdy, kto uzyskuje dostęp do hasła lub klucza tajnego, może uwierzytelnić się w usłudze bazy danych. DefaultAzureCredential oferuje ulepszone korzyści związane z zarządzaniem i zabezpieczeniami za pośrednictwem klucza konta, aby umożliwić uwierzytelnianie bez hasła bez ryzyka przechowywania kluczy.

Najpierw w tym przykładzie zostanie utworzona nowa klasa dziedziczona w AbstractCosmosConfiguration celu skonfigurowania połączenia z usługą Azure Cosmos DB for NoSQL.

@Configuration
@EnableCosmosRepositories
public class CosmosConfiguration extends AbstractCosmosConfiguration {

W klasie konfiguracji ten przykład tworzy nowe wystąpienie CosmosClientBuilder klasy i konfiguruje uwierzytelnianie przy użyciu DefaultAzureCredential wystąpienia.

@Bean
public CosmosClientBuilder getCosmosClientBuilder() {
    DefaultAzureCredential azureTokenCredential = new DefaultAzureCredentialBuilder()
        .build();
        
    return new CosmosClientBuilder()
        .endpoint(uri)
        .credential(azureTokenCredential);
}

Pobieranie bazy danych

W klasie konfiguracji przykład implementuje metodę zwracającą nazwę istniejącej bazy danych o nazwie cosmicworks.

@Override
protected String getDatabaseName() {
    return "cosmicworks";
}

Pobieranie kontenera

Użyj dekoratora Container metody, aby skonfigurować klasę do reprezentowania elementów w kontenerze. Utwórz klasę, aby uwzględnić wszystkie elementy członkowskie, które chcesz serializować w formacie JSON. W tym przykładzie typ ma unikatowy identyfikator i pola dla kategorii, nazwy, ilości, ceny i rozliczenia.

@Container(containerName = "products", autoCreateContainer = false)
public class Item {
    private String id;
    private String name;
    private Integer quantity;
    private Boolean sale;

    @PartitionKey
    private String category;

Tworzenie elementu

Utwórz element w kontenerze przy użyciu polecenia repository.save.

Item item = new Item(
    "70b63682-b93a-4c77-aad2-65501347265f",
    "gear-surf-surfboards",
    "Yamba Surfboard",
    12,
    false
);
Item created_item = repository.save(item);

Odczytywanie elementu

Wykonaj operację odczytu punktu przy użyciu pól unikatowego identyfikatora (id) i klucza partycji. Służy repository.findById do wydajnego pobierania określonego elementu.

PartitionKey partitionKey = new PartitionKey("gear-surf-surfboards");
Optional<Item> existing_item = repository.findById("70b63682-b93a-4c77-aad2-65501347265f", partitionKey);
if (existing_item.isPresent()) {
    // Do something  
}

Elementy kwerend

Wykonywanie zapytania względem wielu elementów w kontenerze przez zdefiniowanie zapytania w interfejsie repozytorium. W tym przykładzie użyto dekoratora Query metody do zdefiniowania metody wykonującej to sparametryzowane zapytanie:

SELECT * FROM products p WHERE p.category = @category
@Repository
public interface ItemRepository extends CosmosRepository<Item, String> {
    @Query("SELECT * FROM products p WHERE p.category = @category")
    List<Item> getItemsByCategory(@Param("category") String category);
}

Pobierz wszystkie wyniki zapytania przy użyciu polecenia repository.getItemsByCategory. Pętla przez wyniki zapytania.

List<Item> items = repository.getItemsByCategory("gear-surf-surfboards");
for (Item item : items) {
    // Do something
}

Następny krok