using MongoDB.Driver;
using MongoDbGenericRepository.Attributes;
using MongoDbGenericRepository.Models;
using MongoDbGenericRepository.Utils;
using System;
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 lefacy UUID representation: use Binary 0x04 subtype.
MongoDefaults.GuidRepresentation = MongoDB.Bson.GuidRepresentation.Standard;
}
///
/// The constructor of the MongoDbContext, it needs a 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);
}
///
/// 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 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));
}
private string GetCollectionName(string partitionKey)
{
if (string.IsNullOrEmpty(partitionKey))
{
return GetAttributeCollectionName() ?? Pluralize();
}
var collectionName = $"{partitionKey}-{(GetAttributeCollectionName() ?? Pluralize())}";
return collectionName;
}
///
/// Very naively pluralizes a TDocument type name.
///
/// The type representing a Document.
///
private string Pluralize()
{
return (typeof(TDocument).Name.Pluralize()).Camelize();
}
}
}