.Net Core對(duì)MongoDB如何執(zhí)行多條件查詢？相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

創(chuàng)新互聯(lián)建站堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的蕭縣網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

以前項(xiàng)目基本上全部使用MySQL數(shù)據(jù)庫(kù), 最近項(xiàng)目排期空出了一點(diǎn)時(shí)間leader決定把日志模塊遷移到插入/查詢性能更好的MongoDB上. 多條件查詢的寫(xiě)法著實(shí)費(fèi)了些功夫, 撰文記錄一下.

一、準(zhǔn)備工作

1. 安裝過(guò)程, 不贅述了

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"] };
}

二、查詢方法

這里的查詢方法是網(wǎng)上找的, 直接拿來(lái)用了. 如果是單一數(shù)據(jù)源的話, 這里的host可以提取出來(lái)成為helper類(lèi)的屬性.

#region FindListByPage 分頁(yè)查詢集合
  /// <summary>
  /// 分頁(yè)查詢集合
  /// </summary>
  /// <param name="filter">查詢條件</param>
  /// <param name="pageIndex">當(dāng)前頁(yè)</param>
  /// <param name="pageSize">頁(yè)容量</param>
  /// <param name="count">總條數(shù)</param>
  /// <param name="field">要查詢的字段,不寫(xiě)時(shí)查詢?nèi)?lt;/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();
        //進(jìn)行排序
        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

三、調(diào)用查詢方法

這里還踩了一個(gè)坑. MongoDB里存儲(chǔ)的時(shí)間是格林尼治時(shí)間, 插入8:00, 查詢時(shí)會(huì)發(fā)現(xiàn)變成了0:00,所以定義時(shí)間屬性的時(shí)候需要加個(gè)標(biāo)簽

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

這里的OprLogModel是定義了查詢條件的類(lèi).

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 用戶權(quán)限過(guò)濾
　　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

也可以先定義一個(gè)空的filterdefinition, 然后與各查詢條件通過(guò)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);

看完上述內(nèi)容，你們掌握.Net Core對(duì)MongoDB如何執(zhí)行多條件查詢的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！

網(wǎng)站名稱(chēng)：.NetCore對(duì)MongoDB如何執(zhí)行多條件查詢
網(wǎng)址分享：http://chinadenli.net/article22/pgescc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、關(guān)鍵詞優(yōu)化、網(wǎng)站設(shè)計(jì)公司、建站公司、網(wǎng)站改版

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)