我正在尝试更新我的数据库中的特定产品。我从body传递产品值并替换它,我的分区键是catlog id.blow,我给出了我所有的代码示例,请告诉我我哪里错了?
Json body:
{
"id": "9fc41e97-c32e-45e6-853f-ae7993cbc773",
"VendorName": "string",
"Industy": {
"Id": "40f5a6f5-2947-469c-8d29-6aa84de982cb",
"IdustryId": 0,
"IdustryName": "string",
"Category": {
"id": "bf16c9a1-52c6-4e88-b24a-082591718ece",
"Name": "string",
"Description": "string",
"Subcategory": {
"id": "c60a191a-f5b8-4cff-8926-e4b364f8aba2",
"Name": "string",
"Description": "string",
"Product": {
"Id": "97c27069-4a16-44c3-bdf1-627c8ea339fa",
"Name": "string",
"CurrentQuantity": 0,
"Tag": "string",
"Unit": "string",
"Price": 0,
"hasMethodOfPreparation": true,
"Addons": {
"id": "1b7afbc0-36df-4a97-951e-4f0fef0c683f",
"Description": "string",
"Price": 0
},
"MethodOfPreparation": {
"id": "9e1581cf-8401-44c0-ac8b-15e972276178",
"Description": "string",
"Price": 0
}
}
}
}
}
控制器代码:
[HttpPut("UpdateProductByIdAsync/{id}", Name = "UpdateProductById")]
public async Task<IActionResult> UpdateProductByIdAsync(
[FromRoute] Guid id,
[FromBody] Product order)
{
if (!ModelState.IsValid)
{
return BadRequest(ModelState);
}
if (id == null
|| id == Guid.Empty)
{
return BadRequest("Id required.");
}
order.Id = id;
var result =
await _catalogRepository.UpdateProductByIdAsync(
id,
order);
return Ok(result);
}
存储库
public async Task<Catalog> UpdateProductByIdAsync(
Guid id,
Product order)
{
var requestOptions =
new RequestOptions
{
PartitionKey = new Microsoft.Azure.Documents.PartitionKey(id.ToString())
};
var catalogDocument = await _cosmosClient.ReplaceDocumentAsync(
UriFactory.CreateDocumentCollectionUri(
_azureCosmosDbOptions.Value.DatabaseId, "catalog"), order, requestOptions);
return
(Catalog)((dynamic)catalogDocument.Resource);
}
}
错误:
<pre class="rawExceptionStackTrace">Microsoft.Azure.Documents.BadRequestException: ResourceType Document is unexpected.
ActivityId: 62f61852-d2a7-466a-9765-80db1d02de32, Windows/10.0.17134 documentdb-netcore-sdk/2.4.0
 at Microsoft.Azure.Documents.PathsHelper.GeneratePathForNameBased(ResourceType resourceType, String resourceFullName, Boolean isFeed, Boolean notRequireValidation)
 at Microsoft.Azure.Documents.GatewayStoreModel.GetEntityUri(DocumentServiceRequest entity)
 at Microsoft.Azure.Documents.GatewayStoreModel.ProcessMessageAsync(DocumentServiceRequest request, CancellationToken cancellationToken)
 at Microsoft.Azure.Documents.Client.DocumentClient.ProcessRequestAsync(DocumentServiceRequest request, IDocumentClientRetryPolicy retryPolicyInstance, CancellationToken cancellationToken)
 at Microsoft.Azure.Documents.Client.DocumentClient.ReplaceDocumentPrivateAsync(String documentLink, Document document, RequestOptions options, IDocumentClientRetryPolicy retryPolicyInstance, CancellationToken cancellationToken)
 at Microsoft.Azure.Documents.BackoffRetryUtility`1.ExecuteRetryAsync(Func`1 callbackMethod, Func`3 callShouldRetry, Func`1 inBackoffAlternateCallbackMethod, TimeSpan minBackoffForInBackoffCallback, CancellationToken cancellationToken, Action`1 preRetryCallback)
 at Microsoft.Azure.Documents.ShouldRetryResult.ThrowIfDoneTrying(ExceptionDispatchInfo capturedException)
 at Microsoft.Azure.Documents.BackoffRetryUtility`1.ExecuteRetryAsync(Func`1 callbackMethod, Func`3 callShouldRetry, Func`1 inBackoffAlternateCallbackMethod, TimeSpan minBackoffForInBackoffCallback, CancellationToken cancellationToken, Action`1 preRetryCallback)
 at Microsoft.Azure.Documents.Client.DocumentClient.ReplaceDocumentInlineAsync(String documentLink, Object document, RequestOptions options, CancellationToken cancellationToken)
 at CatalogAPI.Services.CatalogRepository.UpdateProductByIdAsync(Guid id, Product order) in D:\UCDP\UCDP\UCDP\src\Service\Catalog\CatalogAPI\Services\CatalogRepository.cs:line 322
 at CatalogAPI.Controllers.CatalogController.UpdateProductByIdAsync(Guid id, Product order) in D:\UCDP\UCDP\UCDP\src\Service\Catalog\CatalogAPI\Controllers\CatalogController.cs:line 158
 at Microsoft.AspNetCore.Mvc.Internal.ActionMethodExecutor.TaskOfIActionResultExecutor.Execute(IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments)
 at System.Threading.Tasks.ValueTask`1.get_Result()
 at Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.InvokeActionMethodAsync()
 at Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.InvokeNextActionFilterAsync()
 at Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.Rethrow(ActionExecutedContext context)
 at Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted)
 at Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker.InvokeInnerFilterAsync()
 at Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeNextResourceFilter()
 at Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.Rethrow(ResourceExecutedContext context)
 at Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted)
 at Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeFilterPipelineAsync()
 at Microsoft.AspNetCore.Mvc.Internal.ResourceInvoker.InvokeAsync()
 at Microsoft.AspNetCore.Routing.EndpointMiddleware.Invoke(HttpContext httpContext)
 at Microsoft.AspNetCore.Routing.EndpointRoutingMiddleware.Invoke(HttpContext httpContext)
 at Microsoft.AspNetCore.StaticFiles.StaticFileMiddleware.Invoke(HttpContext context)
 at Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext)
 at Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke(HttpContext httpContext, ISwaggerProvider swaggerProvider)
 at Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext context)</pre>
请帮我完成这个任务,.I尝试了upsertDocumentAsync,但创建了一个新的文档文件,而不是更新现有的文档文件。
发布于 2019-06-21 17:28:46
我终于喜欢上了:
public async Task<Catalog> UpdateProductIdAsync(
Guid productid,
Product productData)
{
var feedOptions =
new FeedOptions
{
MaxItemCount = -1,
EnableCrossPartitionQuery = true
};
var query =
$"SELECT catalog.id,catalog.VendorName,catalog.Industy FROM catalog join industry in catalog.Industy join category in industry.Category join product in category.Subcategory.Product where product.Id ='" + productid + "'";
var catlog = _cosmosClient.CreateDocumentQuery<Catalog>(UriFactory.CreateDocumentCollectionUri(
_azureCosmosDbOptions.Value.DatabaseId, "catalog"), query, feedOptions).AsEnumerable().FirstOrDefault();
if (catlog != null)
{
foreach (var item in catlog.Industy)
{
foreach (var cat in item.Category)
{
Product product = cat.Subcategory.Product.FirstOrDefault(p => p.Id == productid);
if (product != null)
{
product.Name = productData.Name == null ? product.Name : productData.Name;
product.Addons = productData.Addons == null ? product.Addons : productData.Addons;
product.CurrentQuantity = productData.CurrentQuantity == null ? product.CurrentQuantity : productData.CurrentQuantity;
product.MethodOfPreparation = productData.MethodOfPreparation == null ? product.MethodOfPreparation : productData.MethodOfPreparation;
product.Price = productData.Price == null ? product.Price : productData.Price;
product.Tag = productData.Tag == null ? product.Tag : productData.Tag;
product.Unit = productData.Unit == null ? product.Unit : productData.Unit;
product.hasMethodOfPreparation = productData.hasMethodOfPreparation == false ? product.hasMethodOfPreparation : productData.hasMethodOfPreparation;
break;
}
}
break;
}
}
var requestOptions =
new RequestOptions
{
PartitionKey = new Microsoft.Azure.Documents.PartitionKey(catlog.Id.ToString())
};
var orderDocument = await _cosmosClient.ReplaceDocumentAsync(
UriFactory.CreateDocumentUri(
_azureCosmosDbOptions.Value.DatabaseId, "catalog", catlog.Id.ToString()), catlog, requestOptions);
return
(Catalog)((dynamic)catlog);
}
发布于 2019-06-10 08:04:22
ReplaceDocumentAsync调用需要文档Uri,而不是DocumentCollection。
var catalogDocument = await _cosmosClient.ReplaceDocumentAsync(
UriFactory.CreateDocumentUri(
_azureCosmosDbOptions.Value.DatabaseId, "catalog", order.Id), order, requestOptions);
https://stackoverflow.com/questions/56502687
复制相似问题