MongoDB学习笔记(四)用MongoDB的文档结构描述数据关系

MongoDB的集合（collection）可以看做关系型数据库的表，文档对象（document）可以看做关系型数据库的一条记录。但两者并不完全对等。表的结构是固定的，MongoDB集合并没有这个约束；另外，存入集合的文档对象甚至可以嵌入子文档，或者“子集合”。他们最终都可以用类似于BJSON的格式描述。我们今天就来分析MongoDB这一特性带来的独特数据管理方式。我们还是以samus驱动为例来分析，samus驱动支持两种方式访问数据库，基本方式和linq方式，基本方式在上篇以介绍过，linq方式我不想单独讲解应用实例，这篇我会用两种方式来对比介绍。

一、包含子文档的集合操作
有这么一个应用场景，某网站提供会员登录的功能，用户需要注册账号才能享受会员服务，但是注册者可能会因为用户资料表单输入项过大而放弃填写，因此用户信息分为主要资料和详细资料两项，初次注册只需要填写主要资料就行了。我们打算把详细信息设计为子文档存储。

1) linq方式实现

1. 新建数据描述类，描述用户信息

 
 
 
    
  
  
  
  1. ///     
    2.   
  
  
  2. /// 用户主要资料    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public class UserInfo    
    5.   
  
  
  5. {    
    6.   
  
  
  6.     public string UserId { get; set; }    
    7.   
  
  
  7.     public string UserName { get; set; }    
    8.   
  
  
  8.     public string PassWord { get; set; }    
    9.   
  
  
  9.     public Detail Detail { get; set; }    
    10.   
  
  
  10. }    
    11.   
  
  
  11. ///     
    12.   
  
  
  12. /// 用户详细资料    
    13.   
  
  
  13. ///     
    14.   
  
  
  14. public class Detail    
    15.   
  
  
  15. {    
    16.   
  
  
  16.     public string Address { get; set; }    
    17.   
  
  
  17.     public int Age { get; set; }    
    18.   
  
  
  18.     public string Email { get; set; }    
    19.   
  
  
  19. }   
    20.   
  
  
  20.  
    21.

2. 我们要新建一个用户业务操作类“UserBLL”。这个时候要让驱动知道UserInfo类描述了“用户资料”的字段信息，在GetMongo()方法实现了配置步骤，UserBLL完整代码如下：

 
 
 
    
  
  
  
  1. public class UserBLL    
    2.   
  
  
  2. {    
    3.   
  
  
  3.     public string connectionString = "mongodb://localhost";    
    4.   
  
  
  4.     public string databaseName = "myDatabase";    
    5.   
  
  
  5.     private Mongo mongo;    
    6.   
  
  
  6.     private MongoDatabase mongoDatabase;    
    7.   
  
  
  7.     //注意这里泛型类型为“UserInfo”    
    8.   
  
  
  8.     private MongoCollection mongoCollection;    
    9.   
  
  
  9.     public UserBLL()    
    10.   
  
  
  10.     {    
    11.   
  
  
  11.         mongo = GetMongo();    
    12.   
  
  
  12.         mongoDatabase = mongo.GetDatabase(databaseName) as MongoDatabase;    
    13.   
  
  
  13.         mongoCollection = mongoDatabase.GetCollection() as MongoCollection;    
    14.   
  
  
  14.         mongo.Connect();    
    15.   
  
  
  15.     }    
    16.   
  
  
  16.     ~UserBLL()    
    17.   
  
  
  17.     {    
    18.   
  
  
  18.         mongo.Disconnect();    
    19.   
  
  
  19.     }    
    20.   
  
  
  20.     ///     
    21.   
  
  
  21.     /// 配置Mongo,将类UserInfo映射到集合    
    22.   
  
  
  22.     ///     
    23.   
  
  
  23.     private Mongo GetMongo()    
    24.   
  
  
  24.     {    
    25.   
  
  
  25.         var config = new MongoConfigurationBuilder();    
    26.   
  
  
  26.         config.Mapping(mapping =>    
    27.   
  
  
  27.         {    
    28.   
  
  
  28.             mapping.DefaultProfile(profile =>    
    29.   
  
  
  29.             {    
    30.   
  
  
  30.                 profile.SubClassesAre(t => t.IsSubclassOf(typeof(UserInfo)));    
    31.   
  
  
  31.             });    
    32.   
  
  
  32.             mapping.Map();    
    33.   
  
  
  33.         });    
    34.   
  
  
  34.         config.ConnectionString(connectionString);    
    35.   
  
  
  35.         return new Mongo(config.BuildConfiguration());    
    36.   
  
  
  36.     }    
    37.   
  
  
  37. }   
    38.   
  
  
  38.  
    39.

