{

  "AppSettings": {

    "mongodb": "mongodb://用户名:密码@IP地址:端口号"

  }

}

 using ABCDEFG.Config;

 using MongoDB.Driver;

 using System;

 using System.Collections.Generic;

 using System.Linq.Expressions;

 using System.Text;

 namespace Mongodb

 {

     public class MongoContext

     {

         public MongoContext()

         {

             Client = new MongoClient(ABCDEFG.GetAppSetting("mongodb"));

         }

         public MongoContext(string connectionName)

         {

             Client = new MongoClient(MengTConfig.GetAppSetting(connectionName));

         }

         private MongoClient Client { get; set; }

         private IMongoDatabase DataBase { get => Client.GetDatabase("MengTLog"); }

         public IMongoCollection<T> DbSet<T>() where T : IMongoModel => DataBase.GetCollection<T>("MengTLog.Logger");

     }

     public static class MongoExtend

     {

         public static void Add<T>(this IMongoCollection<T> collenction, T Model) where T : IMongoModel

                   => collenction.InsertOne(Model);

         public static void AddList<T>(this IMongoCollection<T> collenction, List<T> Model) where T : IMongoModel

                  => collenction.InsertMany(Model);

         /// <summary>

         /// 查找第一个

         /// </summary>

         public static T FirstOrDefault<T>(this IMongoCollection<T> collenction,Expression<Func<T, bool>> expression) where T : IMongoModel

         {

             if (expression == null) { throw new ArgumentNullException("参数无效"); }

             return collenction.Find(expression).FirstOrDefault();

         }

         /// <summary>

         /// 查找符合数据列表

         /// </summary>

         public static List<T> FindToList<T>(this IMongoCollection<T> collenction, Expression<Func<T, bool>> expression) where T : IMongoModel

         {

             if (expression == null) { throw new ArgumentNullException("参数无效"); }

             return collenction.Find(expression).ToList();

         }

         /// <summary>

         /// 删除全部匹配数据

         /// </summary>

         public static void Delete<T>(this IMongoCollection<T> collenction, Expression<Func<T, bool>> expression) where T : IMongoModel

         {

             if (expression == null) { throw new ArgumentNullException("参数无效"); }

             collenction.DeleteManyAsync(expression);

         }

         /// <summary>

         /// 删除一个

         /// </summary>

         public static void DeleteOne<T>(this IMongoCollection<T> collenction, Expression<Func<T, bool>> expression) where T : IMongoModel

         {

             if (expression == null) { throw new ArgumentNullException("参数无效"); }

             collenction.DeleteOneAsync(expression);

         }

     }

 }

 using MongoDB.Bson;

 using System;

 using System.Collections.Generic;

 using System.Text;

 namespace Mongodb

 {

     public partial class IMongoModel

     {

         /// <summary>

         /// 基础ID

         /// </summary>

         public ObjectId _id { get; set; }

     }

 }