c#驱动操作mongodb辅助类MongoDBHelper
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了c#驱动操作mongodb辅助类MongoDBHelper，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含14011字，纯文字阅读大概需要21分钟。
内容图文
c#驱动操作mongodb辅助类MongoDBHelper
using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
/*
https://docs.mongodb.com/manual/tutorial/update-documents/
https://docs.mongodb.com/manual/tutorial/perform-two-phase-commits/
https://docs.mongodb.com/manual/reference/command/dropDatabase/index.html
https://docs.mongodb.com/manual/reference/command/listCommands/
*/
namespace MongoDbHelper
{
public class MongoDBHelper
{
private string databaseName = string.Empty;
private IMongoClient client = null;
private IMongoDatabase database = null;
public MongoDBHelper(string connectionString)
{
client = new MongoClient(connectionString);
}
public MongoDBHelper(string connectionString, string databaseName)
{
client = new MongoClient(connectionString);
database = client.GetDatabase(databaseName);
}
public string DatabaseName
{
get { return databaseName; }
set
{
databaseName = value;
database = client.GetDatabase(databaseName);
}
}
/// <summary>
/// 执行命令，命令请参考MongoCommand,命令太多，不一一展示，传入的就是里面的字符串，有些命令执行需要连接到admin表
/// </summary>
/// <param name="cmdText"></param>
/// <returns></returns>
public BsonDocument RunCommand(string cmdText)
{
return database.RunCommand<BsonDocument>(cmdText);
}
public IList<BsonDocument> GetDatabase()
{
return client.ListDatabases().ToList();
}
#region SELECT
/// <summary>
/// 判断文档存在状态
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filterexist"></param>
/// <returns></returns>
public bool IsExistDocument<T>(string documentname, FilterDefinition<T> filter)
{
return database.GetCollection<T>(documentname).Count(filter) > 0;
}
/// <summary>
/// 通过条件得到查询的结果个数
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <returns></returns>
public long GetCount<T>(string documentname, FilterDefinition<T> filter)
{
return database.GetCollection<T>(documentname).Count(filter);
}
/// <summary>
/// 通过系统id(ObjectId)获取一个对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="id"></param>
/// <returns></returns>
public T GetDocumentById<T>(string documentname, string id)
{
ObjectId oid = ObjectId.Parse(id);
var filter = Builders<T>.Filter.Eq("_id", oid);
var result = database.GetCollection<T>(documentname).Find(filter);
return result.FirstOrDefault();
}
/// <summary>
/// 通过系统id(ObjectId)获取一个对象同时过滤字段
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="id"></param>
/// <param name="fields"></param>
/// <returns></returns>
public T GetDocumentById<T>(string documentname, string id, ProjectionDefinition<T> fields)
{
ObjectId oid = ObjectId.Parse(id);
var filter = Builders<T>.Filter.Eq("_id", oid);
return database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).FirstOrDefault();
}
/// <summary>
/// 通过指定的条件获取一个对象，如果有多条，只取第一条，同时过滤字段
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <param name="fields"></param>
/// <returns></returns>
public T GetDocumentByUserFilter<T>(string documentname, FilterDefinition<T> filter, ProjectionDefinition<T> fields)
{
return database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).FirstOrDefault();
}
/// <summary>
/// 获取全部文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <returns></returns>
public IList<T> GetAllDocuments<T>(string documentname)
{
var filter = Builders<T>.Filter.Empty;
return database.GetCollection<T>(documentname).Find(filter).ToList();
}
/// <summary>
/// 获取全部文档同时过滤字段
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="fields">要获取的字段</param>
/// <returns></returns>
public IList<T> GetAllDocuments<T>(string documentname, ProjectionDefinition<T> fields)
{
var filter = Builders<T>.Filter.Empty;
return database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).ToList();
}
/// <summary>
/// 通过一个条件获取对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="property">字段名</param>
/// <param name="value">字段值</param>
/// <returns></returns>
public IList<T> GetDocumentsByFilter<T>(string documentname, string property, string value)
{
FilterDefinition<T> filter = Builders<T>.Filter.Eq(property, value);
return database.GetCollection<T>(documentname).Find(filter).ToList();
}
/// <summary>
/// 通过条件获取对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <returns></returns>
public IList<T> GetDocumentsByFilter<T>(string documentname, FilterDefinition<T> filter)
{
return database.GetCollection<T>(documentname).Find(filter).ToList();
}
/// <summary>
/// 通过条件获取对象,同时过滤字段
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="property">字段名</param>
/// <param name="value">字段值</param>
/// <param name="fields">要获取的字段</param>
/// <returns></returns>
public IList<T> GetDocumentsByFilter<T>(string documentname, string property, string value, ProjectionDefinition<T> fields)
{
FilterDefinition<T> filter = Builders<T>.Filter.Eq(property, value);
return database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).ToList();
}
/// <summary>
/// 通过条件获取对象,同时过滤数据和字段
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter">过滤器</param>
/// <param name="fields">要获取的字段</param>
/// <returns></returns>
public IList<T> GetDocumentsByFilter<T>(string documentname, FilterDefinition<T> filter, ProjectionDefinition<T> fields)
{
return database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).ToList();
}
/// <summary>
/// 通过条件获取分页的文档并排序
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <param name="sort"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public IList<T> GetPagedDocumentsByFilter<T>(string documentname, FilterDefinition<T> filter, ProjectionDefinition<T> fields, SortDefinition<T> sort, int pageIndex, int pageSize)
{
IList<T> result = new List<T>();
if (pageIndex != 0 && pageSize != 0)
{
result = database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).Sort(sort).Skip(pageSize * (pageIndex - 1)).Limit(pageSize).ToList();
}
else
{
result = database.GetCollection<T>(documentname).Find(filter).Project<T>(fields).Sort(sort).ToList();
}
return result;
}
/// <summary>
/// 通过条件获取分页的文档并排序
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <param name="sort"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public IList<T> GetPagedDocumentsByFilter<T>(string documentname, FilterDefinition<T> filter, SortDefinition<T> sort, int pageIndex, int pageSize)
{
IList<T> result = new List<T>();
if (pageIndex != 0 && pageSize != 0)
{
result = database.GetCollection<T>(documentname).Find(filter).Sort(sort).Skip(pageSize * (pageIndex - 1)).Limit(pageSize).ToList();
}
else
{
result = database.GetCollection<T>(documentname).Find(filter).Sort(sort).ToList();
}
return result;
}
/// <summary>
/// 通过条件获取分页的文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public IList<T> GetPagedDocumentsByFilter<T>(string documentname, FilterDefinition<T> filter, int pageIndex, int pageSize)
{
IList<T> result = new List<T>();
if (pageIndex != 0 && pageSize != 0)
{
result = database.GetCollection<T>(documentname).Find(filter).Skip(pageSize * (pageIndex - 1)).Limit(pageSize).ToList();
}
else
{
result = database.GetCollection<T>(documentname).Find(filter).ToList();
}
return result;
}
/// <summary>
/// 获取分页的文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public IList<T> GetPagedDocumentsByFilter<T>(string documentname, SortDefinition<T> sort, int pageIndex, int pageSize)
{
IList<T> result = new List<T>();
var filter = Builders<T>.Filter.Empty;
if (pageIndex != 0 && pageSize != 0)
{
result = database.GetCollection<T>(documentname).Find(filter).Sort(sort).Skip(pageSize * (pageIndex - 1)).Limit(pageSize).ToList();
}
else
{
result = database.GetCollection<T>(documentname).Find(filter).Sort(sort).ToList();
}
return result;
}
/// <summary>
/// 获取分页的文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <returns></returns>
public IList<T> GetPagedDocumentsByFilter<T>(string documentname, int pageIndex, int pageSize)
{
IList<T> result = new List<T>();
var filter = Builders<T>.Filter.Empty;
if (pageIndex != 0 && pageSize != 0)
{
result = database.GetCollection<T>(documentname).Find(filter).Skip(pageSize * (pageIndex - 1)).Limit(pageSize).ToList();
}
else
{
result = database.GetCollection<T>(documentname).Find(filter).ToList();
}
return result;
}
#endregion
#region INSERT
/// <summary>
/// 新增
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="document"></param>
/// <param name="filter"></param>
/// <returns></returns>
public void Insert<T>(string documentName, T document)
{
try
{
database.GetCollection<T>(documentName).InsertOne(document);
}
catch (MongoWriteException me)
{
MongoBulkWriteException mbe = me.InnerException as MongoBulkWriteException;
if (mbe != null && mbe.HResult == -2146233088)
throw new Exception("插入重复的键！");
throw new Exception(mbe.Message);
}
catch (Exception ep)
{
throw ep;
}
}
/// <summary>
/// 新增多个文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="documents"></param>
/// <returns></returns>
public void InsertMany<T>(string documentname, IList<T> documents)
{
try
{
database.GetCollection<T>(documentname).InsertMany(documents);
}
catch (MongoWriteException me)
{
MongoBulkWriteException mbe = me.InnerException as MongoBulkWriteException;
if (mbe != null && mbe.HResult == -2146233088)
throw new Exception("插入重复的键！");
throw new Exception(mbe.Message);
}
catch (Exception ep)
{
throw ep;
}
}
#endregion
#region UPDATE
/// <summary>
/// 修改
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filterexist"></param>
/// <param name="id"></param>
/// <param name="oldinfo"></param>
/// <returns></returns>
public void UpdateReplaceOne<T>(string documentname, string id, T oldinfo)
{
ObjectId oid = ObjectId.Parse(id);
var filter = Builders<T>.Filter.Eq("_id", oid);
database.GetCollection<T>(documentname).ReplaceOne(filter, oldinfo);
}
/// <summary>
/// 只能替换一条，如果有多条的话
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <param name="oldinfo"></param>
public void UpdateReplaceOne<T>(string documentname, FilterDefinition<T> filter, T oldinfo)
{
database.GetCollection<T>(documentname).ReplaceOne(filter, oldinfo);
}
/// <summary>
/// 更新指定属性值，按ID就只有一条，替换一条
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="id"></param>
/// <param name="setvalue"></param>
/// <returns></returns>
public void Update<T>(string documentname, string id, string property, string value)
{
ObjectId oid = ObjectId.Parse(id);
var filter = Builders<T>.Filter.Eq("_id", oid);
var update = Builders<T>.Update.Set(property, value);
database.GetCollection<T>(documentname).UpdateOne(filter, update);
}
public void Update<T>(string documentname, FilterDefinition<T> filter, UpdateDefinition<T> update)
{
database.GetCollection<T>(documentname).UpdateOne(filter, update);
}
public void UpdateMany<T>(string documentname, FilterDefinition<T> filter, UpdateDefinition<T> update)
{
database.GetCollection<T>(documentname).UpdateMany(filter, update);
}
#endregion
#region DELETE
/// <summary>
/// 删除一个文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="id"></param>
/// <returns></returns>
public void Delete<T>(string documentname, string id)
{
ObjectId oid = ObjectId.Parse(id);
var filterid = Builders<T>.Filter.Eq("_id", oid);
database.GetCollection<T>(documentname).DeleteOne(filterid);
}
public void Delete<T>(string documentname, string property, string value)
{
FilterDefinition<T> filter = Builders<T>.Filter.Eq(property, value);
database.GetCollection<T>(documentname).DeleteOne(filter);
}
/// <summary>
/// 通过一个属性名和属性值删除多个文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="id"></param>
/// <returns></returns>
public void DeleteMany<T>(string documentname, string property, string value)
{
FilterDefinition<T> filter = Builders<T>.Filter.Eq(property, value);
database.GetCollection<T>(documentname).DeleteMany(filter);
}
/// <summary>
/// 通过一个属性名和属性值删除多个文档
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="documentname"></param>
/// <param name="filter"></param>
/// <returns></returns>
public void DeleteMany<T>(string documentname, FilterDefinition<T> filter)
{
database.GetCollection<T>(documentname).DeleteMany(filter);
}
#endregion
/// <summary>
/// 有些命令要求你连到系统库上才能执行
/// You need to link to the admin table if you want to run system command;eg:listDatabases ,the following url show you the details
/// https://docs.mongodb.com/manual/reference/command/listCommands/
/// </summary>
public sealed class MongoCommand
{
public const string ListDatabases = "{listDatabases:1}";
public const string ListCommands = "{ listCommands: 1 }";
}
}
}
内容总结
以上是互联网集市为您收集整理的c#驱动操作mongodb辅助类MongoDBHelper全部内容，希望文章能够帮你解决c#驱动操作mongodb辅助类MongoDBHelper所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】