3. 接着，在“UserBLL”类中定义一个方法“InsertSomeData()”来插入一些数据：

 
 
 
    
  
  
  
  1. ///     
    2.   
  
  
  2. /// 插入一些数据    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public void InsertSomeData()    
    5.   
  
  
  5. {    
    6.   
  
  
  6.    UserInfo userInfo1 = new UserInfo()    
    7.   
  
  
  7.    {    
    8.   
  
  
  8.        UserId = "1001",    
    9.   
  
  
  9.        UserName = "张三",    
    10.   
  
  
  10.        PassWord = "123456"   
    11.   
  
  
  11.    };    
    12.   
  
  
  12.    mongoCollection.Save(userInfo1);    
    13.   
  
  
  13.    UserInfo userInfo2 = new UserInfo()    
    14.   
  
  
  14.    {    
    15.   
  
  
  15.        UserId = "1002",    
    16.   
  
  
  16.        UserName = "李四",    
    17.   
  
  
  17.        PassWord = "123456",    
    18.   
  
  
  18.        Detail = new Detail()    
    19.   
  
  
  19.        {    
    20.   
  
  
  20.            Address = "湖北",    
    21.   
  
  
  21.            Age = 20,    
    22.   
  
  
  22.            Email = "lisi@163.com"   
    23.   
  
  
  23.        }    
    24.   
  
  
  24.    };    
    25.   
  
  
  25.    mongoCollection.Save(userInfo2);    
    26.   
  
  
  26.    UserInfo userInfo3 = new UserInfo()    
    27.   
  
  
  27.    {    
    28.   
  
  
  28.        UserId = "1003",    
    29.   
  
  
  29.        UserName = "王五",    
    30.   
  
  
  30.        PassWord = "123456",    
    31.   
  
  
  31.        Detail = new Detail()    
    32.   
  
  
  32.        {    
    33.   
  
  
  33.            Address = "广东",    
    34.   
  
  
  34.            Age = 20,    
    35.   
  
  
  35.            Email = "wangwu@163.com"   
    36.   
  
  
  36.        }    
    37.   
  
  
  37.    };    
    38.   
  
  
  38.    mongoCollection.Save(userInfo3);    
    39.   
  
  
  39.    UserInfo userInfo4 = new UserInfo()    
    40.   
  
  
  40.    {    
    41.   
  
  
  41.        UserId = "1004",    
    42.   
  
  
  42.        UserName = "赵六",    
    43.   
  
  
  43.        PassWord = "123456",    
    44.   
  
  
  44.        Detail = new Detail()    
    45.   
  
  
  45.        {    
    46.   
  
  
  46.            Address = "湖北"   
    47.   
  
  
  47.         }    
    48.   
  
  
  48.    };    
    49.   
  
  
  49.    mongoCollection.Save(userInfo4);    
    50.   
  
  
  50. }   
    51.

4. 定义一个查找数据的方法“Select”，它将查找用户详细信息中，地址在湖北的全部用户：

 
 
 
    
  
  
  
  1.     
    2.   
  
  
  2. /// 查询详细资料地址为湖北的用户信息    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public List Select()    
    5.   
  
  
  5. {    
    6.   
  
  
  6.     return mongoCollection.Linq().Where(x => x.Detail.Address == "湖北").ToList();    
    7.   
  
  
  7. }   
    8.

5. 还定义一个删除数据的方法，将删除集合全部数据：

 
 
 
    
  
  
  
  1. ///     
    2.   
  
  
  2. /// 删除全部用户信息    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public void DeleteAll()    
    5.   
  
  
  5. {    
    6.   
  
  
  6.     mongoCollection.Remove(x => true);    
    7.   
  
  
  7. }   
    8.

