MongoDB简单实践:Only CRUD

本文涉及的产品
云数据库 MongoDB,通用型 2核4GB
简介:

断断续续写了个关于MongoDB的简单示例,涉及到了基础的CRUD。实践的过程中,发现不少问题,尤其是新旧版本的C#驱动类库变动较大,所以有一些明显的问题自己还是摸不着头脑,记录下来,期待您的指点。

一、开发环境搭建

这个不用多废话了,可以搜索一下,有很多文章已经介绍了如何搭建开发环境。如果您想亲自尝试一下,参考官方文档的这一篇,按照说明一步一步自己在本地配置一个可开发MongoDB应用程序的windows环境。当然了,如果您的环境不是windows,可以选择这里的文档,对照设置即可。

二、实体类说明

在demo中,您可以看到一个简单的实体类Book,其中包含四个属性:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
using  System;
 
namespace  SimpleMongoDBApp
{
     using  MongoDB.Bson;
 
     [Serializable]
     public  class  Book
     {
         public  Book()
         {
         }
 
         public  Book( string  author, string  title, DateTime createDate)
         {
             this .Author = author;
             this .Title = title;
             this .CreateDate = createDate;
         }
 
         public  string  Author { get ; set ; }
 
         public  string  Title { get ; set ; }
 
         public  DateTime CreateDate { get ; set ; }
 
 
         /// <summary>
         /// 主键
         /// </summary>
         public  ObjectId Id
         {
             get ;
             set ;
         }
     }
}

需要您注意的是主键Id属性的类型是ObjectId。在增删改查中,这个Id的作用是非常重要的。

三、简单的CRUD

老实说,这没什么可说的,只是简单类库调用而已,但是实践的时候还是有一些小意外,感觉和文档说明的不一致。这里的示例主要是参考这一篇而成的。

1、增删改

这三个相对容易一些,对照文档说明,调用对应的几个方法,即可完成增删改的操作。比如对于简单的更新方法:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public  void  Update(Book query, Book dest)
  {
           string  connectionString = Config.GetCurrentMongoDBConnString();
           MongoServer server = MongoServer.Create(connectionString);
           MongoDatabase database = server.GetDatabase(Config.CurrentDBName);
           using  (server.RequestStart(database))
           {
               MongoCollection<Book> books = database.GetCollection<Book>(Config.CurrentTbName);
               QueryDocument condition = new  QueryDocument( "_id" , query.Id); //按照id更新
               Book book = books.FindOne(condition);
               if  (book != null )
               {
                   dest.Id = query.Id;
                   books.Save<Book>(dest);
               }
           }
   }

这里我使用的是Save函数,我们也可以调用文档说明中的Update方法,最终效果其实是一样的。

2、分页查询

和关系型数据库一样,查询也可以分很多种,比如精确匹配,范围查询,模糊匹配,分组查询等等。本文的示例只是进行了简单的按字段精确匹配,是最简单的一种查询。好在现在的类库都有对应的查询方法,您可以自己尝试不同种类的复杂查询试试看。对于简单的查询直接调用相关Find方法即可,分页查询我们通常通过SetSkip和SetLimit配合使用返回查询结果:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/// <summary>
/// 分页查询
/// </summary>
public  IList<Book> Select( int  currentPage, int  recordsPerPage, Book query)
{
     List<Book> listResult = new  List<Book>();
     string  connectionString = Config.GetCurrentMongoDBConnString();
     MongoServer server = MongoServer.Create(connectionString);
     MongoDatabase database = server.GetDatabase(Config.CurrentDBName);
     MongoCollection<Book> books = database.GetCollection<Book>(Config.CurrentTbName);
     QueryComplete condition = Query.And(Query.EQ( "Title" , query.Title)); //有查询结果
     //QueryComplete condition = Query.And(Query.EQ("Author", query.Author));//无查询结果
     //QueryComplete condition = Query.And(Query.EQ("Title", query.Title), Query.EQ("Author", query.Author));//无查询结果
 
     MongoCursor<Book> cursors = books.Find(condition).SetSkip((currentPage - 1) * recordsPerPage).SetLimit(recordsPerPage); // books.Find(condition);
   
     //MongoCursor<Book> cursors = books.FindAs<Book>(condition).SetSkip((currentPage - 1) * recordsPerPage).SetLimit(recordsPerPage);// books.Find(condition);
 
     //MongoCursor<Book> cursors = books.FindAll().SetSkip((currentPage - 1) * recordsPerPage).SetLimit(recordsPerPage);// books.Find(condition);
   
     listResult.AddRange(cursors);
     return  listResult;
}

