.Net Core は MongoDB に対して複数条件クエリを実行します

以前は基本的にすべてのプロジェクトで MySQL データベースを使用していましたが、最近プロジェクトのスケジュールに余裕ができたので、リーダーは挿入/クエリのパフォーマンスが優れている MongoDB にログ モジュールを移行することにしました。 . 複数条件クエリ 書くのにかなりの労力がかかったので、記録するために記事を書きます。

関連する学習の推奨事項: C#.Net 開発グラフィック チュートリアル

1. 準備

#1. インストール手順については詳しく説明しません

2. ReferencePackage

dotnet add package mongodb.bson
dotnet add package mongodb.driver

## を追加します#3. appsetting.json

"MongodbHost": {
  "Connection": "mongodb://[username]:[password]@[ip]:[port]",
  "DataBase": "[database]",
  "Table": ""
 },

に接続設定を追加

4. MongoDBConfig の取得方法

public static MongodbHostOptions MongodbConfig()
{
  var builder = new ConfigurationBuilder()
        .SetBasePath(Directory.GetCurrentDirectory())
        .AddJsonFile("appsettings.json");

　　IConfiguration Configuration = builder.Build();
　　var option = Configuration.GetSection("MongodbHost");
　　return new MongodbHostOptions { Connection = option["Connection"], DataBase = option["DataBase"], Table = option["Table"] };
}

2. クエリメソッド

クエリメソッドはこちらオンラインで見つけて直接使用します。単一のデータ ソースの場合、ここのホストを抽出してヘルパー クラスの属性にすることができます。

#region FindListByPage 分页查询集合
  /// <summary>
  /// 分页查询集合
  /// </summary>
  /// <param name="filter">查询条件</param>
  /// <param name="pageIndex">当前页</param>
  /// <param name="pageSize">页容量</param>
  /// <param name="count">总条数</param>
  /// <param name="field">要查询的字段,不写时查询全部</param>
  /// <param name="sort">要排序的字段</param>
  /// <returns></returns>
  public static List<T> FindListByPage(FilterDefinition<T> filter, int pageIndex, int pageSize, out int count, string[] field = null, SortDefinition<T> sort = null)
  {
    try
    {
      MongodbHostOptions host = Tools.AppSettingsTools.MongodbConfig();
      host.Table = "WSMessageLog";
      var client = MongodbClient<T>.MongodbInfoClient(host);
      count = Convert.ToInt32(client.CountDocuments(filter));
      //不指定查询字段
      if (field == null || field.Length == 0)
      {
        if (sort == null) return client.Find(filter).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
        //进行排序
        return client.Find(filter).Sort(sort).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();
      }

      //指定查询字段
      var fieldList = new List<ProjectionDefinition<T>>();
      for (int i = 0; i < field.Length; i++)
      {
        fieldList.Add(Builders<T>.Projection.Include(field[i].ToString()));
      }
      var projection = Builders<T>.Projection.Combine(fieldList);
      fieldList?.Clear();

      //不排序
      if (sort == null) return client.Find(filter).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();

      //排序查询
      return client.Find(filter).Sort(sort).Project<T>(projection).Skip((pageIndex - 1) * pageSize).Limit(pageSize).ToList();

    }
    catch (Exception ex)
　　{
　　　　throw ex;
　　}
}
#endregion

3. クエリ メソッドを呼び出します

ここにも落とし穴があります MongoDB のストレージ 時刻はグリニッジ時間です 8:00 を入れるとクエリ時に 0:00 になってしまうのでラベルを追加する必要があります時間属性を定義する場合

[BsonDateTimeOptions(Kind = DateTimeKind.Local)]
public DateTime logtime { get; set; }

ここでの OprLogModel は、クエリ条件を定義するクラスです。

public static LogPager<log_operate> Get_operate_log_mongo(OprLogModel qModel)
{
　　LogPager<log_operate> pager = new LogPager<log_operate>();
　　FilterDefinition<log_operate> filters;

　　 var sortbuilder = Builders<log_operate>.Sort;
　　var sort = sortbuilder.Descending("operate_time");

　　#region 用户权限过滤
　　IEnumerable<string> IdList = dev_deviceRepository.GetBinding(qModel.user_id);
　　 filters = Builders<log_operate>.Filter.In("device_id", IdList);
　　#endregion

　　if (!string.IsNullOrEmpty(qModel.device_id))
  {
  　　var filters_did = Builders<log_operate>.Filter.Eq("device_id", qModel.device_id);
  　　filters = Builders<log_operate>.Filter.And(filters, filters_did);
　　}
　　if (qModel.sDate != null)
　　{
　　　　var filters_sdate = Builders<log_operate>.Filter.Gte<DateTime>("operate_time", Convert.ToDateTime(qModel.sDate));
　　　　filters = Builders<log_operate>.Filter.And(filters, filters_sdate);
　　}
　　if (qModel.eDate != null)
　　{
　　　　var filters_edate = Builders<log_operate>.Filter.Lte<DateTime>("operate_time", Convert.ToDateTime(qModel.eDate));
　　　　filters = Builders<log_operate>.Filter.And(filters, filters_edate);
　　}
　　int total;
　　pager.data = MongoTools<log_operate>.FindListByPage(filters, qModel.pageindex, (qModel.pageindex - 1) * qModel.pagesize, out total, null, sort);
　　pager.total = total;
　　return pager;
}
#endregion

最初に空のフィルター定義を定義してから、And を使用して各クエリ条件と集計することもできます。 :

FilterDefinition<log_operate> filters = FilterDefinition<log_operate>.Empty;
var filters_idlist = Builders<log_operate>.Filter.In("device_id", IdList);
filters = Builders<log_operate>.Filter.And(filters, filters_idlist);

以上が.Net Core は MongoDB に対して複数条件クエリを実行しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。