.netCore连接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; }
 }
}

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)
  
  

  新 增  
  详 情  
  删 除  
  
 

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

 

 
  

  

  省份ID
  
  
  

  省份名称
  
  
  

  
  
 
 

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";
}
新增

 

 
  

  
  

  学校名称
  
  
  

  成立年份