6. 在Main方法中添加如下代码：

 
 
 
    
  
  
  
  1. static void Main(string[] args)    
    2.   
  
  
  2. {    
    3.   
  
  
  3.     UserBLL userBll = new UserBLL();    
    4.   
  
  
  4.     userBll.InsertSomeData();    
    5.   
  
  
  5.     var users = userBll.Select();    
    6.   
  
  
  6.     foreach (var user in users)    
    7.   
  
  
  7.     {    
    8.   
  
  
  8.         Console.WriteLine(user.UserName + "是湖北人");    
    9.   
  
  
  9.     };    
    10.   
  
  
  10.     userBll.DeleteAll();    
    11.   
  
  
  11. }   
    12.

7. ***执行程序，打印如下信息：
李四是湖北人 
赵六是湖北人
1) 普通实现
普通方式实现不想多讲，直接贴代码，看看与linq方式有什么区别：

 
 
 
    
  
  
  
  1. class Program    
    2.   
  
  
  2. {    
    3.   
  
  
  3.     static void Main(string[] args)    
    4.   
  
  
  4.     {    
    5.   
  
  
  5.         UserBLL userBll = new UserBLL();    
    6.   
  
  
  6.         userBll.InsertSomeData();    
    7.   
  
  
  7.         var users = userBll.Select();    
    8.   
  
  
  8.         foreach (var user in users)    
    9.   
  
  
  9.         {    
    10.   
  
  
  10.             Console.WriteLine(user["UserName"].ToString() + "是湖北人");    
    11.   
  
  
  11.         };    
    12.   
  
  
  12.         userBll.DeleteAll();    
    13.   
  
  
  13.         Console.ReadLine();    
    14.   
  
  
  14.     }    
    15.   
  
  
  15. }    
    16.   
  
  
  16. public class UserBLL    
    17.   
  
  
  17. {    
    18.   
  
  
  18.     public string connectionString = "mongodb://localhost";    
    19.   
  
  
  19.     public string databaseName = "myDatabase";    
    20.   
  
  
  20.     public string collectionName = "UserInfo";    
    21.   
  
  
  21.     private Mongo mongo;    
    22.   
  
  
  22.     private MongoDatabase mongoDatabase;    
    23.   
  
  
  23.     private MongoCollection mongoCollection;     
    24.   
  
  
  24.     public UserBLL()    
    25.   
  
  
  25.     {    
    26.   
  
  
  26.         mongo = new Mongo(connectionString);    
    27.   
  
  
  27.         mongoDatabase = mongo.GetDatabase(databaseName) as MongoDatabase;    
    28.   
  
  
  28.         mongoCollection = mongoDatabase.GetCollection(collectionName) as MongoCollection;    
    29.   
  
  
  29.         mongo.Connect();    
    30.   
  
  
  30.     }    
    31.   
  
  
  31.     ~UserBLL()    
    32.   
  
  
  32.     {    
    33.   
  
  
  33.         mongo.Disconnect();    
    34.   
  
  
  34.     }    
    35.   
  
  
  35.     ///     
    36.   
  
  
  36.     /// 插入一些数据    
    37.   
  
  
  37.     ///     
    38.   
  
  
  38.     public void InsertSomeData()    
    39.   
  
  
  39.     {    
    40.   
  
  
  40.         Document userInfo1 = new Document();    
    41.   
  
  
  41.         userInfo1["UserId"] = "1001";    
    42.   
  
  
  42.         userInfo1["UserName"] = "张三";    
    43.   
  
  
  43.         userInfo1["PassWord"] = "123456";    
    44.   
  
  
  44.         mongoCollection.Save(userInfo1);    
    45.   
  
  
  45.         Document userInfo2 = new Document();    
    46.   
  
  
  46.         userInfo2["UserId"] = "1002";    
    47.   
  
  
  47.         userInfo2["UserName"] = "李四";    
    48.   
  
  
  48.         userInfo2["PassWord"] = "123456";    
    49.   
  
  
  49.         //子文档    
    50.   
  
  
  50.         var userInfo2Detail = new Document();    
    51.   
  
  
  51.         userInfo2Detail["Address"] = "湖北";    
    52.   
  
  
  52.         userInfo2Detail["Age"] = 20;    
    53.   
  
  
  53.         userInfo2Detail["Email"] = "lisi@163.com";    
    54.   
  
  
  54.         userInfo2["Detail"] = userInfo2Detail;    
    55.   
  
  
  55.         mongoCollection.Save(userInfo2);    
    56.   
  
  
  56.         Document userInfo3 = new Document();    
    57.   
  
  
  57.         userInfo3["UserId"] = "1003";    
    58.   
  
  
  58.         userInfo3["UserName"] = "王五";    
    59.   
  
  
  59.         userInfo3["PassWord"] = "123456";    
    60.   
  
  
  60.         var userInfo3Detail = new Document();    
    61.   
  
  
  61.         userInfo3Detail["Address"] = "广东";    
    62.   
  
  
  62.         userInfo3Detail["Age"] = 20;    
    63.   
  
  
  63.         userInfo3Detail["Email"] = "wangwu@163.com";    
    64.   
  
  
  64.         userInfo3["Detail"] = userInfo3Detail;    
    65.   
  
  
  65.         mongoCollection.Save(userInfo3);    
    66.   
  
  
  66.         Document userInfo4 = new Document();    
    67.   
  
  
  67.         userInfo4["UserId"] = "1004";    
    68.   
  
  
  68.         userInfo4["UserName"] = "赵六";    
    69.   
  
  
  69.         userInfo4["PassWord"] = "123456";    
    70.   
  
  
  70.         var userInfo4Detail = new Document();    
    71.   
  
  
  71.         userInfo4Detail["Address"] = "湖北";    
    72.   
  
  
  72.         userInfo4["Detail"] = userInfo4Detail;    
    73.   
  
  
  73.         mongoCollection.Save(userInfo4);    
    74.   
  
  
  74.     }    
    75.   
  
  
  75.     ///     
    76.   
  
  
  76.     /// 查询详细资料地址为湖北的用户信息    
    77.   
  
  
  77.     ///     
    78.   
  
  
  78.     public IEnumerable Select()    
    79.   
  
  
  79.     {    
    80.   
  
  
  80.         return mongoCollection.Find(new Document { { "Detail.Address", "湖北" } }).Documents;    
    81.   
  
  
  81.     }    
    82.   
  
  
  82.     ///     
    83.   
  
  
  83.     /// 删除全部用户信息    
    84.   
  
  
  84.     ///     
    85.   
  
  
  85.     public void DeleteAll()    
    86.   
  
  
  86.     {    
    87.   
  
  
  87.         mongoCollection.Remove(new Document { });    
    88.   
  
  
  88.     }    
    89.   
  
  
  89. }   
    90.

