一、前言及mongodb的介绍

最近在整合自己的框架,顺便把mongodbd的最简单crud重构一下作为组件化集成到asp.net core项目中,当然此篇文章中没有讲解mongodb的集群部署,等有机会分享一下。

首先,我们在mongodb的官方文档中看到,mongodb的2.4以上的for .net的驱动是支持.net core 2.0的。

针对mongodb,我想大家应该不陌生,没有用过也有听过。

1、mongodb是什么?

mongodb是一个基于分布式文件存储的数据库,为web应用提供可扩展的高性能数据存储解决方案,介于关系型数据库和非关系型数据库的产品,是非关系型数据库中功能最丰富的。针对于数据处理是一把利器。

2、什么是关系型数据库和非关系型数据库?

关系型数据库:在我们所用过的sqlserver、mysql等,这些都是关系型数据库,并且关系型数据库是遵循acid原则的,严格的一致性。

非关系型数据库:也叫作nosql,用与超大规模数据的存储,这些类型的数据存储不需要固定的模式,无需多余的操作就可以横向扩展。

3、rdbms vs nosql

rdbms:

  高度组织结构化数据

  结构化查询语言

  数据和关系都存储在单独的表中

  严格一致性

  基础事务

nosql:

  没有声明性查询语言

  键-值对存储,列存储、文档存储等

  最终一致性

  非结构化和不可预知数据

  cap定理、高可用、高性能、高扩展

我相信讲到这里,眼尖的同学应该有注意到 cap定理和最终一致性,肯定会联想到 分布式系统,在这里给你大大的一个赞。在分布式系统中可以完美的结合nosql,提高我们的性能。

4、介绍一下rdbms与mongodb的一些概念,有助于帮助大家理解

翻译一下,即如下:

二、asp.net core集成mongodb

1、为了演示方便我下载了 windows版本的mongodb server

大家可以自行去官网下载,然后针对于可视化界面,我采用了 robo 3t 这个工具。很简洁美观的可视化工具。推荐大家使用。

安装结束后会在windows服务中看到mongodb server

然后我们打开一下robo 3t,连接我们的mongodb。

2、开始在项目中配置一下我们的mongodb吧

第一步:我新建一个core2.0类库

引入了 “mongodb.driver” 这个nuget包。

然后扩展了 startup.cs 中的services的扩展方法

//扩展方法public static class servicecollectionextensions
 {
 public static void addmongodb(this iservicecollection services, iconfiguration configuration)
 {
  services.configure<settings>(options =>
  {
  options.connectionstring = configuration.getsection("mongoconnection:connectionstring").value;
  options.database = configuration.getsection("mongoconnection:database").value;
  });
 }
 }

第二步:重构封装了mongodb的crud类,此处大家可以自行封装,只展示了查找和新增。

public class mongodbbase
 {
 private readonly imongodatabase _database = null;
 public mongodbbase(string connectionstring, string databasename)
 {
  var client = new mongoclient(connectionstring);
  if (client != null)
  {
  _database = client.getdatabase(databasename);
  }
 }

 #region select
 /// <summary>
 /// 根据查询条件,获取数据
 /// </summary>
 /// <typeparam name="t"></typeparam>
 /// <param name="id"></param>
 /// <returns></returns>
 public list<t> getlist<t>(expression<func<t, bool>> conditions = null)
 {
  var collection = _database.getcollection<t>(typeof(t).name);
  if (conditions != null)
  {
  return collection.find(conditions).tolist();
  }
  return collection.find(_ => true).tolist();
 }#endregion

 #region insert/// <summary>
 /// 插入多条数据,数据用list表示
 /// </summary>
 /// <typeparam name="t"></typeparam>
 /// <param name="list"></param>
 /// <returns></returns>
 public list<t> insertmany<t>(list<t> list)
 {
  var collection = _database.getcollection<t>(typeof(t).name);
  collection.insertmany(list);
  return list;
 }
 #endregion
 }

