C# 操作Mongodb数据库
1.引入NuGet包
2.创建数据库操作类（MongodbHelper）
里面有增删改查的所有内容，同步和异步
using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace ConsoleApp9
{
public class MongoHelper<T>
{
private string connStr = "";//服务器网址
private string dbName = "";//数据库名称
private IMongoClient client;//连接客户端
private IMongoDatabase db;//连接数据库
private string collName;//集合名称
public MongoHelper(string connStr, string dbName, string collName)
{
this.connStr = connStr;
this.dbName = dbName;
this.collName = collName;
this.Init();
}
private void Init()
{
if (client == null)
client = new MongoClient(this.connStr);
if (db == null)
db = client.GetDatabase(this.dbName);
}
public DbMessage Insert(T obj)
{
try
{
var collection = db.GetCollection<T>(this.collName);
collection.InsertOne(obj);
return new DbMessage() { Ex = string.Empty, iFlg = 1 };
}
catch (Exception e)
{
Console.WriteLine("Insert错误!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage Insert(Dictionary<string,object> dicInfo)
{
try
{
var collection = db.GetCollection<BsonDocument>(this.collName);
var document = new BsonDocument(dicInfo);
collection.InsertOne(document);
return new DbMessage() { Ex = string.Empty, iFlg = 1 };
}
catch (Exception e)
{
Console.WriteLine("Insert错误!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage Insert(List<T> documents)
{
try
{
var collection = db.GetCollection<T>(this.collName);
collection.InsertMany(documents);
return new DbMessage() { Ex = string.Empty, iFlg = documents.Count };
}
catch (Exception e)
{
Console.WriteLine("Insert出错!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> InsertAsync(T obj)
{
try
{
var collection = db.GetCollection<T>(this.collName);
await collection.InsertOneAsync(obj);
return new DbMessage() { Ex = string.Empty, iFlg = 1 };
}
catch (Exception e)
{
Console.WriteLine("InsertAsync错误!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> InsertAsync(Dictionary<string, object> dicInfo)
{
try
{
var collection = db.GetCollection<BsonDocument>(this.collName);
var document = new BsonDocument(dicInfo);
await collection.InsertOneAsync(document);
return new DbMessage() { Ex = string.Empty, iFlg = 1 };
}
catch (Exception e)
{
Console.WriteLine("InsertAsync错误!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> InsertManyAsync(List<T> documents)
{
try
{
var collection = db.GetCollection<T>(this.collName);
await collection.InsertManyAsync(documents);
return new DbMessage() { Ex = string.Empty, iFlg = documents.Count };
}
catch (Exception e)
{
Console.WriteLine("InsterManyAsync出错!!!");
return new DbMessage() { Ex = e.Message, iFlg = -1 };
}
}
public List<T> QueryMany()
{
try
{
var collection = db.GetCollection<T>(this.collName);
var rest = collection.Find(Builders<T>.Filter.Empty);
return rest.As<T>().ToList();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public List<T> QueryMany(string field, object val)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = collection.Find(Builders<T>.Filter.Eq(field, val));
return rest.As<T>().ToList();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public List<T> QueryMany(BsonDocument document)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest =collection.Find(document);
return rest.As<T>().ToList();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public async Task<List<T>> QueryManyAsync()
{
try
{
var collection = db.GetCollection<T>(this.collName);
var rest = await collection.FindAsync(Builders<T>.Filter.Empty);
return await rest.ToListAsync<T>();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public async Task<List<T>> QueryManyAsync(string field, object val)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = await collection.FindAsync(Builders<T>.Filter.Eq(field, val));
return await rest.ToListAsync<T>();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public async Task<List<T>> QueryManyAsync(BsonDocument document)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = await collection.FindAsync(document);
return await rest.ToListAsync();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
return null;
}
}
public DbMessage UpdateOne(FilterDefinition<T> filter, UpdateDefinition<T> update, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = collection.UpdateOne(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateOne错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage UpdateOne(string filterKey, object filterVal, string setKey, object setVal, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var filter = Builders<T>.Filter.Eq(filterKey, filterVal);
var update = Builders<T>.Update.Set(setKey, setVal);
var rest = collection.UpdateOne(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateOne错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage UpdateMany(FilterDefinition<T> filter, UpdateDefinition<T> update, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = collection.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateMany错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage UpdateMany(string filterKey, object filterVal, string setKey, object setVal, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var filter = Builders<T>.Filter.Eq(filterKey, filterVal);
var update = Builders<T>.Update.Set(setKey, setVal);
var rest = collection.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateMany错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> UpdateOneAsync(FilterDefinition<T> filter, UpdateDefinition<T> update, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = await collection.UpdateOneAsync(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> UpdateOneAsync(string filterKey, object filterVal, string setKey, object setVal, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var filter = Builders<T>.Filter.Eq(filterKey, filterVal);
var update = Builders<T>.Update.Set(setKey, setVal);
var rest = await collection.UpdateOneAsync(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> UpdateManyAsync(FilterDefinition<T> filter, UpdateDefinition<T> update, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var rest = await collection.UpdateManyAsync(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateManyAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> UpdateManyAsync(string filterKey, object filterVal, string setKey, object setVal, bool upsert = false)
{
try
{
var collection = db.GetCollection<T>(collName);
var filter = Builders<T>.Filter.Eq(filterKey, filterVal);
var update = Builders<T>.Update.Set(setKey, setVal);
var rest = await collection.UpdateManyAsync(filter, update, new UpdateOptions { IsUpsert = upsert });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch (Exception e)
{
Console.WriteLine("UpdateManyAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage DeleteOne(string filterKey, string filterVal, bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = collection.DeleteOne(Builders<T>.Filter.Eq(filterKey, filterVal));
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
var msg = UpdateOne(filterKey, filterVal, "IsDelete", true);
if (msg.iFlg == -1 || !string.IsNullOrEmpty(msg.Ex))
throw new Exception("DeleteOne中更新字段IsDelete出错!!!");
return new DbMessage { Ex = msg.Ex, iFlg = msg.iFlg };
}
}
catch (Exception e)
{
Console.WriteLine("DeleteOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage DeleteMany(string filterKey, string filterVal, bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = collection.DeleteMany(Builders<T>.Filter.Eq(filterKey, filterVal));
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
var msg = UpdateMany(filterKey, filterVal, "IsDelete", true);
if (msg.iFlg == -1 || !string.IsNullOrEmpty(msg.Ex))
throw new Exception("DeleteOneAsync中更新字段IsDelete出错!!!");
return new DbMessage { Ex = msg.Ex, iFlg = msg.iFlg };
}
}
catch (Exception e)
{
Console.WriteLine("DeleteManyAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public DbMessage DeleteMany(FilterDefinition<T> filter, bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = collection.DeleteMany(filter);
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
try
{
var rest = collection.UpdateMany(filter, Builders<T>.Update.Set("IsDelete", true), new UpdateOptions { IsUpsert = false });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch
{
throw new Exception("DeleteOneAsync中更新字段IsDelete出错!!!");
}
}
}
catch (Exception e)
{
Console.WriteLine("DeleteOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> DeleteOneAsync(FilterDefinition<T> filter,bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = await collection.DeleteOneAsync(filter);
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
try
{
var rest = await collection.UpdateOneAsync(filter, Builders<T>.Update.Set("IsDelete", true), new UpdateOptions { IsUpsert = false });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch
{
throw new Exception("DeleteOneAsync中更新字段IsDelete出错!!!");
}
}
}
catch (Exception e)
{
Console.WriteLine("DeleteOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> DeleteManyAsync(string filterKey, string filterVal, bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = await collection.DeleteManyAsync(Builders<T>.Filter.Eq(filterKey, filterVal));
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
var msg = await UpdateManyAsync(filterKey, filterVal, "IsDelete", true);
if (msg.iFlg == -1 || !string.IsNullOrEmpty(msg.Ex))
throw new Exception("DeleteOneAsync中更新字段IsDelete出错!!!");
return new DbMessage { Ex = msg.Ex, iFlg = msg.iFlg };
}
}
catch (Exception e)
{
Console.WriteLine("DeleteManyAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
public async Task<DbMessage> DeleteManyAsync(FilterDefinition<T> filter, bool isTrueDelete = false)
{
try
{
var collection = db.GetCollection<T>(collName);
if (isTrueDelete)
{
var rest = await collection.DeleteManyAsync(filter);
return new DbMessage { Ex = string.Empty, iFlg = rest.DeletedCount };
}
else
{
try
{
var rest = await collection.UpdateManyAsync(filter, Builders<T>.Update.Set("IsDelete", true), new UpdateOptions { IsUpsert = false });
return new DbMessage { Ex = string.Empty, iFlg = rest.ModifiedCount };
}
catch
{
throw new Exception("DeleteOneAsync中更新字段IsDelete出错!!!");
}
}
}
catch (Exception e)
{
Console.WriteLine("DeleteOneAsync错误!!!");
return new DbMessage { Ex = e.Message, iFlg = -1 };
}
}
}
public class DbMessage
{
/// <summary>
/// 反馈数量
/// </summary>
public long iFlg { get; set; }
/// <summary>
/// 反馈文字描述
/// </summary>
public string Ex { get; set; }
public override string ToString()
{
return $"返回数据库消息: 是否成功:{string.IsNullOrEmpty(Ex)},反馈数量:{iFlg},描述:{Ex}";
}
}
}
3.使用封装的类操作数据库
namespace ConsoleApp9
{
class Program
{
static void Main(string[] args)
{
//var connStr = "mongodb://127.0.0.1:27017";
//var client = new MongoDB.Driver.MongoClient(connStr);
//var db = client.GetDatabase("test");
//var studentCollection = db.GetCollection<Students>("Students");
//var student = new Students()
//{
// _id = ObjectId.GenerateNewId(),
// Name = "zzs",
// Age = 18,
// Sex = true,
//};
//Console.WriteLine("开始插入");
//studentCollection.InsertOneAsync(student);
//Console.WriteLine("插入完成");
//Thread thread = new Thread(async () =>
//{
// MongoHelper<Students> studentsMongoHeaper = new MongoHelper<Students>("mongodb://127.0.0.1:27017", "test", "Students");
// var msg = await studentsMongoHeaper.InsterManyAsync(new List<Students>()
// {
// new Students{Name = "wy",Age = 14,Sex = true},
// new Students{Name = "pnb",Age = 20,Sex = true}
// });
// Console.WriteLine(msg);
// Console.WriteLine("插入完成!!!");
//});
//thread.Start();
//Thread thread = new Thread(async () =>
//{
// MongoHelper<Students> studentsMongoHeaper = new MongoHelper<Students>("mongodb://127.0.0.1:27017", "test", "Students");
// var doc = new BsonDocument();
// doc.Add("Age",18);
// doc.Add("Sex",false);
// var allList = await studentsMongoHeaper.QueryAsync(doc);
// Console.WriteLine(allList[0].Name);
//});
//thread.Start();
//Thread thread = new Thread(async () =>
//{
// MongoHelper<Students> studentsMongoHeaper = new MongoHelper<Students>("mongodb://127.0.0.1:27017", "test", "Students");
// var msg = await studentsMongoHeaper.UpdateManyAsync
// (
// Builders<Students>.Filter.Eq("Name", "zzs"),
// Builders<Students>.Update.Set("Age", 777)
// );
// Console.WriteLine(msg);
//});
//thread.Start();
Thread thread = new Thread(async () =>
{
MongoHelper<Students> studentsMongoHeaper = new MongoHelper<Students>("mongodb://127.0.0.1:27017", "test", "Students");
var msg = await studentsMongoHeaper.DeleteManyAsync("Name","zzs",true);
Console.WriteLine(msg);
});
thread.Start();
Console.ReadKey();
}
}
class Students
{
public ObjectId _id { get; set; }
public string Name { get; set; }
public int Age { get; set; }
public bool Sex { get; set; }
}
}
