37 lines
1.1 KiB
C#
37 lines
1.1 KiB
C#
using MongoDB.Driver;
|
|
|
|
namespace Infrastructure.Services.MongoDB
|
|
{
|
|
public class MongoDbService
|
|
{
|
|
private readonly IMongoDatabase _database;
|
|
|
|
public MongoDbService(string connectionString)
|
|
{
|
|
var url = new MongoUrl(connectionString);
|
|
var client = new MongoClient(url);
|
|
_database = client.GetDatabase(url.DatabaseName);
|
|
}
|
|
|
|
public IMongoCollection<T> GetCollection<T>(string collectionName)
|
|
{
|
|
return _database.GetCollection<T>(collectionName);
|
|
}
|
|
|
|
public async Task<List<T>> FindAsync<T>(string collectionName, List<(string FieldName, string Value)> criteria)
|
|
{
|
|
var collection = _database.GetCollection<T>(collectionName);
|
|
|
|
var filters = new List<FilterDefinition<T>>();
|
|
foreach (var (FieldName, Value) in criteria)
|
|
{
|
|
filters.Add(Builders<T>.Filter.Eq(FieldName, Value));
|
|
}
|
|
|
|
var combinedFilter = Builders<T>.Filter.And(filters);
|
|
|
|
return await collection.Find(combinedFilter).ToListAsync();
|
|
}
|
|
}
|
|
}
|