Kotlin：如何正确过滤含指定ID内部列表的对象并映射至领域模型？

一、代码层面修正过滤逻辑 #

首先必须确保数据库中存储的JSON格式内部列表已正确反序列化为可操作的对象/字典列表（比如Java的List<TaskCategory>、Python的list[dict]），反序列化失败会直接导致后续过滤逻辑失效。

Java示例代码 #

假设数据库实体类为DbTask，内部包含List<TaskCategory> categories，目标是过滤出categories中包含指定targetCategoryId的对象，再映射到领域模型Task：

// 从数据库获取原始对象列表
List<DbTask> dbTasks = yourDatabaseQueryMethod();

// 正确过滤：先判空再检查内部列表是否存在匹配ID的元素
List<DbTask> filteredTasks = dbTasks.stream()
    .filter(dbTask -> dbTask.getCategories() != null 
        && dbTask.getCategories().stream()
            .anyMatch(category -> targetCategoryId.equals(category.getId())))
    .collect(Collectors.toList());

// 映射到领域模型Task
List<Task> tasks = filteredTasks.stream()
    .map(this::convertToTask) // 实现自定义的实体转领域模型逻辑
    .collect(Collectors.toList());

常见错误点：

• 未做非空判断：categories为null时直接调用stream会抛出空指针异常
• 匹配逻辑错误：误用allMatch（要求所有元素匹配）而非anyMatch（只要存在匹配元素），或ID类型不匹配（比如字符串与数字直接比较）

Python示例代码 #

假设数据库返回字典列表，categories字段已反序列化为Python列表：

target_category_id = "你的目标ID"
# 从数据库获取的原始数据
db_tasks = your_database_query_function()

# 过滤逻辑：检查categories中是否存在ID匹配的项
filtered_tasks = [
    task for task in db_tasks
    if task.get("categories") and any(
        cat.get("id") == target_category_id for cat in task["categories"]
    )
]

# 映射到Task领域模型
tasks = [convert_to_task(task) for task in filtered_tasks]

二、数据库查询阶段处理更高效 #

由于内部列表以JSON格式存储，在数据库层面过滤确实更简便且性能更优——无需将大量不符合条件的数据加载到应用内存，大幅减少IO和内存开销。不同数据库的实现方式如下：

MySQL（JSON类型字段） #

假设表名为tasks，JSON字段为categories，存储格式为[{"id":"1"},{"id":"2"},...]，过滤包含指定ID的记录：

SELECT * FROM tasks
WHERE JSON_CONTAINS(categories, '{"id": "目标ID"}', '$');

若ID为数字类型，将JSON字符串中的"目标ID"改为数字即可（如'{"id": 123}'）。

PostgreSQL（推荐用jsonb类型字段） #

用@>操作符判断JSON数组是否包含指定元素：

SELECT * FROM tasks
WHERE categories @> '[{"id": "目标ID"}]';

如需更灵活的嵌套匹配，可通过jsonb_array_elements展开数组后过滤：

SELECT DISTINCT t.* FROM tasks t
JOIN jsonb_array_elements(t.categories) cat
ON cat->>'id' = '目标ID';

核心优势 #

• 减少数据传输：仅返回符合条件的记录，降低网络和内存消耗
• 支持索引优化：可针对JSON字段创建专用索引（如PostgreSQL的GIN索引），进一步提升查询速度

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