***，我们通过这段代码输出全部用户资料信息的BJSON格式：

 
 
 
    
  
  
  
  1. ///     
    2.   
  
  
  2. /// 打印数据BJSON    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public void PrintBJSON()    
    5.   
  
  
  5. {    
    6.   
  
  
  6.     string BJSON = string.Empty;    
    7.   
  
  
  7.     foreach (var documet in mongoCollection.FindAll().Documents)    
    8.   
  
  
  8.     {    
    9.   
  
  
  9.         BJSON += documet.ToString();    
    10.   
  
  
  10.     }    
    11.   
  
  
  11.     Console.WriteLine(BJSON);    
    12.   
  
  
  12. }   
    13.   
  
  
  13.  
    14.   
  
  
  14. 结果如下：  
    15.   
  
  
  15. { "UserId": "1001", "UserName": "张三", "PassWord": "123456", "_id": "4d80ec1ab8a4731338000001" }    
    16.   
  
  
  16. { "UserId": "1002", "UserName": "李四", "PassWord": "123456", "Detail": { "Address": "湖北", "Age": 20, "Email": "lisi@163.com" }, "_id": "4d80ec1ab8a4731338000002" }    
    17.   
  
  
  17. { "UserId": "1003", "UserName": "王五", "PassWord": "123456", "Detail": { "Address": "广东", "Age": 20, "Email": "wangwu@163.com" }, "_id": "4d80ec1ab8a4731338000003" }    
    18.   
  
  
  18. { "UserId": "1004", "UserName": "赵六", "PassWord": "123456", "Detail": { "Address": "湖北" }, "_id": "4d80ec1ab8a4731338000004" }   
    19.   
  
  
  19.  
    20.

