using MongoDB.Driver;
using MongoDbGenericRepository.Attributes;
using MongoDbGenericRepository.Utils;
using System.Linq;
using System.Reflection;
namespace MongoDbGenericRepository
{
///
/// The MongoDb context
///
public class MongoDbContext : IMongoDbContext
{
///
/// The IMongoClient from the official MongoDB driver
///
public IMongoClient Client { get; }
///
/// The IMongoDatabase from the official MongoDB driver
///
public IMongoDatabase Database { get; }
///
/// Sets the Guid representation of the MongoDB Driver.
///
/// The new value of the GuidRepresentation
public virtual void SetGuidRepresentation(MongoDB.Bson.GuidRepresentation guidRepresentation)
{
MongoDefaults.GuidRepresentation = guidRepresentation;
}
///
/// Initialize the Guid representation of the MongoDB Driver.
/// Override this method to change the default GuidRepresentation.
///
protected virtual void InitializeGuidRepresentation()
{
// by default, avoid legacy UUID representation: use Binary 0x04 subtype.
MongoDefaults.GuidRepresentation = MongoDB.Bson.GuidRepresentation.Standard;
}
///
/// The constructor of the MongoDbContext, it needs an object implementing .
///
/// An object implementing IMongoDatabase
public MongoDbContext(IMongoDatabase mongoDatabase)
{
// Avoid legacy UUID representation: use Binary 0x04 subtype.
InitializeGuidRepresentation();
Database = mongoDatabase;
Client = Database.Client;
}
///
/// The constructor of the MongoDbContext, it needs a connection string and a database name.
///
/// The connections string.
/// The name of your database.
public MongoDbContext(string connectionString, string databaseName)
{
InitializeGuidRepresentation();
Client = new MongoClient(connectionString);
Database = Client.GetDatabase(databaseName);
}
///
/// The constructor of the MongoDbContext, it needs a connection string and a database name.
///
/// The MongoClient.
/// The name of your database.
public MongoDbContext(MongoClient client, string databaseName)
{
InitializeGuidRepresentation();
Client = client;
Database = client.GetDatabase(databaseName);
}
///
/// Extracts the CollectionName attribute from the entity type, if any.
///
/// The type representing a Document.
/// The name of the collection in which the TDocument is stored.
private string GetAttributeCollectionName()
{
return (typeof(TDocument).GetTypeInfo()
.GetCustomAttributes(typeof(CollectionNameAttribute))
.FirstOrDefault() as CollectionNameAttribute)?.Name;
}
///
/// Returns a collection for a document type. Also handles document types with a partition key.
///
/// The type representing a Document.
/// The optional value of the partition key.
public IMongoCollection GetCollection(string partitionKey = null)
{
return Database.GetCollection(GetCollectionName(partitionKey));
}
///
/// Drops a collection, use very carefully.
///
/// The type representing a Document.
public void DropCollection(string partitionKey = null)
{
Database.DropCollection(GetCollectionName(partitionKey));
}
///
/// Given the document type and the partition key, returns the name of the collection it belongs to.
///
/// The type representing a Document.
/// The value of the partition key.
/// The name of the collection.
private string GetCollectionName(string partitionKey)
{
var collectionName = GetAttributeCollectionName() ?? Pluralize();
if (string.IsNullOrEmpty(partitionKey))
{
return collectionName;
}
return $"{partitionKey}-{collectionName}";
}
///
/// Very naively pluralizes a TDocument type name.
///
/// The type representing a Document.
/// The pluralized document name.
private string Pluralize()
{
return (typeof(TDocument).Name.Pluralize()).Camelize();
}
}
}