188 lines
8.3 KiB
C#
188 lines
8.3 KiB
C#
using MongoDbGenericRepository.DataAccess.Create;
|
|
using MongoDbGenericRepository.Models;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace MongoDbGenericRepository
|
|
{
|
|
public interface IBaseMongoRepository_Create : IBaseMongoRepository_Create<Guid>
|
|
{
|
|
/// <summary>
|
|
/// Asynchronously adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
Task AddOneAsync<TDocument, TKey>(TDocument document)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>;
|
|
|
|
/// <summary>
|
|
/// Adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
void AddOne<TDocument, TKey>(TDocument document)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>;
|
|
|
|
/// <summary>
|
|
/// Asynchronously adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
Task AddManyAsync<TDocument, TKey>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>;
|
|
|
|
/// <summary>
|
|
/// Adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
void AddMany<TDocument, TKey>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>;
|
|
}
|
|
|
|
/// <summary>
|
|
/// The base Repository, it is meant to be inherited from by your custom custom MongoRepository implementation.
|
|
/// Its constructor must be given a connection string and a database name.
|
|
/// </summary>
|
|
public abstract partial class BaseMongoRepository : IBaseMongoRepository_Create
|
|
{
|
|
private readonly object _initLock = new object();
|
|
private MongoDbCreator _mongoDbCreator;
|
|
protected virtual MongoDbCreator MongoDbCreator
|
|
{
|
|
get
|
|
{
|
|
if (_mongoDbCreator != null) { return _mongoDbCreator; }
|
|
|
|
lock (_initLock)
|
|
{
|
|
if (_mongoDbCreator == null)
|
|
{
|
|
_mongoDbCreator = new MongoDbCreator(MongoDbContext);
|
|
}
|
|
}
|
|
|
|
return _mongoDbCreator;
|
|
}
|
|
set { _mongoDbCreator = value; }
|
|
}
|
|
|
|
/// <summary>
|
|
/// Asynchronously adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
public virtual async Task AddOneAsync<TDocument, TKey>(TDocument document)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>
|
|
{
|
|
await MongoDbCreator.AddOneAsync<TDocument, TKey>(document);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Asynchronously adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
public virtual async Task AddOneAsync<TDocument>(TDocument document)
|
|
where TDocument : IDocument<Guid>
|
|
{
|
|
await MongoDbCreator.AddOneAsync<TDocument, Guid>(document);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
public virtual void AddOne<TDocument, TKey>(TDocument document)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>
|
|
{
|
|
MongoDbCreator.AddOne<TDocument, TKey>(document);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds a document to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <param name="document">The document you want to add.</param>
|
|
public virtual void AddOne<TDocument>(TDocument document) where TDocument : IDocument<Guid>
|
|
{
|
|
MongoDbCreator.AddOne<TDocument, Guid>(document);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Asynchronously adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
public virtual async Task AddManyAsync<TDocument, TKey>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>
|
|
{
|
|
await MongoDbCreator.AddManyAsync<TDocument, TKey>(documents);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Asynchronously adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
public virtual async Task AddManyAsync<TDocument>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<Guid>
|
|
{
|
|
await MongoDbCreator.AddManyAsync<TDocument, Guid>(documents);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <typeparam name="TKey">The type of the primary key for a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
public virtual void AddMany<TDocument, TKey>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<TKey>
|
|
where TKey : IEquatable<TKey>
|
|
{
|
|
MongoDbCreator.AddMany<TDocument, TKey>(documents);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Adds a list of documents to the collection.
|
|
/// Populates the Id and AddedAtUtc fields if necessary.
|
|
/// </summary>
|
|
/// <typeparam name="TDocument">The type representing a Document.</typeparam>
|
|
/// <param name="documents">The documents you want to add.</param>
|
|
public virtual void AddMany<TDocument>(IEnumerable<TDocument> documents)
|
|
where TDocument : IDocument<Guid>
|
|
{
|
|
MongoDbCreator.AddMany<TDocument, Guid>(documents);
|
|
}
|
|
}
|
|
|
|
}
|