如何编写Cosmos DB查询语句获取commonId=123下QuestionType=1的Answer列表

问题原因 #

你原来的查询无法生效有两个核心问题：

1. Answers是文档内的嵌套数组，无法直接通过点语法c.Answers.QuestionType访问数组内元素的属性，必须先通过Cosmos DB的JOIN语法展平数组，才能对数组内元素做过滤和属性提取。
2. 数据类型不匹配：你存储的commonId和QuestionType都是字符串类型，原查询里直接写数字123、1会因为类型不一致无法匹配到数据。

正确实现方式 #

方式1：SQL查询实现 #

你可以用参数化查询避免硬编码和类型匹配问题，以下是正确的SQL语句和C#代码：

查询SQL（逐行返回符合条件的Answer）

SELECT ans.Answer[0] AS AnswerValue
FROM c
JOIN ans IN c.Answers
WHERE c.commonId = @commonId 
AND ans.QuestionType = @questionType

如果你需要直接返回单个汇总数组，可以用内置的ARRAY函数：

SELECT ARRAY(
    SELECT ans.Answer[0]
    FROM ans IN c.Answers
    WHERE ans.QuestionType = @questionType
) AS AnswerList
FROM c
WHERE c.commonId = @commonId

完整C#代码

// 采用参数化查询更安全规范
string sqlQueryText = @"
SELECT ans.Answer[0] AS AnswerValue
FROM c
JOIN ans IN c.Answers
WHERE c.commonId = @commonId 
AND ans.QuestionType = @questionType
";

QueryDefinition queryDefinition = new QueryDefinition(sqlQueryText)
    .WithParameter("@commonId", "123")
    .WithParameter("@questionType", "1");

List<string> resultAnswers = new List<string>();
// 迭代处理所有分页结果
using FeedIterator<dynamic> queryIterator = cosmosContainer.GetItemQueryIterator<dynamic>(queryDefinition);
while (queryIterator.HasMoreResults)
{
    FeedResponse<dynamic> currentPage = await queryIterator.ReadNextAsync();
    foreach (var item in currentPage)
    {
        resultAnswers.Add(item.AnswerValue.ToString());
    }
}
// resultAnswers 就是最终汇总的Answer字符串列表

方式2：LINQ查询实现 #

如果你不想手写SQL，也可以用Cosmos DB的LINQ provider实现，先定义对应的数据实体：

// 对应你的文档结构
public class SurveyDocument
{
    public string commonId { get; set; }
    public List<AnswerEntry> Answers { get; set; }
}

public class AnswerEntry
{
    public string QuestionType { get; set; }
    public List<string> Answer { get; set; }
}

然后编写LINQ查询即可：

using FeedIterator<string> linqIterator = cosmosContainer.GetItemLinqQueryable<SurveyDocument>()
    .Where(doc => doc.commonId == "123")
    // 展平Answers数组
    .SelectMany(doc => doc.Answers)
    // 过滤QuestionType为1的条目
    .Where(entry => entry.QuestionType == "1")
    // 提取Answer数组的第一个元素（你的数据中每个Answer数组只有1个值）
    .Select(entry => entry.Answer.First())
    .ToFeedIterator();

List<string> resultAnswers = new List<string>();
while (linqIterator.HasMoreResults)
{
    FeedResponse<string> currentPage = await linqIterator.ReadNextAsync();
    resultAnswers.AddRange(currentPage);
}

注意事项 #

如果你的Answer数组可能存在多个值，把上述代码中的ans.Answer[0]/entry.Answer.First()替换为对应的展平逻辑即可。

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