实践的时候我发现一个问题,就是在尝试按照Author属性进行查询的时候,一条记录没有(实际匹配结果应该不止一条,而且比按照Title查询的匹配结果更多),但是按照Title数据又可以查询出结果,对照文档查找良久,没有找到原因,莫非又是….传说中的rp问题?郁闷。

四、老赵的EasyMongo

对于MongDB的其他相关方法,可以参考官方说明文档,类库已经非常丰富。到这里您可能已经发现了一个问题,就是我在调用MongoDB相关类库方法的时候,重复的代码较多,比如下面这一段:

1
2
3
4
5
6
7
string  connectionString = Config.GetCurrentMongoDBConnString();
   MongoServer server = MongoServer.Create(connectionString);
   MongoDatabase database = server.GetDatabase(Config.CurrentDBName);
   using  (server.RequestStart(database))
   {
       //some code here
   }

就出现不少次,那什么,大家当然想到要重构,要使用ORM,要更优雅地调用……等等等等。我当然已经发现程序中的问题,本来想自己再封装一层的,让调用更简洁舒服一些,但是自从看到了老赵的EasyMongo(原来这么强大实用的东西牛人早帮我们做好了,看了一下源码,感觉和他之前的FastReflection差不多复杂,我承认自己真的写不出来),还是直接推荐使用了吧。

最后介绍一个国内非常好的NoSQL学习资源:

http://blog.nosqlfan.com/

demo下载:MongoDBApp






本文转自JeffWong博客园博客,原文链接:http://www.cnblogs.com/jeffwongishandsome/archive/2011/04/05/2006029.html,如需转载请自行联系原作者


相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
目录
相关文章
|
4月前
|
NoSQL Java 关系型数据库
让 MongoDB 的 CRUD 有 JPA 的味道
让 MongoDB 的 CRUD 有 JPA 的味道
20 0
|
4月前
|
NoSQL 关系型数据库 MySQL
使用 MongoTemplate 对 MongoDB 进行 CRUD
使用 MongoTemplate 对 MongoDB 进行 CRUD
44 0
|
4月前
|
NoSQL JavaScript 前端开发
MongoDB【CRUD练习-条件查询-文档关系】
MongoDB【CRUD练习-条件查询-文档关系】
|
4月前
|
JSON NoSQL MongoDB
MongoDB【CRUD基本操作】
MongoDB【CRUD基本操作】
|
7月前
|
SQL NoSQL MongoDB
MongoDB 操作(CRUD) 教程—官方原版
MongoDB 操作(CRUD) 教程—官方原版
110 0
|
9月前
|
存储 SQL JSON
三.MongoDB入门-Mongodb的CRUD
MongoDB入门-Mongodb的CRUD
|
9月前
|
存储 消息中间件 SQL
Flink CDC & MongoDB 联合实时数仓的探索实践
XTransfer 技术专家, Flink CDC Maintainer 孙家宝,在 Flink Forward Asia 2022 数据集成专场的分享。
1045 0
Flink CDC & MongoDB 联合实时数仓的探索实践
|
11月前
|
消息中间件 数据采集 NoSQL
《Apache Flink 案例集(2022版)》——1.数据集成——XTransfer-基Flink MongoDB CDC 在 XTransfer 的生产实践(上)
《Apache Flink 案例集(2022版)》——1.数据集成——XTransfer-基Flink MongoDB CDC 在 XTransfer 的生产实践(上)
160 0
|
11月前
|
SQL 并行计算 NoSQL
《Apache Flink 案例集(2022版)》——1.数据集成——XTransfer-基Flink MongoDB CDC 在 XTransfer 的生产实践(下)
《Apache Flink 案例集(2022版)》——1.数据集成——XTransfer-基Flink MongoDB CDC 在 XTransfer 的生产实践(下)
197 0
|
消息中间件 NoSQL Oracle
Flink MongoDB CDC 在 XTransfer 的生产实践|Flink CDC 专题
Flink-learning 学训平台和 Flink CDC 专题课程来啦!
Flink MongoDB CDC 在 XTransfer 的生产实践|Flink CDC 专题