DynamoDB C#：如何检查Book的Sections列表中是否存在指定Section？

核心思路 #

要判断指定Section的Identifier是否存在于任意Book的Sections列表中，不能直接用简单的ScanOperator.Contains（因为Sections是对象列表，需要匹配对象的属性），正确的做法是使用DynamoDB条件表达式配合contains函数，遍历列表中对象的Identifier属性进行匹配。如果数据量较大，建议通过添加反向索引来优化查询性能。

方案1：基于Scan的直接检查（适合小数据量场景） #

如果你的Book表数据量不大，可以直接用ScanAsync配合条件表达式过滤出包含目标Section的Book：

// 检查Section是否被任意Book关联的方法
public async Task<bool> IsSectionLinkedToBook(string targetSectionId)
{
    // 条件表达式：检查Sections列表中任意元素的Identifier等于目标值
    var filterExpr = "contains(Sections[*].Identifier, :targetId)";
    var attrValues = new Dictionary<string, object>
    {
        { ":targetId", targetSectionId }
    };

    var scanConfig = new ScanOperationConfig
    {
        FilterExpression = filterExpr,
        ExpressionAttributeValues = attrValues,
        // 只返回Book的主键，减少数据传输开销
        ProjectionExpression = "Identifier"
    };

    // 执行Scan并获取结果
    var matchedBooks = await _context.ScanAsync<Book>(scanConfig).GetRemainingAsync();
    
    // 存在匹配结果即说明Section已关联
    return matchedBooks.Any();
}

删除前的校验逻辑 #

在执行删除操作前调用上述方法即可：

string sectionToDeleteId = "your-section-id";

// 先校验关联关系
if (await IsSectionLinkedToBook(sectionToDeleteId))
{
    // 提示用户无法删除
    Console.WriteLine("该章节已被书籍关联，无法删除");
    return;
}

// 校验通过，执行删除
await _context.DeleteAsync<Section>(sectionToDeleteId);

方案2：基于GSI的优化查询（适合大数据量场景） #

如果Book表数据量较大，全表Scan的效率会很低，建议通过添加反向索引来优化：

1. 修改Book实体类

新增一个仅存储Section Identifier的列表，用于创建全局二级索引（GSI）：

[DynamoDBTable("Book")]
public class Book
{
    [DynamoDBHashKey]
    public string Identifier { get; set; }
    public List<Section> Sections { get; set; }
    // 新增：仅存储Section的ID，用于GSI索引
    public List<string> SectionIds { get; set; }
}

2. 创建GSI

在DynamoDB控制台或通过代码给Book表创建GSI：

• 索引名称：SectionIds-index
• 分区键（Partition Key）：SectionIds（DynamoDB会自动为列表中的每个ID生成索引条目）

3. 优化后的查询方法

通过GSI进行Query查询，效率远高于全表Scan：

public async Task<bool> IsSectionLinkedToBook(string targetSectionId)
{
    var queryConfig = new QueryOperationConfig
    {
        IndexName = "SectionIds-index", // 你的GSI名称
        KeyConditionExpression = "SectionIds = :targetId",
        ExpressionAttributeValues = new Dictionary<string, object>
        {
            { ":targetId", targetSectionId }
        },
        ProjectionExpression = "Identifier"
    };

    var matchedBooks = await _context.QueryAsync<Book>(queryConfig).GetRemainingAsync();
    
    return matchedBooks.Any();
}

注意事项

• 维护SectionIds列表时，要确保在添加/删除Book中的Section时同步更新该列表，保证数据一致性。

为什么你之前的Scan操作失败？ #

你之前尝试的Scan可能是直接使用ScanOperator.Contains传入sectionId，但这种写法只会匹配列表中完全等于sectionId的元素，而你的Sections是对象列表，需要通过路径表达式Sections[*].Identifier指定要匹配的对象属性，配合contains函数才能正确判断。

内容的提问来源于stack exchange，提问作者André Felipe