第三步:新建一个asp.net core webapi 项目,引用此类库进行演示

在项目中的 appsetting.json 添加 mongodb的连接字符串:我在这边使用自定义的一个数据名称 testdb,在插入mongodb的时候会会自动在创建数据库和集合以及文档。接着往下看

 "mongoconnection": { //mongodb数据库连接
 "connectionstring": "mongodb://127.0.0.1:27017",
 "database": "testdb",
 "isssl": true
 },

第四步:新建一个mongodb测试控制器,展示了插入单条和多条以及查询的接口。

[produces("application/json")]
 [route("api/mongodb/[action]")]
 public class mongodbcontroller : controller
 {
  private readonly mongodbbase _context = null;
  public mongodbcontroller(ioptions<settings> settings)
  {
   _context = new mongodbbase(settings.value.connectionstring, settings.value.database);
  }
  [httpget]
  public iactionresult addlist()
  {
   list<mongodbposttest> list = new list<mongodbposttest>()
   {
    new mongodbposttest()
    {
     id = "2",
     body = "test note 3",
     updatedon = datetime.now,
     userid = 1,
     headerimage = new noteimage
     {
      imagesize = 10,
      url = "http://localhost/image1.png",
      thumbnailurl = "http://localhost/image1_small.png"
     }
    },
    new mongodbposttest()
    {
     id = "3",
     body = "test note 4",
     updatedon = datetime.now,
     userid = 1,
     headerimage = new noteimage
     {
      imagesize = 14,
      url = "http://localhost/image3.png",
      thumbnailurl = "http://localhost/image3_small.png"
     }
    }
   };

   try
   {
    _context.insertmany(list);
   }
   catch (exception ex)
   {

    throw;
   }

   return ok("成功");
  }

  [httpget]
  public result<list<mongodbposttest>> selectsingle()
  {
   //无条件
   var list = _context.getlist<mongodbposttest>();

   //有条件
   //var list = _context.getlist<mongodbposttest>(a => a.id == "1");

   //得到单条数据,无条件
   //var list = _context.getsingle<mongodbposttest>();

   //得到单条数据,有条件
   //var list = _context.getsingle<mongodbposttest>(a => a.id == "3");

   objectid internalid = _context.getinternalid("5bbf41651d3b66668cbb5bfc");

   var a = _context.getsingle<mongodbposttest>(note => note.id == "5bbf41651d3b66668cbb5bfc" || note.internalid == internalid);

   return reshelper.suc(1, list, "成功");
  }
}

测试类

public class mongodbposttest
 {
  [bsonid]
  // standard bsonid generated by mongodb
  public objectid internalid { get; set; }
  public string id { get; set; }

  public string body { get; set; } = string.empty;

  [bsondatetimeoptions]
  public datetime updatedon { get; set; } = datetime.now;

  public noteimage headerimage { get; set; }

  public int userid { get; set; } = 0;
 }

public class noteimage
 {
  public string url { get; set; } = string.empty;
  public string thumbnailurl { get; set; } = string.empty;
  public long imagesize { get; set; } = 0l;
 }

第五步:运行项目,执行一下。

我们执行一下插入多条的数据吧,执行成功。

然后我们看一下数据库,发现已经生成了一个 testdb 数据库,里面包含了我们的数据内容

然后我们执行以下查的操作:把我们刚才插入的数据返回回来了。

注意:这边有一个坑有待解决,就是mongodb存储的时间是utc,会跟我们的本地时间相差8个小时。因此这边需要特殊处理一下时间。

三、总结

至此,mongodb的简单运用已演示完毕,后期大家根据官方文档可进行扩展,越扩展到后面,会觉得越来越有意思。感谢大家的支持。thank you。

参考文档:

mongodb教程:http://www.runoob.com/mongodb/mongodb-tutorial.html

mongodb中文手册:http://www.mongoing.com/docs/

好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对www.887551.com的支持。