Upgrade MongoDB.Driver dependency to version 2.24.0

And implement the new required IMongoCollection<T> members: DistinctMany + DistinctManyAsync.
SwissLife-OSS · Feb 22, 2024 · 3b6c16e · 3b6c16e
1 parent d3a353e
commit 3b6c16e
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 1 deletion.
diff --git a/Directory.Packages.props b/Directory.Packages.props
@@ -21,7 +21,7 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageVersion Include="MongoDB.Driver" Version="2.21.0" />
+ <PackageVersion Include="MongoDB.Driver" Version="2.24.0" />
  <PackageVersion Include="MongoDB.Driver.Core.Extensions.DiagnosticSources" Version="1.3.0" />
  <PackageVersion Include="System.Text.Json" Version="7.0.0" />
  </ItemGroup>

diff --git a/src/Transactions/MongoTransactionCollection.cs b/src/Transactions/MongoTransactionCollection.cs
@@ -437,6 +437,44 @@ public class MongoTransactionCollection<T> : IMongoCollection<T>
  return _collection.DistinctAsync(session, field, filter, options, cancellationToken);
  }
 
+ public IAsyncCursor<TItem> DistinctMany<TItem>(
+ FieldDefinition<T, IEnumerable<TItem>> field,
+ FilterDefinition<T> filter,
+ DistinctOptions? options = null,
+ CancellationToken cancellationToken = default)
+ {
+ return _collection.DistinctMany(field, filter, options, cancellationToken);
+ }
+
+ public IAsyncCursor<TItem> DistinctMany<TItem>(
+ IClientSessionHandle session,
+ FieldDefinition<T, IEnumerable<TItem>> field,
+ FilterDefinition<T> filter,
+ DistinctOptions? options = null,
+ CancellationToken cancellationToken = default)
+ {
+ return _collection.DistinctMany(session, field, filter, options, cancellationToken);
+ }
+
+ public Task<IAsyncCursor<TItem>> DistinctManyAsync<TItem>(
+ FieldDefinition<T, IEnumerable<TItem>> field,
+ FilterDefinition<T> filter,
+ DistinctOptions? options = null,
+ CancellationToken cancellationToken = default)
+ {
+ return _collection.DistinctManyAsync(field, filter, options, cancellationToken);
+ }
+
+ public Task<IAsyncCursor<TItem>> DistinctManyAsync<TItem>(
+ IClientSessionHandle session,
+ FieldDefinition<T, IEnumerable<TItem>> field,
+ FilterDefinition<T> filter,
+ DistinctOptions? options = null,
+ CancellationToken cancellationToken = default)
+ {
+ return _collection.DistinctManyAsync(session, field, filter, options, cancellationToken);
+ }
+
  public long EstimatedDocumentCount(
  EstimatedDocumentCountOptions? options = null,
  CancellationToken cancellationToken = default)