本文来自zvvq
一、前言及MongoDB的介绍
最近在整合自己的框架,顺便把MongoDBD的最简单CRUD重构一下作为组件化集成到asp.net core项目中,当然此篇文章中没有讲解mongodb的集群部署,等有机会分享一下。 内容来自samhan
首先,我们在MongoDB的官方文档中看到,MongoDb的2.4以上的For .Net的驱动是支持.Net Core 2.0的。 本文来自zvvq
内容来自samhan
针对MongoDB,我想大家应该不陌生,没有用过也有听过。 zvvq好,好zvvq
相关学习推荐:ASP.NET视频教程1、mongodb是什么? zvvq.cn
MongoDB是一个基于分布式文件存储的数据库,为web应用提供可扩展的高性能数据存储解决方案,介于关系型数据库和非关系型数据库的产品,是非关系型数据库中功能最丰富的。针对于数据处理是一把利器。 内容来自zvvq
2、什么是关系型数据库和非关系型数据库? zvvq好,好zvvq
关系型数据库:在我们所用过的sqlserver、mysql等,这些都是关系型数据库,并且关系型数据库是遵循ACID原则的,严格的一致性。
非关系型数据库:也叫作NoSQL,用与超大规模数据的存储,这些类型的数据存储不需要固定的模式,无需多余的操作就可以横向扩展。 内容来自zvvq,别采集哟
3、RDBMS VS NoSQL copyright zvvq
RDBMS: 内容来自zvvq
高度组织结构化数据
内容来自samhan666
结构化查询语言 copyright zvvq
数据和关系都存储在单独的表中 zvvq.cn
严格一致性
基础事务 zvvq
NoSQL: 内容来自zvvq,别采集哟
没有声明性查询语言
zvvq好,好zvvq
键-值对存储,列存储、文档存储等
最终一致性 zvvq.cn
非结构化和不可预知数据 内容来自samhan
CAP定理、高可用、高性能、高扩展 内容来自samhan666
我相信讲到这里,眼尖的同学应该有注意到 CAP定理和最终一致性,肯定会联想到 分布式系统,在这里给你大大的一个赞。在分布式系统中可以完美的结合nosql,提高我们的性能。
4、介绍一下RDBMS与Mongodb的一些概念,有助于帮助大家理解
zvvq.cn
zvvq.cn
翻译一下,即如下:
内容来自samhan666
二、asp.net core集成mongoDB
zvvq好,好zvvq
1、为了演示方便我下载了 windows版本的mongodb server zvvq
大家可以自行去官网下载,然后针对于可视化界面,我采用了 Robo 3T 这个工具。很简洁美观的可视化工具。推荐大家使用。
安装结束后会在windows服务中看到mongodb server
内容来自samhan666
内容来自samhan
然后我们打开一下Robo 3T,连接我们的mongodb。
本文来自zvvq
2、开始在项目中配置一下我们的mongodb吧
第一步:我新建一个Core2.0类库 内容来自zvvq,别采集哟
引入了 “MongoDB.Driver” 这个nuget包。 zvvq好,好zvvq
然后扩展了 Startup.cs 中的Services的扩展方法 zvvq
1
copyright zvvq
2 zvvq
3 内容来自zvvq,别采集哟
4 copyright zvvq
5 内容来自samhan666
6 zvvq
7 zvvq好,好zvvq
8 内容来自samhan
9
zvvq
10
11 zvvq好,好zvvq
//扩展方法public static class ServiceCollectionExtensions
内容来自zvvq,别采集哟
{
zvvq好,好zvvq
public static void AddMongoDB(this IServiceCollection services, IConfiguration configuration) zvvq
{
services.Configure<Settings>(options => 内容来自zvvq
{ 内容来自samhan
options.ConnectionString = configuration.GetSection("MongoConnection:ConnectionString").Value;
options.Database = configuration.GetSection("MongoConnection:Database").Value; 内容来自samhan666
}); copyright zvvq
} zvvq.cn
} zvvq
第二步:重构封装了mongodb的CRUD类,此处大家可以自行封装,只展示了查找和新增。
内容来自zvvq,别采集哟
1 本文来自zvvq
2 zvvq好,好zvvq
3
4 内容来自samhan
5 本文来自zvvq
6 内容来自zvvq
7
8 zvvq
9
10
11
12
13 内容来自samhan
14 zvvq好,好zvvq
15
内容来自zvvq
16
内容来自zvvq
17 内容来自samhan666
18
19 本文来自zvvq
20 zvvq
21
内容来自zvvq
22
23
24
zvvq好,好zvvq
25 内容来自samhan666
26
内容来自zvvq,别采集哟
27 zvvq.cn
28 本文来自zvvq
29 copyright zvvq
30
31
32 zvvq好,好zvvq
33 内容来自samhan666
34 zvvq.cn
35
zvvq.cn
36
37
内容来自zvvq,别采集哟
38 内容来自zvvq
39 copyright zvvq
40 本文来自zvvq
41
内容来自samhan666
42
43
public class MongoDBBase
copyright zvvq
{ zvvq.cn
private readonly IMongoDatabase _database = null; 内容来自zvvq
public MongoDBBase(string connectionString, string databaseName)
zvvq好,好zvvq
{
var client = new MongoClient(connectionString);
if (client != null) 内容来自samhan666
{ copyright zvvq
_database = client.GetDatabase(databaseName); zvvq.cn
} 内容来自zvvq,别采集哟
}
内容来自zvvq,别采集哟
#region SELECT
zvvq好,好zvvq
/// <summary> zvvq.cn
/// 根据查询条件,获取数据
zvvq.cn
/// </summary>
/// <typeparam name="T"></typeparam> 内容来自samhan666
/// <param name="id"></param> 内容来自samhan
/// <returns></returns> zvvq
public List<T> GetList<T>(Expression<Func<T, bool>> conditions = null) copyright zvvq
{
zvvq.cn
var collection = _database.GetCollection<T>(typeof(T).Name); 内容来自samhan666
if (conditions != null) zvvq.cn
{ 内容来自zvvq,别采集哟
return collection.Find(conditions).ToList();
内容来自samhan666
} zvvq.cn
return collection.Find(_ => true).ToList();
}#endregion 内容来自samhan666
#region INSERT/// <summary> 本文来自zvvq
/// 插入多条数据,数据用list表示
zvvq好,好zvvq
/// </summary> zvvq
/// <typeparam name="T"></typeparam>
/// <param name="list"></param> 本文来自zvvq
/// <returns></returns> copyright zvvq
public List<T> InsertMany<T>(List<T> list) 本文来自zvvq
{
内容来自zvvq
var collection = _database.GetCollection<T>(typeof(T).Name);
collection.InsertMany(list);
内容来自samhan
return list; copyright zvvq
} zvvq
#endregion
} 本文来自zvvq
第三步:新建一个asp.net core webapi 项目,引用此类库进行演示 内容来自zvvq
在项目中的 appsetting.json 添加 mongodb的连接字符串:我在这边使用自定义的一个数据名称 testdb,在插入mongodb的时候会会自动在创建数据库和集合以及文档。接着往下看
本文来自zvvq
1 内容来自zvvq,别采集哟
2
zvvq
3
4
内容来自samhan
5 zvvq好,好zvvq
"MongoConnection": { //mongodb数据库连接
"ConnectionString": "mongodb://127.0.0.1:27017",
本文来自zvvq
"Database": "testdb", zvvq
"IsSSL": true
},
copyright zvvq
第四步:新建一个mongodb测试控制器,展示了插入单条和多条以及查询的接口。 内容来自samhan666
1
2
本文来自zvvq
3 内容来自zvvq
4 本文来自zvvq
5
内容来自zvvq
6 zvvq好,好zvvq
7 copyright zvvq
8 zvvq好,好zvvq
9
zvvq.cn
10 本文来自zvvq
11
12 zvvq
13
内容来自samhan666
14
15
16
内容来自samhan666
17 内容来自zvvq,别采集哟
18
19
内容来自samhan666
20 zvvq.cn
21 内容来自samhan
22 copyright zvvq
23
内容来自samhan
24
内容来自zvvq,别采集哟
25
26 zvvq好,好zvvq
27 zvvq
28
zvvq
29
内容来自zvvq,别采集哟
30 内容来自zvvq
31 zvvq.cn
32 内容来自zvvq,别采集哟
33 zvvq
34 本文来自zvvq
35 内容来自zvvq,别采集哟
36 内容来自zvvq
37 内容来自zvvq
38 zvvq.cn
39
zvvq好,好zvvq
40 内容来自samhan
41 zvvq
42
43 内容来自zvvq
44 内容来自zvvq
45 内容来自samhan
46 内容来自samhan
47
48
49
本文来自zvvq
50 本文来自zvvq
51
内容来自samhan
52
53
内容来自samhan666
54
55
内容来自samhan666
56
本文来自zvvq
57 zvvq好,好zvvq
58
59
内容来自zvvq,别采集哟
60 zvvq好,好zvvq
61 内容来自zvvq,别采集哟
62 内容来自zvvq
63
zvvq.cn
64 zvvq
65 内容来自samhan
66 内容来自samhan
67 本文来自zvvq
68 内容来自zvvq,别采集哟
69
70 内容来自zvvq
71
内容来自samhan
72 本文来自zvvq
73 copyright zvvq
74
内容来自zvvq,别采集哟
75
76
内容来自zvvq
77 本文来自zvvq
[Produces("application/json")]
copyright zvvq
[Route("api/MongoDB/[action]")]
copyright zvvq
public class MongoDBController : Controller zvvq
{
内容来自zvvq,别采集哟
private readonly MongoDBBase _context = null; zvvq.cn
public MongoDBController(IOptions<Settings> settings)
zvvq.cn
{ zvvq好,好zvvq
_context = new MongoDBBase(settings.Value.ConnectionString, settings.Value.Database);
本文来自zvvq
}
[HttpGet]
public IActionResult AddList() 本文来自zvvq
{ 内容来自samhan666
List<MongoDBPostTest> list = new List<MongoDBPostTest>()
{
new MongoDBPostTest() 本文来自zvvq
{ zvvq.cn
Id = "2", 内容来自samhan666
Body = "Test note 3", zvvq.cn
UpdatedOn = DateTime.Now,
UserId = 1,
内容来自samhan666
HeaderImage = new NoteImage
{
ImageSize = 10, 内容来自samhan
Url = "http://localhost/image1.png", zvvq好,好zvvq
ThumbnailUrl = "http://localhost/image1_small.png"
}
内容来自samhan
},
内容来自samhan
new MongoDBPostTest() 内容来自zvvq,别采集哟
{
Id = "3", 内容来自zvvq
Body = "Test note 4", zvvq
UpdatedOn = DateTime.Now, copyright zvvq
UserId = 1, zvvq好,好zvvq
HeaderImage = new NoteImage
内容来自samhan
{
内容来自samhan
ImageSize = 14,
Url = "http://localhost/image3.png", 本文来自zvvq
ThumbnailUrl = "http://localhost/image3_small.png"
}
内容来自samhan666
} 内容来自zvvq
}; 本文来自zvvq
try
{
_context.InsertMany(list); 内容来自samhan666
}
catch (Exception ex)
zvvq好,好zvvq
{
throw; zvvq好,好zvvq
} copyright zvvq
return Ok("成功"); zvvq.cn
}
内容来自samhan
[HttpGet] copyright zvvq
public Result<List<MongoDBPostTest>> SelectSingle()
{ 内容来自samhan
//无条件
var list = _context.GetList<MongoDBPostTest>();
//有条件
内容来自samhan666
//var list = _context.GetList<MongoDBPostTest>(a => a.Id == "1");
//得到单条数据,无条件 本文来自zvvq
//var list = _context.GetSingle<MongoDBPostTest>(); 内容来自zvvq
//得到单条数据,有条件 内容来自zvvq
//var list = _context.GetSingle<MongoDBPostTest>(a => a.Id == "3");
内容来自zvvq
ObjectId internalId = _context.GetInternalId("5bbf41651d3b66668cbb5bfc");
内容来自zvvq,别采集哟
var a = _context.GetSingle<MongoDBPostTest>(note => note.Id == "5bbf41651d3b66668cbb5bfc" || note.InternalId == internalId); 内容来自samhan
return ResHelper.Suc(1, list, "成功"); zvvq
}
内容来自samhan
}
测试类 本文来自zvvq
1 内容来自zvvq
2 zvvq
3 本文来自zvvq
4 内容来自zvvq,别采集哟
5 内容来自zvvq
6
zvvq
7
8 内容来自samhan666
9 内容来自samhan
10 本文来自zvvq
11
12
zvvq.cn
13
14
15 内容来自zvvq,别采集哟
16 内容来自zvvq
17 zvvq好,好zvvq
18 copyright zvvq
19
20
21
22 zvvq好,好zvvq
23
public class MongoDBPostTest zvvq
{ 内容来自samhan666
[BsonId]
// standard BSonId generated by MongoDb zvvq好,好zvvq
public ObjectId InternalId { get; set; }
public string Id { get; set; }
本文来自zvvq
public string Body { get; set; } = string.Empty; 内容来自zvvq,别采集哟
[BsonDateTimeOptions] copyright zvvq
public DateTime UpdatedOn { get; set; } = DateTime.Now; 内容来自samhan
public NoteImage HeaderImage { get; set; }
public int UserId { get; set; } = 0; 本文来自zvvq
} 内容来自zvvq
public class NoteImage 内容来自samhan666
{
public string Url { get; set; } = string.Empty; 内容来自samhan
public string ThumbnailUrl { get; set; } = string.Empty; 内容来自samhan666
public long ImageSize { get; set; } = 0L; 本文来自zvvq
}
第五步:运行项目,执行一下。 本文来自zvvq
我们执行一下插入多条的数据吧,执行成功。
内容来自samhan
zvvq.cn
然后我们看一下数据库,发现已经生成了一个 testdb 数据库,里面包含了我们的数据内容
然后我们执行以下查的操作:把我们刚才插入的数据返回回来了。 copyright zvvq
zvvq好,好zvvq
注意:这边有一个坑有待解决,就是mongodb存储的时间是UTC,会跟我们的本地时间相差8个小时。因此这边需要特殊处理一下时间。 copyright zvvq
三、总结 zvvq.cn
至此,mongodb的简单运用已演示完毕,后期大家根据官方文档可进行扩展,越扩展到后面,会觉得越来越有意思。感谢大家的支持。Thank you。
以上就是学习asp.net core集成MongoDB的完整步骤的详细内容,更多请关注其它相关文章! 内容来自zvvq