快速入门：将 Azure Cosmos DB for Table 与 Azure SDK for Java 配合使用

在本快速入门中，你将使用 Azure SDK for Java 部署基本的 Azure Cosmos DB for Table 应用程序。 Azure Cosmos DB for Table 是一种无架构数据存储，允许应用程序在云中存储结构化表数据。 你将了解如何使用 Azure SDK for Java 在 Azure Cosmos DB 资源中创建表、行并执行基本任务。

API 参考文档 | 库源代码 | 包 (Maven) | Azure Developer CLI

• Azure 开发人员 CLI
• Docker Desktop
• Java 21

如果你没有 Azure 帐户，请在开始之前创建一个试用帐户。

使用 Azure Developer CLI (azd) 创建 Azure Cosmos DB for Table 帐户并部署容器化示例应用程序。 示例应用程序使用客户端库来管理、创建、读取和查询示例数据。

1. 在空目录中打开终端。

2. 如果尚未经过身份验证，请使用 azd auth login 向 Azure Developer CLI 进行身份验证。 按照该工具指定的步骤，使用首选 Azure 凭据向 CLI 进行身份验证。

   azd auth login
   

3. 使用 azd init 来初始化项目。

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

4. 在初始化期间，配置唯一的环境名称。

5. 使用 azd up 部署 Azure Cosmos DB 帐户。 Bicep 模板还部署示例 Web 应用程序。

   azd up
   

6. 在预配过程中，选择订阅、所需位置和目标资源组。 等待预配过程完成。 此过程可能需要大约 5 分钟。

7. 预配 Azure 资源后，输出中将包含指向正在运行的 Web 应用程序的 URL。

   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. 使用控制台中的 URL 在浏览器中导航到 Web 应用程序。 观察正在运行的应用的输出。

客户端库可以通过 Maven 作为 azure-data-tables 包提供。

1. 导航到 /src/web 文件夹并打开“pom.xml”文件。

   cd ./src
   

2. 如果它尚不存在，请为 azure-data-tables 包添加一个条目。

   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-data-tables</artifactId>
   </dependency>
   

将所有必需的命名空间导入你的应用程序代码。

import com.azure.core.http.rest.PagedFlux;
import com.azure.data.tables.TableAsyncClient;
import com.azure.data.tables.TableClientBuilder;
import com.azure.data.tables.models.ListEntitiesOptions;
import com.azure.data.tables.models.TableEntity;
import com.azure.identity.DefaultAzureCredential;
import com.azure.identity.DefaultAzureCredentialBuilder;

• 对客户端进行身份验证
• 获取一个表格
• 创建实体
• 获取实体
• 查询实体

模板中的示例代码使用名为 cosmicworks-products 的表。 cosmicworks-products 表包含每个产品的详细信息，例如名称、类别、数量、价格、唯一标识符和销售标志。 容器使用唯一标识符*作为行键，使用类别作为分区键。

此示例创建 TableServiceAsyncClient 类的新实例。

DefaultAzureCredential azureTokenCredential = new DefaultAzureCredentialBuilder()
    .build();

TableServiceAsyncClient client = new TableServiceClientBuilder()
    .endpoint("<azure-cosmos-db-table-account-endpoint>")
    .credential(credential)
    .buildAsyncClient();

此示例使用 TableAsyncClient 类的 GetTableClient 方法创建 TableServiceClient 类的实例。

TableAsyncClient table = client
    .getTableClient("<azure-cosmos-db-table-name>");

在表中创建新实体的最简单方法是使用 createEntity。

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = new TableEntity(partitionKey, rowKey)
        .addProperty("Name", "Yamba Surfboard")
        .addProperty("Quantity", 12)
        .addProperty("Price", 850.00)
        .addProperty("Sale", false);

使用 upsertEntity 在集合中创建实体。

Mono<Void> response = table.upsertEntity(entity);

可使用 getEntity 从表中检索特定实体。

String rowKey = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
String partitionKey = "gear-surf-surfboards";

TableEntity entity = table.getEntity(partitionKey, rowKey);

插入实体后，还可以使用 listEntities 和 ListEntitiesOptions 类运行查询以获取与特定筛选器匹配的所有实体。 使用 setFilter 方法指定字符串 OData 筛选器。

ListEntitiesOptions options = new ListEntitiesOptions()
    .setFilter("PartitionKey eq 'gear-surf-surfboards'");

PagedFlux<TableEntity> tableEntities = table.listEntities(options, null, null);

使用订阅分析查询的分页结果。

tableEntities
    .DoOnNext(entity -> {
        // Do something
    });

不再需要示例应用程序或资源时，请删除相应的部署和所有资源。

azd down

• .NET 快速入门
• Node.js 快速入门
• Python 快速入门
• Go 快速入门