.net Core连接MongoDB数据库的步骤详解

作者：袖梨 2022-06-25

前两天在学习MongoDB相关的知识，做了个小Demo，做的是省份下面有多少所学校，嗯，做的比较粗暴。。。

我们在MongoDB的官方文档中看到，MongoDb的2.4以上的For .Net的驱动是支持.Net Core 2.0的。

所以，在我们安装好了MangoDB后，就可以开始MangoDB的.Net之旅了。

方法如下：

连接MongoDB首先要通过Nuget添加一个MongoDB的包，下载此包

安装完毕后开始写代码了，创建一个省份实体，一个学校实体 

using MongoDB.Bson.Serialization.Attributes;using System.Collections.Generic;
namespace MongoCore.Models
{
 public class Province
 {
 [BsonId]
 public int ProvinceID { get; set; }

 public string ProvinceName { get; set; }
 /// 
 /// 省份里有多个学校 这里用集合保存
 /// 
 public IList SchoolName { get; set; }
 }
}

namespace MongoCore.Models
{ //用于后面添加学校 public School(string schoolName, string years) { SchoolName = schoolName; Years = years; }
 public class School
 {
 public string SchoolName { get; set; }
 public string Years { get; set; }
 }
}

创建上下文类，连接MongoDB 

namespace MongoCore.Models
{
 public class ProvinceContext
 {
 //定义数据库
 private readonly IMongoDatabase _database = null;
 public ProvinceContext()
 {
  //连接服务器名称 mongo的默认端口27017
  var client = new MongoClient("mongodb://.......:27017");
  if (client != null)
  //连接数据库
  _database = client.GetDatabase("数据库名");
 }

 public IMongoCollection Province
 {
  get
  {
  return _database.GetCollection("Province");
  }
 }
 }
}

创建控制器 

private readonly ProvinceContext _context = new ProvinceContext();
 public async Task Index()
 {
  var list = await _context.Province.Find(_ => true).ToListAsync();
  return View(list);
 }

视图 

@model List
@{
 ViewData["Title"] = "Index";
}

Index


Index



 @foreach (var item in Model)
 {
 
 }


 

 省份ID
 省份名称
 操作
 

  
  @Html.DisplayFor(modelItem => item.ProvinceID)
  
  
  @Html.DisplayFor(modelItem => item.ProvinceName)
  
  
  新 增  
  详 情  
  删 除  

运行的时候修改配置在Startup.cs里

运行效果是这样的，现在还没有数据，

点击新建按钮添加省份,这里我添加了湖北省

添加省份代码如下：后端 

public IActionResult Create()
 {
  return View();
 }
 [HttpPost]
 [ValidateAntiForgeryToken]
 public async Task Create(Province item)
 {
  try
  {
  //初始化学校类型数据
  item.SchoolName = new List();
  await _context.Province.InsertOneAsync(item);
  return RedirectToAction(nameof(Index));
  }
  catch
  {
  return View();
  }
 }

视图： 

@model MongoCore.Models.Province
@{
 ViewData["Title"] = "Create";
}


Create

接下来就是添加省份下面的学校了 

public async Task Insert(int ProvinceID)
 {
  var num = await _context.Province.Find(p => p.ProvinceID == ProvinceID).SingleOrDefaultAsync();
  return View(num);
 }
 
 [HttpPost]
 [ValidateAntiForgeryToken]
 public async Task Insert(int ProvinceID, string Years, string SchoolName)
 {
  var item = await _context.Province.Find(p => p.ProvinceID == ProvinceID).SingleOrDefaultAsync();
  School sl = new School(SchoolName,Years);
  //添加学校
  item.SchoolName.Add(sl);
  //更新
  ReplaceOneResult actionResult
  = await _context.Province
    .ReplaceOneAsync(n => n.ProvinceID.Equals(ProvinceID)
     , item
     , new UpdateOptions { IsUpsert = true });
  return RedirectToAction(nameof(Index));
 }

视图： 

@model MongoCore.Models.Province
@{
 ViewData["Title"] = "Insert";
}

新增

然后添加学校，我添加了两所学校，在MongoDB里可以看到数据

相关文章

精彩推荐