MAKS-IT/maksit-mongodb-linq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

(feature): allow empty collections for insert, update and upsert many

Browse Source
This commit is contained in:
Maksym Sadovnychyy 2024-10-25 21:48:44 +02:00
parent 993cb90f8a
commit 37e64d7d24
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/MaksIT.MongoDB.Linq/Abstractions/BaseCollectionDataProviderBase.cs
View File

@ -46,6 +46,11 @@ namespace MaksIT.MongoDB.Linq.Abstractions {
#region InsertMany
protected virtual async Task<Result<List<TDtoKey>?>> InsertManyAsync(List<TDtoDocument> documents, IClientSessionHandle? session) {
try {
// Check if the documents list is empty
if (documents.Count == 0) {
return Result<List<TDtoKey>?>.Ok(new List<TDtoKey>());
}
if (session != null)
await Collection.InsertManyAsync(session, documents);
else
@ -90,6 +95,11 @@ namespace MaksIT.MongoDB.Linq.Abstractions {
Expression<Func<TDtoDocument, bool>> predicate,
IClientSessionHandle? session) {
try {
// Check if the documents list is empty
if (documents.Count == 0) {
return Result<List<TDtoKey>?>.Ok(new List<TDtoKey>());
}
// Step 1: Find the documents that already exist based on the predicate
List<TDtoDocument> existingDocuments;
if (session != null) {
@ -161,6 +171,11 @@ namespace MaksIT.MongoDB.Linq.Abstractions {
Expression<Func<TDtoDocument, bool>> predicate,
IClientSessionHandle? session) {
try {
// Check if the documents list is empty
if (documents.Count == 0) {
return Result<List<TDtoKey>?>.Ok(new List<TDtoKey>());
}
// Deletion
if (session != null)
await Collection.DeleteManyAsync(session, predicate);

2
src/MaksIT.MongoDB.Linq/MaksIT.MongoDB.Linq.csproj
View File

@ -8,7 +8,7 @@
<!-- NuGet package metadata -->
<PackageId>MaksIT.MongoDB.Linq</PackageId>
<Version>1.0.6</Version>
<Version>1.0.7</Version>
<Authors>Maksym Sadovnychyy</Authors>
<Company>MAKS-IT</Company>
<Product>MaksIT.MongoDB.Linq</Product>