RMS.Common/Tools/MongoDBHelper.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using MongoDB.Bson;
using MongoDB.Driver;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace RMS.Common
{
    /// <summary>
    /// MongoDB操作帮助类（不要用异步方法，关不上链接）
    /// </summary>
    public static class MongoDBHelper
    {
        static NLogHelper nlog = new NLogHelper();
        #region 参数
        /// <summary>
        /// MongoDB客户端，在帮助类实例化的时候进行初始化
        /// </summary>
        public static MongoClient Client;
        /// <summary>
        /// MongoDB操作数据库
        /// </summary>
        public static IMongoDatabase Database;
        #endregion

        #region 构造函数
        /// <summary>
        /// 创建MongoDB帮助类，根据config文件的MongoDBUrl节点进行链接
        /// </summary>
        static MongoDBHelper()
        {
            try
            {
                string databaseName = "SXeDTLog";
                #region 配置类配置方式(参数较多，不推荐)
                //List<MongoServerAddress> seedList = new List<MongoServerAddress>();
                //seedList.Add(new MongoServerAddress("dds-2ze07f469e5917641.mongodb.rds.aliyuncs.com", 3717));
                //seedList.Add(new MongoServerAddress("dds-2ze07f469e5917642.mongodb.rds.aliyuncs.com", 3717));
                //// 构建鉴权信息
                //List<MongoCredential> credentials = new List<MongoCredential>();
                //credentials.Add(MongoCredential.CreateCredential("admin", "root", "Hewenlong123"));
                //// 构建操作选项，requiredReplicaSetName属性外的选项根据自己的实际需求配置，默认参数满足大多数场景
                //MongoClientSettings setting = new MongoClientSettings()
                //{
                //    Servers = seedList,
                //    Credentials = credentials,
                //    ReplicaSetName = "mgset-2997739",
                //    SocketTimeout = new TimeSpan(2000)
                //};
                //Client = new MongoClient(setting); 
                #endregion

                //通过URI初始化
                //mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
                string url = ConfigHelper.GetAppValue("MongoDBUrl");