GetCollection Method

ManagedCode.Database.AzureTables/AzureTablesDatabase.cs

@@ -1,7 +1,9 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
+using System.Xml.Linq;
 using Azure.Data.Tables;
 using Humanizer;
 using ManagedCode.Database.Core;

ManagedCode.Database.AzureTables/AzureTablesDatabaseCollection.cs

@@ -34,6 +34,11 @@ public override ValueTask DisposeAsync()
 
     #region Get
 
+    protected override async Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        return await _tableClient.QueryAsync<TItem>().ToListAsync(cancellationToken);
+    }
+
     protected override async Task<TItem?> GetInternalAsync(TableId id, CancellationToken cancellationToken = default)
     {
         try

ManagedCode.Database.Core/BaseDatabaseCollection.cs

@@ -15,6 +15,11 @@ public abstract class BaseDatabaseCollection<TId, TItem> : IDatabaseCollection<T
 
     public abstract ValueTask DisposeAsync();
 
+    public Task<List<TItem>> GetCollection(CancellationToken cancellationToken = default)
+    {
+        return ExecuteAsync(GetCollectionInternalAsync(cancellationToken));
+    }
+
     public Task<TItem> InsertAsync(TItem item, CancellationToken cancellationToken = default)
     {
         return ExecuteAsync(InsertInternalAsync(item, cancellationToken));
@@ -107,6 +112,8 @@ protected abstract Task<int> DeleteInternalAsync(IEnumerable<TItem> items,
         CancellationToken cancellationToken = default);
 
     protected abstract Task<bool> DeleteCollectionInternalAsync(CancellationToken cancellationToken = default);
+
+    protected abstract Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default);
 
     protected abstract Task<TItem?> GetInternalAsync(TId id, CancellationToken cancellationToken = default);
 

ManagedCode.Database.Core/IDatabase.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
 

ManagedCode.Database.Core/IDatabaseCollection.cs

@@ -8,7 +8,8 @@ namespace ManagedCode.Database.Core;
 public interface IDatabaseCollection<in TId, TItem> : IDisposable, IAsyncDisposable where TItem : IItem<TId>
 {
     ICollectionQueryable<TItem> Query { get; }
-
+
+    Task<List<TItem>> GetCollection(CancellationToken cancellationToken = default);
     Task<TItem> InsertAsync(TItem item, CancellationToken cancellationToken = default);
     Task<int> InsertAsync(IEnumerable<TItem> items, CancellationToken cancellationToken = default);
 

ManagedCode.Database.Core/InMemory/InMemoryDatabaseCollection.cs

@@ -148,18 +148,25 @@
             return Task.FromResult(_storage.Count == 0);
         }
 
+
+
         #endregion
 
         #region Get
+
+        protected override Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+        {
+            return Task.FromResult(_storage.Values.ToList());
+        }
 
         protected override Task<TItem> GetInternalAsync(TId id, CancellationToken cancellationToken = default)
         {
             if (_storage.TryGetValue(id, out var item))
             {
                 return Task.FromResult(item);
             }
 
             return Task.FromResult<TItem>(default);
         }
 
         #endregion

ManagedCode.Database.Cosmos/CosmosCollection.cs

@@ -49,6 +49,11 @@ public override ValueTask DisposeAsync()
 
     #region Get
 
+    protected override Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        return Task.FromResult(_container.GetItemLinqQueryable<TItem>().ToList());
+    }
+
     protected override async Task<TItem?> GetInternalAsync(string id, CancellationToken cancellationToken = default)
     {
         using var queryIterator = _container.GetItemLinqQueryable<TItem>().Where(w => w.Id == id).ToFeedIterator<TItem>();

ManagedCode.Database.DynamoDB/DynamoDBCollection.cs

@@ -88,6 +88,11 @@ public override ValueTask DisposeAsync()
 
     #region Get
 
+    protected override async Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        return await _dynamoDBContext.ScanAsync<TItem>(null, _config).GetRemainingAsync(cancellationToken);
+    }
+
     protected override async Task<TItem?> GetInternalAsync(string hashKey, CancellationToken cancellationToken = default)
     {
         var data = await _dynamoDBContext.ScanAsync<TItem>(GetScanConditions(hashKey), _config).GetRemainingAsync(cancellationToken);

ManagedCode.Database.LiteDB/LiteDBCollection.cs

@@ -31,6 +31,11 @@ public override void Dispose()
 
     #region Get
 
+    protected override Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        return Task.FromResult(_collection.FindAll().ToList());
+    }
+
     protected override async Task<TItem?> GetInternalAsync(TId id, CancellationToken cancellationToken = default)
     {
         await Task.Yield();

ManagedCode.Database.MongoDB/MongoDBCollection.cs

@@ -33,6 +33,15 @@ public override ValueTask DisposeAsync()
 
     #region Get
 
+    protected override async Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        var collectionName = _collection.CollectionNamespace.CollectionName;
+
+        var collection = await _collection.Database.GetCollection<TItem>(collectionName).Find<TItem>(_ => true).ToListAsync();
+
+        return collection;
+    }
+
     protected override async Task<TItem?> GetInternalAsync(ObjectId id, CancellationToken cancellationToken = default)
     {
         var cursor = await _collection.FindAsync(w => w.Id == id, cancellationToken: cancellationToken);

ManagedCode.Database.SQLite/SQLiteDatabaseCollection.cs

@@ -31,6 +31,11 @@ public override void Dispose()
 
     #region Get
 
+    protected override Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        return Task.FromResult(_database.Query<TItem>(null));
+    }
+
     protected override async Task<TItem?> GetInternalAsync(TId id, CancellationToken cancellationToken = default)
     {
         await Task.Yield();

ManagedCode.Database.Tests/BaseTests/BaseCollectionTests.cs

@@ -6,6 +6,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using ManagedCode.Database.Tests.TestContainers;
+using Microsoft.Azure.Cosmos;
 using Xunit;
 
 namespace ManagedCode.Database.Tests.BaseTests;
@@ -368,6 +369,22 @@ public virtual async Task Count()
 
     #region Get
 
+    [Fact]
+    public virtual async Task GetAll_ReturnOk()
+    {
+        // Arrange
+        await Collection.InsertAsync(CreateNewItem());
+        await Collection.InsertAsync(CreateNewItem());
+        await Collection.InsertAsync(CreateNewItem());
+
+        // Act
+        var getItemResult = await Collection.GetCollection();
+
+        // Assert
+        getItemResult.Count.Should().Be(3);
+    }
+
+
     [Fact]
     public virtual async Task GetById_ReturnOk()
     {

ManagedCode.Database.ZoneTree/ZoneTreeCollection.cs

@@ -92,6 +92,12 @@ protected override Task<bool> DeleteCollectionInternalAsync(CancellationToken ca
         return Task.FromResult(true);
     }
 
+    protected override Task<List<TItem>> GetCollectionInternalAsync(CancellationToken cancellationToken = default)
+    {
+        var collection = _zoneTree.Enumerate().ToList();
+        return Task.FromResult(collection.Count == 0 ? null : collection)!;
+    }
+
     protected override async Task<TItem> InsertOrUpdateInternalAsync(TItem item,
         CancellationToken cancellationToken = default)
     {