编写C# POST API操作Azure Cosmos DB，求指定用户最高值的简洁SQL

嘿，针对你这个用C#写POST API、批量获取指定UserID对应最大Value记录的需求，我有个更简洁高效的方案，用Cosmos DB支持的窗口函数就能一次性搞定，不用折腾多次查询或者复杂的IN拼接~

核心思路 #

我们需要给每个UserID的记录按Value降序排号，然后只取每个UserID的第一条记录（也就是Value最大的那条）。用ROW_NUMBER()窗口函数可以轻松实现这个逻辑，同时结合参数化查询安全处理请求体里的UserID列表。

优化后的SQL查询 #

SELECT c.userid, c.value, c.Date
FROM (
    SELECT *,
           -- 按userid分区，每个分区内按value转数字后降序排，给每条记录编号
           ROW_NUMBER() OVER (PARTITION BY c.userid ORDER BY TO_NUMBER(c.value) DESC) AS rn
    FROM c
    -- 过滤指定的userid列表
    WHERE c.userid IN (@userIds)
) AS sub
-- 只取每个分区的第一条记录（rn=1就是value最大的那条）
WHERE sub.rn = 1

关键提醒：

你的示例里value是字符串类型（比如"10"），直接按字符串排序会出现逻辑错误（比如"100"会比"20"小），所以用TO_NUMBER()转成数字再排序更准确。如果你的value实际存储的是数字类型，可以去掉TO_NUMBER()，直接用c.value排序。

结合C# POST API的实现代码 #

这里给你写好完整的参数化查询示例，既简洁又能避免SQL注入：

// 定义请求体的模型
public class UserIdRequestItem
{
    public string userid { get; set; }
}

// API接口方法
[HttpPost]
public async Task<IActionResult> GetMaxValueRecords([FromBody] List<UserIdRequestItem> requestBody)
{
    // 提取请求体里的userid列表
    var targetUserIds = requestBody.Select(item => item.userid).ToList();
    if (!targetUserIds.Any())
    {
        return BadRequest("请提供有效的UserID列表");
    }

    // 构建参数化查询
    var queryDefinition = new QueryDefinition(@"
        SELECT c.userid, c.value, c.Date
        FROM (
            SELECT *,
                   ROW_NUMBER() OVER (PARTITION BY c.userid ORDER BY TO_NUMBER(c.value) DESC) AS rn
            FROM c
            WHERE c.userid IN (@userIds)
        ) AS sub
        WHERE sub.rn = 1
    ").WithParameter("@userIds", targetUserIds);

    // 获取Cosmos DB容器（这里需要你注入CosmosClient实例）
    var container = _cosmosClient.GetContainer("你的数据库名", "你的容器名");
    var queryIterator = container.GetItemQueryIterator<dynamic>(queryDefinition);

    var results = new List<dynamic>();
    while (queryIterator.HasMoreResults)
    {
        var response = await queryIterator.ReadNextAsync();
        results.AddRange(response.Resource);
    }

    return Ok(results);
}

为什么这个方案更好？ #

• 一次查询搞定所有UserID的需求，相比循环查询每个UserID，性能提升明显
• 参数化查询更安全，避免SQL注入风险
• 逻辑清晰易维护，后续如果要调整排序规则（比如优先按Date排序），只需要修改窗口函数的ORDER BY部分就行

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