Aracılığıyla paylaş

Hızlı Başlangıç: Java için Azure SDK ile NoSQL için Azure Cosmos DB kullanma

  • Makale
  • Şunlara uygulanır:
    ✅ NoSQL

Bu hızlı başlangıçta, Java için Azure SDK'yı kullanarak tablo için temel bir Azure Cosmos DB uygulaması dağıtacaksınız. Tablo için Azure Cosmos DB, uygulamaların yapılandırılmış tablo verilerini bulutta depolamasına olanak sağlayan şemasız bir veri deposudur. Java için Azure SDK'yı kullanarak Azure Cosmos DB kaynağınızda tablo, satır oluşturma ve temel görevleri gerçekleştirme hakkında bilgi edinirsiniz.

API başvuru belgeleri | Kitaplık kaynak kodu | Paketi (Maven) | Azure Geliştirici CLI

Önkoşullar

  • Azure Geliştirici CLI
  • Docker Desktop
  • Java 21

Azure hesabınız yoksa, başlamadan önce ücretsiz hesap oluşturun.

Projeyi başlatma

Tablo hesabı için Azure Cosmos DB oluşturmak ve kapsayıcılı örnek bir uygulama dağıtmak için Azure Geliştirici CLI'sini (azd) kullanın. Örnek uygulama örnek verileri yönetmek, oluşturmak, okumak ve sorgulamak için istemci kitaplığını kullanır.

  1. Boş bir dizinde bir terminal açın.

  2. Henüz kimlik doğrulaması yapmadıysanız kullanarak azd auth loginAzure Geliştirici CLI'sinde kimlik doğrulamasından geçin. Tercih ettiğiniz Azure kimlik bilgilerini kullanarak CLI'da kimlik doğrulaması yapmak için araç tarafından belirtilen adımları izleyin.

    azd auth login

  3. Projeyi başlatmak için kullanın azd init .

    azd init --template cosmos-db-nosql-java-quickstart

  4. Başlatma sırasında benzersiz bir ortam adı yapılandırın.

  5. Kullanarak azd upAzure Cosmos DB hesabını dağıtın. Bicep şablonları ayrıca örnek bir web uygulaması dağıtır.

    azd up

  6. Sağlama işlemi sırasında aboneliğinizi, istediğiniz konumu ve hedef kaynak grubunu seçin. Sağlama işleminin tamamlanmasını bekleyin. İşlem yaklaşık beş dakika sürebilir.

  7. Azure kaynaklarınızın sağlanması tamamlandıktan sonra, çalışan web uygulamasının URL'si çıktıya eklenir.

    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. Tarayıcıda web uygulamanıza gitmek için konsoldaki URL'yi kullanın. Çalışan uygulamanın çıkışını gözlemleyin.

Çalışan web uygulamasının ekran görüntüsü.

İstemci kitaplığını yükleme

İstemci kitaplığı, paket olarak azure-spring-data-cosmos Maven aracılığıyla kullanılabilir.

  1. Klasöre /src/web gidin ve pom.xml dosyasını açın.

  2. Henüz yoksa paket için azure-spring-data-cosmos bir girdi ekleyin.

    <dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-spring-data-cosmos</artifactId>
</dependency>

  3. Ayrıca, henüz yoksa paket için azure-identity başka bir bağımlılık ekleyin.

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

Nesne modeli

Veri Akışı Adı Açıklama
EnableCosmosRepositories Bu tür, NoSQL için Azure Cosmos DB'ye erişmek üzere bir depo yapılandırmak için kullanılan bir yöntem dekoratörüdür.
CosmosRepository Bu sınıf birincil istemci sınıfıdır ve kapsayıcı içindeki verileri yönetmek için kullanılır.
CosmosClientBuilder Bu sınıf, depo tarafından kullanılan bir istemci oluşturmak için kullanılan bir fabrikadır.
Query Bu tür, deponun yürüttüğü sorguyu belirtmek için kullanılan bir yöntem dekoratörüdür.

Kod örnekleri

Şablondaki örnek kod adlı bir veritabanı ve adlı cosmicworks productskapsayıcıyı kullanır. Kapsayıcı ad products , kategori, miktar, benzersiz tanımlayıcı ve her ürün için satış bayrağı gibi ayrıntıları içerir. Kapsayıcı, mantıksal bölüm anahtarı olarak özelliğini kullanır /category .

İstemcinin kimliğini doğrulama

İlk olarak bu örnek, NoSQL için Azure Cosmos DB bağlantısını yapılandırmak üzere öğesinden AbstractCosmosConfiguration devralan yeni bir sınıf oluşturur.

@Configuration
@EnableCosmosRepositories
public class CosmosConfiguration extends AbstractCosmosConfiguration {
}

Yapılandırma sınıfı içinde, bu örnek sınıfın CosmosClientBuilder yeni bir örneğini oluşturur ve bir DefaultAzureCredential örnek kullanarak kimlik doğrulamasını yapılandırılır.

@Bean
public CosmosClientBuilder getCosmosClientBuilder() {
    DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
        .build();
        
    return new CosmosClientBuilder()
        .endpoint("<azure-cosmos-db-nosql-account-endpoint>")
        .credential(credential);
}

Veritabanı alma

Yapılandırma sınıfında, örnek adlı cosmicworksmevcut veritabanının adını döndürmek için bir yöntem uygular.

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

Kapsayıcı alma

Kapsayıcıdaki Container öğeleri temsil eden bir sınıf yapılandırmak için yöntem dekoratörunu kullanın. JSON'da seri hale getirmek istediğiniz tüm üyeleri dahil etmek için sınıfını yazın. Bu örnekte, türün benzersiz bir tanımlayıcısı ve kategori, ad, miktar, fiyat ve boşluk alanları vardır.

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

    @PartitionKey
    private String category;

    // Extra members omitted for brevity
}

Öğe oluşturma

kullanarak repository.savekapsayıcıda bir öğe oluşturun.

Item item = new Item(
    "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
    "gear-surf-surfboards",
    "Yamba Surfboard",
    12,
    false
);
Item created_item = repository.save(item);

Öğe okuma

Hem benzersiz tanımlayıcıyı (id) hem de bölüm anahtarı alanlarını kullanarak nokta okuma işlemi gerçekleştirin. Belirli bir öğeyi verimli bir şekilde almak için kullanın repository.findById .

PartitionKey partitionKey = new PartitionKey("gear-surf-surfboards");
Optional<Item> existing_item = repository.findById("aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb", partitionKey);
if (existing_item.isPresent()) {
    // Do something
}

Sorgu öğeleri

Deponun arabiriminde bir sorgu tanımlayarak bir kapsayıcıdaki birden çok öğe üzerinde sorgu gerçekleştirin. Bu örnekte, bu parametreli sorguyu Query yürüten bir yöntem tanımlamak için yöntem dekoratörü kullanılır:

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);

}

kullanarak repository.getItemsByCategorysorgunun tüm sonuçlarını getirin. Sorgunun sonuçları arasında döngü yapın.

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

Kaynakları temizleme

Örnek uygulamaya veya kaynaklara artık ihtiyacınız kalmadığında, ilgili dağıtımı ve tüm kaynakları kaldırın.

azd down

İlgili içerik