DynamoDB含PK与SK时，能否仅按前缀查询PK？Java查询报错求助

核心结论 #

当表同时拥有分区键（PK）和排序键（SK）时，无法通过原生Query操作直接查询PK以指定前缀开头的记录——因为Query操作要求KeyConditionExpression必须包含PK的精确匹配（=），仅允许对SK使用begins_with这类范围操作符。你代码的语法错误正是因为违反了这条规则。

可行解决方案 #

方案1：使用Scan+FilterExpression（适合小数据集） #

Scan会遍历全表，再通过过滤条件筛选出符合PK前缀要求的记录。注意：数据量大时，Scan的性能和成本都会显著上升，不推荐用于大规模数据集。

修正后的代码示例：

Map<String, String> expressionAttributeNames = new HashMap<>();
expressionAttributeNames.put("#pk", "pk");
Map<String, AttributeValue> expressionAttributeValues = new HashMap<>();
expressionAttributeValues.put(":prefix", new AttributeValue().withS("abc"));

ScanRequest scanRequest = new ScanRequest()
    .withTableName(tableName)
    .withFilterExpression("begins_with(#pk, :prefix)")
    .withExpressionAttributeNames(expressionAttributeNames)
    .withExpressionAttributeValues(expressionAttributeValues);

// 执行扫描请求
ScanResult result = dynamoDB.scan(scanRequest);

方案2：通过全局二级索引（GSI）实现高效查询（推荐） #

重新设计索引，创建一个GSI：将原表的PK作为GSI的排序键，同时给GSI设置一个固定值的分区键（比如"ALL_RECORDS"）。这样就可以通过Query这个GSI，结合固定的GSI分区键值，对GSI的排序键（原表PK）使用begins_with做前缀查询。

步骤说明

1. 创建或更新表，添加GSI（示例定义）：

   • GSI分区键：gsi_pk（字符串类型，固定值为"ALL"）
   • GSI排序键：pk（与原表PK一致）
   • GSI名称：PKPrefixIndex（自定义名称）

2. 查询代码示例：

Map<String, String> expressionAttributeNames = new HashMap<>();
expressionAttributeNames.put("#gsi_pk", "gsi_pk");
expressionAttributeNames.put("#original_pk", "pk");
Map<String, AttributeValue> expressionAttributeValues = new HashMap<>();
expressionAttributeValues.put(":gsi_pk_val", new AttributeValue().withS("ALL"));
expressionAttributeValues.put(":prefix", new AttributeValue().withS("abc"));

QueryRequest queryRequest = new QueryRequest()
    .withTableName(tableName)
    .withIndexName("PKPrefixIndex") // 替换为你的GSI名称
    .withKeyConditionExpression("#gsi_pk = :gsi_pk_val AND begins_with(#original_pk, :prefix)")
    .withExpressionAttributeNames(expressionAttributeNames)
    .withExpressionAttributeValues(expressionAttributeValues);

// 执行查询请求
QueryResult result = dynamoDB.query(queryRequest);

内容的提问来源于stack exchange，提问作者HellGuoan