DynamoDB Java SDK QueryRequest使用IN子句遇语法错误求助

常见错误原因 #

• ExpressionAttributeValues的键格式错误：键必须是以冒号开头的字符串，不能添加引号，也不能省略冒号
• IN子句的表达式写法错误：IN后面的括号内需要列出对应每个值的占位符，不能直接使用单个列表类型的占位符
• 占位符与ExpressionAttributeValues中的键不匹配

正确实现代码示例 #

import software.amazon.awssdk.services.dynamodb.DynamoDbClient;
import software.amazon.awssdk.services.dynamodb.model.*;
import java.util.HashMap;
import java.util.Map;

public class DynamoDbQueryInDemo {
    public static void main(String[] args) {
        try (DynamoDbClient ddbClient = DynamoDbClient.create()) {
            // 待查询的目标值列表
            String[] targetIds = {"user_001", "user_002", "user_003"};

            // 构建表达式属性值和IN子句
            Map<String, AttributeValue> attrValues = new HashMap<>();
            StringBuilder inClauseBuilder = new StringBuilder("UserID IN (");
            
            for (int i = 0; i < targetIds.length; i++) {
                String placeholder = ":id" + i;
                // 为每个值创建对应的占位符和属性值
                attrValues.put(placeholder, AttributeValue.builder().s(targetIds[i]).build());
                inClauseBuilder.append(placeholder);
                if (i != targetIds.length - 1) {
                    inClauseBuilder.append(", ");
                }
            }
            inClauseBuilder.append(")");

            // 构建QueryRequest
            QueryRequest queryRequest = QueryRequest.builder()
                    .tableName("UserTable")
                    // 必须指定分区键条件，Query操作必须基于分区键
                    .keyConditionExpression("PartitionKey = :partitionVal")
                    // 将IN子句作为过滤条件
                    .filterExpression(inClauseBuilder.toString())
                    // 添加所有表达式属性值
                    .expressionAttributeValues(attrValues)
                    // 补充分区键的占位符值
                    .expressionAttributeValues(attrs -> attrs.put(":partitionVal", AttributeValue.builder().s("user_group_01").build()))
                    .build();

            // 执行查询并处理结果
            QueryResponse response = ddbClient.query(queryRequest);
            response.items().forEach(item -> System.out.println("查询到的条目: " + item));
        } catch (DynamoDbException e) {
            System.err.println("查询失败: " + e.getMessage());
            System.exit(1);
        }
    }
}

核心注意事项 #

• 分区键必填：Query操作必须指定分区键的匹配条件，IN子句只能作为filterExpression过滤查询结果，不能用于替代分区键条件
• 占位符规范：所有表达式中的占位符必须以冒号开头，且与expressionAttributeValues中的键完全一致（包括冒号），不能给键添加引号
• IN子句格式：IN括号内需要逐个列出对应每个值的占位符，用逗号分隔，不能直接传入列表类型的属性值

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