Skip to content

Instantly share code, notes, and snippets.

@TRex22
Last active October 3, 2015 01:43
Show Gist options
  • Save TRex22/3156a513664f08acc61c to your computer and use it in GitHub Desktop.
Save TRex22/3156a513664f08acc61c to your computer and use it in GitHub Desktop.
public async Task<string> CreateDocument(string collectionName, BsonDocument document)
{
string message = "nothing has happened";
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
//insert collection
await collection.InsertOneAsync(document);
message = "updated data";
return message;
}
public async Task<BsonDocument> GetFirstDataDocument(string collectionName)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
var document = await collection.Find(new BsonDocument()).FirstOrDefaultAsync();
return document;
}
public async Task<List<BsonDocument>> GetData (string collectionName)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
List<BsonDocument> documents = await collection.Find(new BsonDocument()).ToListAsync();
return documents;
}
public async Task<BsonDocument> SearchFirstDocumentResult (string collectionName, string attributeName, string searchTerm)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
var filter = Builders<BsonDocument>.Filter.Eq(attributeName, searchTerm);
var document = await collection.Find(filter).FirstAsync();
return document;
}
public async Task<List<BsonDocument>> SearchListDocumentResult(string collectionName, string attributeName, string searchTerm)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
var filter = Builders<BsonDocument>.Filter.Gt(attributeName, searchTerm);
List<BsonDocument> documents = await collection.Find(filter).ToListAsync();
return documents;
}
public async void UpdateDocument(string collectionName, string attributeName, string oldValue, string newValue)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
var filter = Builders<BsonDocument>.Filter.Eq(attributeName, oldValue);
var update = Builders<BsonDocument>.Update.Set(attributeName, newValue);
await collection.UpdateOneAsync(filter, update);
}
public async void DeleteDocument(string collectionName, string attributeName, string value)
{
var collection = _mongoDatabase.GetCollection<BsonDocument>(collectionName);
var filter = Builders<BsonDocument>.Filter.Eq(attributeName, value));
await collection.DeleteOneAsync(filter);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment