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

  • 相关阅读:
    Unity3D-光照贴图技术
    登岳麓山
    第一个OC程序
    Unity3D之碰撞体,刚体
    TypeError: 'stepUp' called on an object that does not implement interface HTMLInputElement
    QQ互联登录回调路径错误redirect uri is illegal(100010)
    Quartz.Net使用
    C# 文件相关操作
    微信扫码支付模式一和模式二的区别
    ankhSVN安装后,VS2010使用
  • 原文地址:https://www.cnblogs.com/gaobing/p/5667021.html
Copyright © 2011-2022 走看看