zoukankan      html  css  js  c++  java
  • C# 操作mongodb子文档

     1           var mongoString = "mongodb://jamesbing:123456@localhost:27017";
     2             var host = new TMongodbHostModel
     3             {
     4                 CollectionName = "ft_test",
     5                 ConnectionString = mongoString,
     6                 DatabaseName = "system_db"
     7             };
     8 
     9             var person = new Person
    10             {
    11                 Id = ObjectId.GenerateNewId(),
    12                 Name = "jamesbing",
    13                 Address = new List<AddressItem>
    14                 {
    15                     new AddressItem {Add = "英国", Id = ObjectId.GenerateNewId(), Age = 12},
    16                     new AddressItem {Add = "美国", Id = ObjectId.GenerateNewId(), Age = 19}
    17                 }
    18             };
    19             //  var addresult = TMongodbHelper.Add(host, person);
    20             var collection = TMongodbHelper.GetMongoCollection<Person>(host.ConnectionString, host.DatabaseName, host.CollectionName);
    21 
    22             //Update ChildDocument
    23             var address = "Address.$";
    24             var result = collection.Update(
    25                 Query.And(new List<IMongoQuery>
    26                 {
    27                    Query.EQ("_id", new ObjectId("577b344a87aebb23c0fc767a")),
    28                     Query.EQ("Address._id", new ObjectId("577b344a87aebb23c0fc767b")),
    29                 }), Update.Set(address + ".Age", 33));
    30 
    31 
    32             //Add ChildDocument
    33             //单个
    34             var result2 = collection.Update(Query.EQ("_id", new ObjectId("577b2d6787aebb198839d415")
    35                ), Update.Push("Address", new AddressItem { Add = "山西省运城市", Id = ObjectId.GenerateNewId() }.ToBsonDocument()));
    36 
    37             //多个
    38             var result3 = collection.Update(Query.EQ("_id", new ObjectId("577b262587aebb41fca9a3af")
    39              ), Update.PushEach("Address", new[] { new AddressItem { Add = "山西省运城市4", Id = ObjectId.GenerateNewId(), Age = 10 }.ToBsonDocument(), new AddressItem { Add = "山西省运城市5", Id = ObjectId.GenerateNewId(), Age = 9 }.ToBsonDocument() }));
    40 
    41             //Remove ChildDocument
    42             var result4 = collection.Update(Query.EQ("_id", new ObjectId("577b2d6787aebb198839d415")),
    43                Update.Pull("Address", new { Id = new ObjectId("577b2d9387aebb2d7449367f") }.ToBsonDocument()));
    44 
    45 
    46             //Query ChildDocument
    47              var query = Query.EQ("_id", new ObjectId("577b30e087aebb34ec170e7a"));
                 var q = Query.ElemMatch("Address"", Query.EQ("Add", "北京市"));     
                var result5= collection.FindOne(Query.And(query,q));

    备注:

    mongodb for C# SDK版本:1.11(可支持mongodb 3.2版本)

    mongodb版本:3.0.6

  • 相关阅读:
    WCF 订单服务(2)
    移动应用接口的授权和安全
    数据库服务器死锁的解决方法 (转)
    WCF 订单服务(3)
    sqlservice 表分区方法
    基于.NET解决方案的架构和框架
    IIS7架构原理
    多线程的同步和通信
    【原创】关于wince OS开发面试问题的总结系列之OAL
    【原创】关于noot的学习笔记
  • 原文地址:https://www.cnblogs.com/gaobing/p/5667021.html
Copyright © 2011-2022 走看看