C#使用Mongodb方法

显示全部楼层 · 2016-12-19 09:25:43

封装好的增删改查方法：

[C#] 纯文本查看 复制代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Driver;
using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
using System.Linq.Expressions;

namespace Langu.DbHelper
{
    /// <summary>
    /// MongoDb 数据库操作类
    /// </summary>
    public class MongoHelper<T> where T : BaseEntity
    {
        /// <summary>
        /// 数据库对象
        /// </summary>
        private IMongoDatabase database;
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="conString">连接字符串</param>
        public MongoHelper(String conString)
        {
            var url = new MongoUrl(conString);
            MongoClientSettings mcs = MongoClientSettings.FromUrl(url);
            mcs.MaxConnectionLifeTime = TimeSpan.FromMilliseconds(1000);
            var client = new MongoClient(mcs);
            this.database = client.GetDatabase(url.DatabaseName);
        }
        /// <summary>
        /// 创建集合对象
        /// </summary>
        /// <param name="collName">集合名称</param>
        ///<returns>集合对象</returns>
        private IMongoCollection<T> GetColletion(String collName)
        {
            return database.GetCollection<T>(collName);
        }

        #region 增加
        /// <summary>
        /// 插入对象
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="t">插入的对象</param>
        public void Insert(String collName, T t)
        {
            var coll = GetColletion(collName);
            coll.InsertOne(t);
        }
        /// <summary>
        /// 批量插入
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="ts">要插入的对象集合</param>
        public void InsertBath(String collName, IEnumerable<T> ts)
        {
            var coll = GetColletion(collName);
            coll.InsertMany(ts);
        }
        #endregion

        #region 删除
        /// <summary>
        /// 按BsonDocument条件删除
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="document">文档</param>
        /// <returns></returns>
        public Int64 Delete(String collName, BsonDocument document)
        {
            var coll = GetColletion(collName);
            var result = coll.DeleteOne(document);
            return result.DeletedCount;
        }
        /// <summary>
        /// 按json字符串删除
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="json">json字符串</param>
        /// <returns></returns>
        public Int64 Delete(String collName, String json)
        {
            var coll = GetColletion(collName);
            var result = coll.DeleteOne(json);
            return result.DeletedCount;
        }
        /// <summary>
        /// 按条件表达式删除
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="predicate">条件表达式</param>
        /// <returns></returns>
        public Int64 Delete(String collName, Expression<Func<T, Boolean>> predicate)
        {
            var coll = GetColletion(collName);
            var result = coll.DeleteOne(predicate);
            return result.DeletedCount;
        }
        /// <summary>
        /// 按检索条件删除
        /// 建议用Builders<T>构建复杂的查询条件
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="filter">条件</param>
        /// <returns></returns>
        public Int64 Delete(String collName, FilterDefinition<T> filter)
        {
            var coll = GetColletion(collName);
            var result = coll.DeleteOne(filter);
            return result.DeletedCount;
        }
        #endregion

        #region 修改
        /// <summary>
        /// 修改文档
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="filter">修改条件</param>
        /// <param name="update">修改结果</param>
        /// <param name="upsert">是否插入新文档（filter条件满足就更新，否则插入新文档）</param>
        /// <returns></returns>
        public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, UpdateDefinition<T> update, Boolean upsert = false)
        {
            var coll = GetColletion(collName);
            var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
            return result.ModifiedCount;
        }
        /// <summary>
        /// 用新对象替换新文档
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <param name="filter">修改条件</param>
        /// <param name="t">新对象</param>
        /// <param name="upsert">是否插入新文档（filter条件满足就更新，否则插入新文档）</param>
        /// <returns>修改影响文档数</returns>
        public Int64 Update(String collName, Expression<Func<T, Boolean>> filter, T t, Boolean upsert = false)
        {
            var coll = GetColletion(collName);
            BsonDocument document = t.ToBsonDocument<T>();
            document.Remove("_id");
            UpdateDocument update = new UpdateDocument("$set", document);
            var result = coll.UpdateMany(filter, update, new UpdateOptions { IsUpsert = upsert });
            return result.ModifiedCount;
        }
        #endregion

        /// <summary>
        /// 查询，复杂查询直接用Linq处理
        /// </summary>
        /// <param name="collName">集合名称</param>
        /// <returns>要查询的对象</returns>
        public IQueryable<T> GetQueryable(String collName)
        {
            var coll = GetColletion(collName);
            return coll.AsQueryable<T>();
        }
        #region 查询 
        #endregion
    }

    /// <summary>
    /// 实体基类，方便生成_id
    /// </summary>
    public class BaseEntity
    {
        [BsonRepresentation(BsonType.ObjectId)]
        public String Id { get; set; }
        /// <summary>
        /// 给对象初值
        /// </summary>
        public BaseEntity()
        {
            this.Id = ObjectId.GenerateNewId().ToString();
        }
    }
}

调用方法：

[C#] 纯文本查看 复制代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Langu.DbHelper;
using System.Threading;
using System.Linq.Expressions;
using MongoDB.Driver;

namespace Client
{
    class Program
    {
        static void Main(string[] args)
        {
            //连接字符串 127.0.0.1 服务器IP   27100 mongodb服务端口号   mydb 数据库名称
            String conString = "mongodb://127.0.0.1:27100/mydb";
            //实例化MongoHelper对象（泛型版本），构造函数要求传入连接字符串
            MongoHelper<User> mongoHelper = new MongoHelper<User>(conString);
            //查询集合 user中有多少数据量
            var cnt = mongoHelper.GetQueryable("user").Count();
            Console.WriteLine(cnt);
            Console.ReadKey();
        }
    }

    internal class User : BaseEntity
    {
        public int Age { get; set; }
        public String Name { get; set; }
    }
}

本文转自博客园