#p#

二、包含“子集合”的集合操作

同样举个例子：有一个学校人事管理系统要统计班级和学生的信息，现在定义了一个“班级集合”，这个集合里面的学生字段是一个“学生集合”，包含了本班全部学生。

1) linq方式实现

基础配置我就不多说了，数据类定义如下：

 
 
 
    
  
  
  
  1. ///     
    2.   
  
  
  2. /// 班级信息    
    3.   
  
  
  3. ///     
    4.   
  
  
  4. public class ClassInfo    
    5.   
  
  
  5. {    
    6.   
  
  
  6.     public string ClassName { get; set; }    
    7.   
  
  
  7.     public List Students { get; set; }    
    8.   
  
  
  8. }    
    9.   
  
  
  9. ///     
    10.   
  
  
  10. /// 学生信息    
    11.   
  
  
  11. ///     
    12.   
  
  
  12. public class Student    
    13.   
  
  
  13. {    
    14.   
  
  
  14.     public string Name { get; set; }    
    15.   
  
  
  15.     public int Age { get; set; }    
    16.   
  
  
  16. }   
    17.   
  
  
  17.  
    18.

查询叫“张三”的学生在哪个班级，以及他的详细信息：

(这里其实是ToList后在内存中查的,linq方式直接查询好像驱动不支持。)

 
 
 
    
  
  
  
  1. public List Select()    
    2.   
  
  
  2. {    
    3.   
  
  
  3.    return mongoCollection.Linq().ToList().Where(x => x.Students.Exists(s => s.Name == "张三")).ToList();    
    4.   
  
  
  4. }   
    5.   
  
  
  5.  
    6.

 1) 普通实现

查询叫“张三”的学生在哪个班级，以及他的详细信息：

 
 
 
    
  
  
  
  1. public List Select()    
    2.   
  
  
  2. {    
    3.   
  
  
  3.    var mongocollection = mongoDatabase.GetCollection("ClassInfo");    
    4.   
  
  
  4.    return mongocollection.Find(new Document { { "Students.Name", "张三" } }).Documents.ToList();    
    5.   
  
  
  5. }   
    6.   
  
  
  6.  
    7.

打印数据的BJSON：

 
 
 
    
  
  
  
  1. { "_id": "4d814bae5c5f000000005f63", "ClassName": "1001", "Students": [ { "Name": "张三", "Age": 10 }, { "Name": "李四", "Age": 0 } ] }    
    2.   
  
  
  2. { "_id": "4d814bae5c5f000000005f64", "ClassName": "1002", "Students": [ ] }    
    3.   
  
  
  3. { "_id": "4d814bae5c5f000000005f65", "ClassName": "1003", "Students": [ { "Name": "王五", "Age": 11 }, { "Name": "赵六", "Age": 9 } ] }   
    4.   
  
  
  4.  
    5.

三、小结

通过本节例子我们发现，MongoDB有它独特的文档结构可以描述数据对象之间的一些关系特征。它虽然没有关系型数据库多表符合查询那样强大的表间查询方式，但也可以通过文档结构描述更灵活的关系特性，可以这么说，关系型数据库能做的，MongoDB基本上也可以做到。甚至有些关系数据库不容易做到的，MongoDB也可以轻松做到，比如，描述数据类的继承关系等

原文链接：http://www.cnblogs.com/lipan/archive/2011/03/17/1986616.html

本文名称：MongoDB学习笔记(四)用MongoDB的文档结构描述数据关系
文章源于：http://www.csdahua.cn/qtweb/news9/358059.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

网站维护知识

分类信息网

南充网站建设　　 　成都翻译公司　　 　上市集团网站建设　　 　重庆网站建设　　 　公路钻孔机　　 　成都小程序制作　　 　乐山做网站　　 　鑫友邦火锅桌　　 　成都宣传海报　　 　升施印刷　　 　网络推广　　 　IOS开发　　 　眉山托管服务器　　 　成都做网站　　 　网站空间　　 　四川国泰民安消防　　 　重庆机房托管　　 　众诚伟业　　 　四川和正源　　 　软文发布平台