DynamoDB排序键前缀查询方法

文章不知道大家是否熟悉？今天我将给大家介绍《DynamoDB排序键前缀查询技巧》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

当已知DynamoDB分区键和排序键的前缀（而非完整排序键）时，可使用`QueryConditional.sortBeginsWith()`实现精准范围查询，避免全表扫描，兼顾性能与灵活性。

在DynamoDB中，query操作要求必须指定分区键（Partition Key），而排序键（Sort Key）则支持多种条件匹配方式——其中sortBeginsWith()正是解决“仅知前缀”场景的核心方法。它会匹配所有以指定字符串开头的排序键值，等价于SQL中的 WHERE pk = ? AND sk LIKE 'prefix%'，且完全利用底层LSM树索引，保持毫秒级响应。

根据你提供的实体结构：

@DynamoDbPartitionKey
public String getPk() {
    return String.format("%s#%s", "KEY", getId());
}

@DynamoDbSortKey
public String getSk() {
    return String.format("%s#%s", "KEY_SORT", getName());
}

假设 id = "23456"，则分区键为 "KEY#23456"；若你想查找所有 getName() 以 "user" 开头的记录（如 "user#abc"、"user#xyz"），对应排序键前缀即为 "KEY_SORT#user"。

✅ 正确查询代码如下：

String partitionPrefix = "KEY#" + id;           // e.g., "KEY#23456"
String sortKeyPrefix = "KEY_SORT#" + namePrefix; // e.g., "KEY_SORT#user"

QueryConditional condition = QueryConditional.sortBeginsWith(
    Key.builder()
        .partitionValue(partitionPrefix)
        .sortValue(sortKeyPrefix)
        .build()
);

QueryEnhancedRequest request = QueryEnhancedRequest.builder()
    .queryConditional(condition)
    .build();

// 执行查询（table 为 DynamoDbTable<T> 实例）
table.query(request).stream()
    .map(Page::items)
    .flatMap(List::stream)
    .forEach(System.out::println);

⚠️ 注意事项：

• sortBeginsWith() 必须与分区键联合使用，不可单独用于全局二级索引（GSI）或作为唯一条件；
• 排序键值需严格按字典序存储，确保前缀匹配逻辑符合预期（例如 "KEY_SORT#user1" 和 "KEY_SORT#user10" 均会被匹配，但 "KEY_SORT#users" 不会，除非显式包含）；
• 若前缀过短（如仅 "KEY_SORT#"），可能导致返回大量结果，建议结合 limit() 或分页（lastEvaluatedKey）控制负载；
• 确保表结构中定义的 @DynamoDbSortKey 字段类型与实际写入值一致，避免因空格、大小写或编码差异导致匹配失败。

总结：sortBeginsWith() 是 DynamoDB 高效查询的利器，特别适用于层级化、命名空间化或时间戳前缀等常见设计模式。只要合理设计排序键格式（如 TYPE#ID#TIMESTAMP），即可通过灵活的前缀查询实现复杂业务语义，无需降级为低效的 scan 操作。

理论要掌握，实操不能落！以上关于《DynamoDB排序键前缀查询方法》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！