lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-21 02:58:05 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

HandlePipelineUpdate

Browse Source
This commit is contained in:
sunkaixuan
2025-08-09 10:45:45 +08:00
parent 69d00e1213
commit ed35a79a1e
2 changed files with 22 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItemsAsync/BulkWriteHandlerAsync.cs
View File

@@ -57,7 +57,7 @@ namespace MongoDb.Ado.data
return new List<BsonDocument> { BsonDocument.Parse(json) };
}
private static async Task<int> HandlePipelineUpdate(IMongoCollection<BsonDocument> collection, BsonDocument filter, BsonDocument update)
private async Task<int> HandlePipelineUpdate(IMongoCollection<BsonDocument> collection, BsonDocument filter, BsonDocument update)
{
// 构造pipeline update
// 构造pipeline update，不写死，循环现有的$set值
@@ -81,8 +81,16 @@ namespace MongoDb.Ado.data
};
var pipelineUpdate = new PipelineUpdateDefinition<BsonDocument>(updatePipeline);
var result =await collection.UpdateManyAsync(filter, pipelineUpdate);
return (int)result.ModifiedCount;
if (context.IsAnyServerSession)
{
var result = await collection.UpdateManyAsync(context.ServerSession,filter, pipelineUpdate);
return (int)result.ModifiedCount;
}
else
{
var result = await collection.UpdateManyAsync(filter, pipelineUpdate);
return (int)result.ModifiedCount;
}
}
private static bool IsUpateBySql(BsonDocument update)