C# 使用 Upsert 更新 Azure Cosmos Db json 项目

Question

我（CosmosDb 的新手）正在尝试更新 Azure Cosmos 数据库中的项目，但它正在插入。

发送的对象是

public class Bank
{
    public string id { get; set; }
    public string Code { get; set; }
    public string Name { get; set; }
}

我尝试仅传递回代码和名称值（即我没有在对象中包含 id，这会导致插入（我想要更新）。

我现在包含会导致错误的 id。

返回的错误是：

ResourceType Document 是意外的。 ActivityId：a0d50426-c556-4b17-9646-93052699026e，Windows/10.0.19044 documentdb-netcore-sdk/2.16.2

因此，前端更新后的值（仅更改名称值）为：

Code: "FNB"
Name: "aa First Update Test"
id:   "d76ade3d-7d02-46e5-a458-e9f0781bf044"

DAL 代码：

var documentUri = UriFactory.CreateDocumentUri(DBName, "Banks", bank.Code);
try
{
    Document doc = await client.UpsertDocumentAsync(documentUri, bank);
}

如何更新？

TIA

Answer 1

您的代码不清楚并且没有足够的信息。请尝试这些功能。

protected DataContext(string endpointUrl, string databaseId,   
                      string masterKey)  
{  
    _databaseId = databaseId;  
    _masterKey = masterKey;  
  
    _databaseUri = UriFactory.CreateDatabaseUri(_databaseId);  
  
    this._client = new DocumentClient(new Uri(endpointUrl), _masterKey);  
  
    this._client.CreateDatabaseIfNotExistsAsync(new Database   
      { Id = _databaseId });  
  
    this._client.CreateDocumentCollectionIfNotExistsAsync(  
      UriFactory.CreateDatabaseUri(_databaseId),   
      new DocumentCollection { Id = CollectionId });  
  
    _databaseCollectionUri = UriFactory.CreateDocumentCollectionUri(  
      _databaseId, CollectionId);  
}  

插入和更新；

public async Task<Document> UpsertDocumentAsync(T entity)  
{  
    var result = await this._client.UpsertDocumentAsync(  
    _databaseCollectionUri, entity);  
    return result;  
}  

使用或尝试使用 nuget Microsoft.Azure.Cosmos

 string cosmosDbConnectionString = CosmosDbConnectionKey;
                CosmosClient cosmosClient = new CosmosClient(cosmosDbConnectionString);
                var db = CosmosDbNameKey;
                var container = ContainerKey;
                await container.UpsertItemAsync(Model, new PartitionKey(Model.PK));

Answer 2

我需要的是Upsert中的DocumentCollection（DocumentCollection Link），但我有Document Link（documentUri）
所以，

    public async Task<ExBool> UpdateAsyncPOCO(Bank bank)
    {
        
        //  NB:  UpsertDocumentAsync should take the DocumentCollection link, instead of Document link.
        // This is a DocumentLink
        var documentUri = UriFactory.CreateDocumentUri(DBName, "Banks", bank.Code);

        // This is a DocumentCollection
        var CollectionUri = UriFactory.CreateDocumentCollectionUri("demo", "Banks");


        try
        {
            Document doc = await client.UpsertDocumentAsync(CollectionUri, bank);
        }
        catch (Exception ex)
        {
            HandleException(ex);
        }

        return result;
    }

插入和更新现在可以完美地工作了。
更新的模型和值：

Code: "updated   FNB 2"
Name: "updated   First National Bank 22"
id: "d76ade3d-7d02-46e5-a458-e9f0781bf044"

类似地，插入

Code: "qwerty"
Name: "qwertyuiop"
id: ""