小编Jai*_*Jai的帖子

使用 Cosmos 客户端将集合中的记录数读取到控制台应用程序

我正在使用 Cosmos 客户端和 C# 从集合中删除项目。在这个过程中,我想检查集合中的记录数,我有它的数据部分和查询,但我坚持使用什么,因为我只会接收一个 int 而不是数据流。

为了删除数据,我使用 FeedIterator,因为我们得到了数据流。

FeedIterator<Order> queryResultSetIterator = this.container.GetItemQueryIterator<Order>(queryDefinition);

List<Order> orders = new List<Order>();
Run Code Online (Sandbox Code Playgroud)

我通过循环列表来删除记录

由于输出将是集合中的记录数,我应该使用什么来代替 FeedIterator?

var sqlQueryText1 = "SELECT value count(1) from c where c.tenantId = 
'5d484526d76e9653e6226aa2'";
QueryDefinition queryDefinition1 = new QueryDefinition(sqlQueryText1);
Run Code Online (Sandbox Code Playgroud)

这是我用来帮助控制台应用程序的文章: https: //learn.microsoft.com/en-us/azure/cosmos-db/sql-api-get-started

c# client cosmos azure-cosmosdb-sqlapi

5
推荐指数
1
解决办法
4662
查看次数

使用 C# 和 cosmos 客户端从 cosmos db 中删除文档

我是 Cosmos DB 的新手,在阅读了 microsoft 文档后,我试图从 Cosmos db 中删除记录。我试图尽可能地遵循这个例子。正在找到并读取记录,但在尝试删除时遇到了未找到的错误。

集合已分区,我在示例中提到了分区键,但仍然导致错误。

    private async Task QueryItemsAsync()
    {
        var sqlQueryText = "SELECT * FROM c WHERE c.tenantId = '5c6cb2d77c1c2edc001b9007' and c.id = 'abae8abf-5836-464f-8129-1f0e83a1f639'";

        QueryDefinition queryDefinition = new QueryDefinition(sqlQueryText);
        FeedIterator<Order> queryResultSetIterator = this.container.GetItemQueryIterator<Order>(queryDefinition);

        List<Order> orders = new List<Order>();

        while (queryResultSetIterator.HasMoreResults)
        {
            FeedResponse<Order> currentResultSet = await queryResultSetIterator.ReadNextAsync();
            foreach (Order o in currentResultSet)
            {
                orders.Add(o);
                Console.WriteLine("\tRead {0}\n", o);       
            }
        }
    }         
    private async Task DeleteFamilyItemAsync()
    {
        var partitionKeyValue = "tenantId";
        var orderId = "abae8abf-5836-464f-8129-1f0e83a1f639";

        // Delete …
Run Code Online (Sandbox Code Playgroud)

c# delete-row azure-cosmosdb azure-cosmosdb-sqlapi

2
推荐指数
1
解决办法
3949
查看次数