# 适用于 Java 的 Azure 表 SDK 使用适用于 Java 的 Azure Tables SDK 构建表存储应用程序。可与 Azure 表存储和 Cosmos DB 表 API 配合使用。 ## 安装 <依赖关系> com.azure azure-data-tables <版本>12.6.0-beta.1 ## 客户端创建 ### 带连接字符串导入 com.azure.data.tables.TableServiceClient; 导入 com.azure.data.tables.TableServiceClientBuilder; 导入 com.azure.data.tables.TableClient; TableServiceClient serviceClient = new TableServiceClientBuilder() .connectionString("<您的连接字符串>") .buildClient(); ### 使用共享密钥导入 com.azure.core.credential.AzureNamedKeyCredential; AzureNamedKeyCredential 凭据 = 新的 AzureNamedKeyCredential( “<帐户名称>”， “<帐户密钥>”）； TableServiceClient serviceClient = new TableServiceClientBuilder() .endpoint("") .凭证（凭证） .buildClient(); ### 使用 SAS 令牌 TableServiceClient serviceClient = new TableServiceClientBuilder() .endpoint("") .sasToken("") .buildClient(); ### 使用 DefaultAzureCredential（仅限存储）导入 com.azure.identity.DefaultAzureCredentialBuilder； TableServiceClient serviceClient = new TableServiceClientBuilder() .endpoint("") .credential(new DefaultAzureCredentialBuilder().build()) .buildClient(); ## 关键概念 * **TableServiceClient** ：管理表（创建、列出、删除） * **TableClient** ：管理表中的实体（CRUD） * **分区键** ：对实体进行分组以实现高效查询 * **行键** ：分区内的唯一标识符 * **Entity** ：最多具有 252 个属性的行（1MB 存储、2MB Cosmos） ## 核心模式 ### 创建表 // 创建表（如果存在则抛出） TableClient tableClient = serviceClient.createTable("mytable"); // 如果不存在则创建（也不例外） TableClient tableClient = serviceClient.createTableIfNotExists("mytable"); ### 获取表客户端 // 来自服务客户端 TableClient tableClient = serviceClient.getTableClient("mytable"); // 直接构造 TableClient tableClient = new TableClientBuilder() .connectionString("<连接字符串>") .tableName("mytable") .buildClient(); ### 创建实体导入 com.azure.data.tables.models.TableEntity; TableEntity 实体 = new TableEntity("partitionKey", "rowKey") .addProperty("名称","产品A") .addProperty("价格", 29.99) .addProperty("数量", 100) .addProperty("IsAvailable", true); tableClient.createEntity(实体); ### 获取实体 TableEntity实体 = tableClient.getEntity("partitionKey", "rowKey"); 字符串名称=（字符串）entity.getProperty（“名称”）; 双倍价格 = (Double)entity.getProperty("价格"); System.out.printf("产品：%s，价格：%.2f%n"，名称，价格); ### 更新实体导入 com.azure.data.tables.models.TableEntityUpdateMode; // 合并（仅更新指定属性） TableEntity updateEntity = new TableEntity("partitionKey", "rowKey") .addProperty("价格", 24.99); tableClient.updateEntity(updateEntity, TableEntityUpdateMode.MERGE); // 替换（替换整个实体） TableEntity ReplaceEntity = new TableEntity("partitionKey", "rowKey") .addProperty("名称", "产品 A 已更新") .addProperty("价格", 24.99) .addProperty("数量", 150); tableClient.updateEntity(replaceEntity, TableEntityUpdateMode.REPLACE); ### 更新插入实体 // 插入或更新（合并模式） tableClient.upsertEntity(实体, TableEntityUpdateMode.MERGE); // 插入或替换 tableClient.upsertEntity(实体, TableEntityUpdateMode.REPLACE); ### 删除实体 tableClient.deleteEntity("partitionKey", "rowKey"); ### 列出实体导入 com.azure.data.tables.models.ListEntitiesOptions; // 列出所有实体 for (TableEntity 实体: tableClient.listEntities()) { System.out.printf("%s - %s%n", 实体.getPartitionKey(), 实体.getRowKey()); } // 带有过滤和选择 ListEntitiesOptions 选项 = new ListEntitiesOptions() .setFilter("PartitionKey eq '销售'") .setSelect("名称", "价格"); for (TableEntity 实体: tableClient.listEntities(options, null, null)) { System.out.printf("%s: %.2f%n", 实体.getProperty("名称"), entity.getProperty("价格")); } ### 使用 OData 过滤器查询 // 按分区键过滤 ListEntitiesOptions 选项 = new ListEntitiesOptions() .setFilter("PartitionKey eq '电子产品'"); // 多条件过滤 options.setFilter("PartitionKey eq '电子产品' 且价格 gt 100"); // 使用比较运算符进行过滤 options.setFilter("数量 ge 10 和数量 le 100"); // 前 N 个结果选项.setTop(10); for (TableEntity 实体: tableClient.listEntities(options, null, null)) { System.out.println(entity.getRowKey()); } ### 批量操作（事务）导入 com.azure.data.tables.models.TableTransactionAction; 导入 com.azure.data.tables.models.TableTransactionActionType; 导入java.util.Arrays； // 所有实体必须具有相同的分区键 List actions = Arrays.asList( 新的表事务操作（表事务操作类型.CREATE, new TableEntity("batch", "row1").addProperty("名称", "项目 1")), 新的表事务操作（表事务操作类型.CREATE, new TableEntity("batch", "row2").addProperty("名称", "项目 2")), 新的表事务操作（ TableTransactionActionType.UPSERT_MERGE, new TableEntity("batch", "row3").addProperty("名称", "项目 3")) ）； tableClient.submitTransaction(actions); ### 列表表导入 com.azure.data.tables.models.TableItem; 导入 com.azure.data.tables.models.ListTablesOptions; // 列出所有表 for (TableItem 表: serviceClient.listTables()) { System.out.println(table.getName()); } // 过滤表 ListTablesOptions 选项 = new ListTablesOptions() .setFilter("表名 eq 'mytable'"); for (TableItem 表: serviceClient.listTables(options, null, null)) { System.out.println(table.getName()); } ### 删除表 serviceClient.deleteTable("mytable"); ## 类型实体公共类 Product 实现 TableEntity { 私有字符串分区键；私有字符串行键；私有 OffsetDateTime 时间戳；私有字符串电子标签；私有字符串名称；私人双价； // 所有字段的 getter 和 setter @覆盖公共字符串 getPartitionKey() { 返回partitionKey; } @覆盖公共无效 setPartitionKey（字符串分区键） { this.partitionKey = 分区键； } @覆盖公共字符串 getRowKey() { 返回 rowKey; } @覆盖公共无效 setRowKey(String rowKey) { this.rowKey = rowKey; } // ...其他 getter/setter 公共字符串 getName() { 返回名称; } public void setName(String name) { this.name = name; } } 公共双 getPrice() { 返回价格; } 公共无效 setPrice(双倍价格) { this.price = 价格; } } // 用法产品产品 = 新产品(); 产品.setPartitionKey(“电子产品”); 产品.setRowKey(“笔记本电脑-001”); 产品.setName("笔记本电脑"); 产品.setPrice(999.99); tableClient.createEntity(产品); ## 错误处理导入 com.azure.data.tables.models.TableServiceException; 尝试{ tableClient.createEntity(实体); } catch (TableServiceException e) { System.out.println("状态：" + e.getResponse().getStatusCode()); System.out.println("错误：" + e.getMessage()); // 409 = 冲突（实体存在） // 404 = 未找到 } ## 环境变量 # 存储账户 AZURE_TABLES_CONNECTION_STRING=DefaultEndpointsProtocol=https;AccountName=... AZURE_TABLES_ENDPOINT=https://<帐户>.table.core.windows.net # Cosmos DB 表 API COSMOS_TABLE_ENDPOINT=https://<帐户>.table.cosmosdb.azure.com ## 最佳实践 1. **分区键设计**：选择均匀分配负载的键 2. **批量操作**：使用事务进行原子多实体更新 3. **查询优化**：尽可能按PartitionKey过滤 4. **选择投影** ：仅选择性能所需的属性 5. **实体大小**：将实体保持在 1MB（存储）或 2MB（Cosmos）以下 ## 触发短语 *“Azure 表 Java” * “表格存储SDK” *“Cosmos DB 表 API” *“NoSQL键值存储” *“分区键行键” *“表实体增删改查” ## 何时使用此技能适用于执行概述中描述的工作流程或操作。

Azure 数据表 Java

包含技能