如何基于用户输入动态构造Java DynamoDB Mapper的Query查询表达式

解决方案 #

你可以通过动态遍历用户传入的筛选参数，自动拼接过滤表达式、填充属性值映射来实现优雅的动态查询构造，不需要硬编码每个参数，同时兼容零个到任意多个筛选条件的场景。

以下是可直接复用的实现代码：

// 入参filterParams为用户传入的筛选键值对，key为DynamoDB表字段名，value为筛选值
public DynamoDBQueryExpression<RequestModel> buildDynamicQuery(String appName, Map<String, Object> filterParams) {
    // 1. 初始化属性值映射，先写入必填的分区键参数
    Map<String, AttributeValue> eav = new HashMap<>();
    eav.put(":appNameVal", new AttributeValue().withS(appName));

    // 2. 固定写入分区键查询条件
    String keyCondition = "appName = :appNameVal";
    StringBuilder filterExpressionBuilder = new StringBuilder();
    int paramIndex = 0;

    // 3. 遍历筛选参数动态拼接过滤条件
    for (Map.Entry<String, Object> entry : filterParams.entrySet()) {
        String fieldName = entry.getKey();
        Object fieldValue = entry.getValue();
        // 跳过空值，可根据业务规则调整
        if (fieldValue == null) {
            continue;
        }
        // 多条件自动拼接AND
        if (filterExpressionBuilder.length() > 0) {
            filterExpressionBuilder.append(" AND ");
        }
        String placeholder = ":filter" + paramIndex;
        filterExpressionBuilder.append(fieldName).append(" = ").append(placeholder);
        // 根据值类型自动生成对应AttributeValue，可扩展支持布尔、列表等其他类型
        if (fieldValue instanceof String) {
            eav.put(placeholder, new AttributeValue().withS((String) fieldValue));
        } else if (fieldValue instanceof Number) {
            eav.put(placeholder, new AttributeValue().withN(String.valueOf(fieldValue)));
        }
        paramIndex++;
    }

    // 4. 构造最终查询表达式
    DynamoDBQueryExpression<RequestModel> queryExpression = new DynamoDBQueryExpression<RequestModel>()
            .withKeyConditionExpression(keyCondition)
            .withExpressionAttributeValues(eav);
    // 仅当存在筛选条件时才设置过滤表达式，避免空表达式报错
    if (filterExpressionBuilder.length() > 0) {
        queryExpression.withFilterExpression(filterExpressionBuilder.toString());
    }
    return queryExpression;
}

扩展说明 #

• 如果需要支持不等于、大于、小于等非等值匹配，只需要调整入参结构，把操作符和值一起传入，拼接表达式的时候替换掉固定的=即可
• 如果筛选参数包含排序键requestId，建议单独判断把排序键条件放入KeyConditionExpression，相比放在FilterExpression可以大幅降低读容量消耗
• 注意字段名要和你表结构的字段名、或者RequestModel中DynamoDB注解指定的字段名保持一致

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