增加和删除改文书档案上,MongoDB学习笔记3

目录

插入insert

插入insert

MongoDB是文书档案型数据库,各类文档(doc)表示数据的一项记录。相比较关系型DB的row只好接纳不难的数据类型,doc可以利用复杂的数据类型:内嵌doc,数组。MongoDB的数组是壹多级元素的集纳,使用中括号
[] 表示数组,例如:[1,2,3]的成分是整数值,[{name:”t5″},
{name:”t7″}],[ {name:”t5″, age:21}, {name:”t7″, age:22}
]的因素是doc。

  • 一、前言
    • (1)
      运行条件
  • 2、先前时代准备干活
    • (壹) 成立 MongoDBContext
      MongoDb操作上下文类
    • (二)成立测试类
    • (三)
      创造测试代码
  • 3、内嵌数组增新币素操作
    • (1) Update.Set()方法
      替换内嵌数组(不引进应用)
    • (二)Update.Push()方法
      直接将成分压入内嵌数组(推荐)
    • (三) Update.PushEach()方法
      将多个因素压入内嵌数组(推荐)
  • 四、内嵌数组删除成分操作
    • (一) Update.Set()方法
      替换内嵌数组(不引进应用)
    • (2) Update.Pull()方法
      Pull删除二个因素(推荐)
    • (3)Update.PullFilter()方法
      删除过滤器删除成分(推荐)
  • 五、内嵌数组修改成分操作
    • (一) Update.Set()
      Set先查询后修改(不引进)
    • (贰) Update.Set()
      协作过滤器修改(推荐)
  • 陆、内嵌数组查找成分操作(Linq)
    • (1)Linq查询一条记下(推荐)
    • (二)Linq查询分页
      (推荐)
  • 七、总结

单条插入

> db.foo.insert({"bar":"baz"})
WriteResult({ "nInserted" : 1 })

单条插入

> db.foo.insert({"bar":"baz"})
WriteResult({ "nInserted" : 1 })

在MongoDB中,数组成分允许再一次,成分的地点是原则性的。尽管几个数组相等,那么这三个数组的成分和及其地方都一致。

一、前言

本教程是入门基础教程,主要是笔者在项目中使用MongoDB .Net官方驱动对MongoDB内嵌文档的操作时遇到了很多不方便的情况,踩了很多的坑,所以单独整理出来一篇文章,来讲一讲笔者踩坑的过程。

小编水平有限,如有错误还请批评指正!

批量插入

> db.foo.insert([{"_id":1},{"_id":2},{"_id":3}])
BulkWriteResult({
        "writeErrors" : [ ],
        "writeConcernErrors" : [ ],
        "nInserted" : 3,
        "nUpserted" : 0,
        "nMatched" : 0,
        "nModified" : 0,
        "nRemoved" : 0,
        "upserted" : [ ]
})
> db.foo.find()
{ "_id" : 1 }
{ "_id" : 2 }
{ "_id" : 3 }
> 

要是在推行批量插入的长河中有四个文书档案插入战败,那么在那几个文书档案从前的有着文书档案都会插入成功,之后的装有壹切惜败。

> db.foo.insert([{"_id":10},{"_id":11},{"_id":10},{"_id":12}])
BulkWriteResult({
        "writeErrors" : [
                {
                        "index" : 2,
                        "code" : 11000,
                        "errmsg" : "E11000 duplicate key error collection: test.foo index: _id_ dup key: { : 10.0 }",
                        "op" : {
                                "_id" : 10
                        }
                }
        ],
        "writeConcernErrors" : [ ],
        "nInserted" : 2,
        "nUpserted" : 0,
        "nMatched" : 0,
        "nModified" : 0,
        "nRemoved" : 0,
        "upserted" : [ ]
})
> db.foo.find()
{ "_id" : 10 }
{ "_id" : 11 }
> 

批量布置

> db.foo.insert([{"_id":1},{"_id":2},{"_id":3}])
BulkWriteResult({
        "writeErrors" : [ ],
        "writeConcernErrors" : [ ],
        "nInserted" : 3,
        "nUpserted" : 0,
        "nMatched" : 0,
        "nModified" : 0,
        "nRemoved" : 0,
        "upserted" : [ ]
})
> db.foo.find()
{ "_id" : 1 }
{ "_id" : 2 }
{ "_id" : 3 }
> 

一旦在执行批量布置的经过中有一个文书档案插入失败,那么在那几个文书档案以前的富有文档都会插入成功,之后的具备1切功亏壹篑。

> db.foo.insert([{"_id":10},{"_id":11},{"_id":10},{"_id":12}])
BulkWriteResult({
        "writeErrors" : [
                {
                        "index" : 2,
                        "code" : 11000,
                        "errmsg" : "E11000 duplicate key error collection: test.foo index: _id_ dup key: { : 10.0 }",
                        "op" : {
                                "_id" : 10
                        }
                }
        ],
        "writeConcernErrors" : [ ],
        "nInserted" : 2,
        "nUpserted" : 0,
        "nMatched" : 0,
        "nModified" : 0,
        "nRemoved" : 0,
        "upserted" : [ ]
})
> db.foo.find()
{ "_id" : 10 }
{ "_id" : 11 }
> 

始建示范collection,使用db.collection.insert()函数和数组参数,叁回性向聚集中插入一个doc。

(1) 运维条件

.net版本

.Net Framwork 4.6.2 x64

MongoDb数据库版本

MongoDb 3.6.2 x64

使得版本

MongoDb Driver 2.5

笔者利用的MongoDB驱动是法定2.五本子驱动,大家可以通过下载GitHub源码自行编写翻译,可能通过NuGet包管理工科具安装。
GitHub地址:戳一戳查看、Link
NuGet地址:戳壹戳查看、Link

本例源码已上传至Gitee

亚洲必赢官网 ,本例源码地址:戳一戳、Link

除去文书档案

删去文书档案

user1={ name:"t1", age:21}
user2={ name:"t2", age:22}
user3={ name:"t3", age:23}

db.users.insert([user1,user2,user3])

二、早先时代准备干活

remove

remove函数接受八个查询文书档案作为参数。符合条件的文书档案才被剔除。删除数据是永久性的,不可能收回,也不能够还原。

> db.foo.remove()
2016-12-15T19:50:31.721+0800 E QUERY    [thread1] Error: remove needs a query :
DBCollection.prototype._parseRemove@src/mongo/shell/collection.js:406:1
DBCollection.prototype.remove@src/mongo/shell/collection.js:433:18
@(shell):1:1

> db.foo.remove({"_id":10})
WriteResult({ "nRemoved" : 1 })
> db.foo.find()
{ "_id" : 11 }
> 

remove

remove函数接受七个询问文书档案作为参数。符合条件的文书档案才被去除。删除数据是永久性的,不能够收回,也不能够回复。

> db.foo.remove()
2016-12-15T19:50:31.721+0800 E QUERY    [thread1] Error: remove needs a query :
DBCollection.prototype._parseRemove@src/mongo/shell/collection.js:406:1
DBCollection.prototype.remove@src/mongo/shell/collection.js:433:18
@(shell):1:1

> db.foo.remove({"_id":10})
WriteResult({ "nRemoved" : 1 })
> db.foo.find()
{ "_id" : 11 }
> 

1,使用dot标记法(dot notation)访问数组成分

(壹) 创造 MongoDBContext MongoDb操作上下文类

创建MongoDBContext操作上下文类,用于连接Mongodb数据库和管理Collection对象

using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
using System.Security.Authentication;
using System.Threading.Tasks;

namespace MongoDBEmbeddedOperation
{
    public class MongoDbContext
    {
        #region Fields
        /// <summary>
        /// 缓存Mongodb集合
        /// </summary>
        private Dictionary<string, object> _collectionsMongoDb;

        #endregion

        #region Properties
        /// <summary>
        /// 数据库连接字符串
        /// </summary>
        public string ConnectionString { get; }

        /// <summary>
        /// Mongo客户端设置
        /// </summary>
        public MongoClientSettings Settings { get; }

        /// <summary>
        /// 数据库名称
        /// </summary>
        public string DatabaseName { get; }

        /// <summary>
        /// Mongo上下文 
        /// </summary>
        public IMongoDatabase DbContext { get; }
        #endregion

        /// <summary>
        /// MongoDb数据上下文
        /// </summary>
        /// <param name="connectionString">
        /// 连接字符串,如:"mongodb://username:password@host:port/[DatabaseName]?ssl=true"
        /// 详情参见:http://www.runoob.com/mongodb/mongodb-connections.html
        /// </param>
        public MongoDbContext(string connectionString)
        {
            if (string.IsNullOrWhiteSpace(connectionString))
                throw new ArgumentException("connectionString 连接字符串不能为空!");

            try
            {
                var mongoUrl = new MongoUrl(connectionString);
                ConnectionString = connectionString;
                Settings = MongoClientSettings.FromUrl(mongoUrl);

                if (string.IsNullOrWhiteSpace(mongoUrl.DatabaseName))
                    throw new ArgumentException("数据库名称不能为空!");

                DatabaseName = mongoUrl.DatabaseName;
                // SSL加密
                if (Settings.UseSsl)
                {
                    Settings.SslSettings = new SslSettings
                    {
                        EnabledSslProtocols = SslProtocols.Tls12
                    };
                }

                var mongoClient = new MongoClient(Settings);
                DbContext = mongoClient.GetDatabase(DatabaseName);
            }
            catch (Exception e)
            {
                // TODO: 记录错误日志
                throw;
            }
        }

        /// <summary>
        /// 异步获取集合
        /// </summary>
        /// <typeparam name="TEntity"></typeparam>
        /// <returns></returns>
        public async Task<IMongoCollection<TEntity>> GetCollectionAsync<TEntity>() where TEntity : class
        {
            // 集合缓存如果为空,那么创建一个
            if (_collectionsMongoDb == null)
            {
                _collectionsMongoDb = new Dictionary<string, object>();
            }

            // 获取集合名称,使用的标准是在实体类型名后添加Set
            var collectionName = $"{typeof(TEntity).Name}Set";

            // 如果集合不存在,那么创建集合
            if (false == await IsCollectionExistsAsync<TEntity>())
            {
                await DbContext.CreateCollectionAsync(collectionName);
            }

            // 如果缓存中没有该集合,那么加入缓存
            if (!_collectionsMongoDb.ContainsKey(collectionName))
            {
                _collectionsMongoDb[collectionName] = DbContext.GetCollection<TEntity>(collectionName);
            }

            // 从缓存中取出集合返回
            return (IMongoCollection<TEntity>)_collectionsMongoDb[collectionName];
        }

        /// <summary>
        /// 集合是否存在
        /// </summary>
        /// <typeparam name="TEntity"></typeparam>
        /// <returns></returns>
        public async Task<bool> IsCollectionExistsAsync<TEntity>()
        {
            var filter = new BsonDocument("name", $"{typeof(TEntity).Name}Set");
            // 通过集合名称过滤
            var collections = await DbContext.ListCollectionsAsync(new ListCollectionsOptions { Filter = filter });
            // 检查是否存在
            return await collections.AnyAsync();
        }
    }
}

drop

要清空整个集合,那么使用drop直接删除集合会更快。代价是:无法内定其余限制标准。整个集合都被剔除,全数元数据都丢掉了。

> for(var i=0;i<1000000;i++){
... db.tester.insert({"foo":"bar","baz":i,"z":10-i})
... }
WriteResult({ "nInserted" : 1 })
> db.tester.find()
{ "_id" : ObjectId("58528543b049609a5fa74f7c"), "foo" : "bar", "baz" : 0, "z" : 10 }
......

Type "it" for more
> db.tester.drop()//插入一百万条数据,使用drop删除,只需1ms
true
>

drop

要清空整个集合,那么使用drop直接删除集合会更快。代价是:不可能钦点别的限制条件。整个集合都被删除,全部元数据都遗落了。

> for(var i=0;i<1000000;i++){
... db.tester.insert({"foo":"bar","baz":i,"z":10-i})
... }
WriteResult({ "nInserted" : 1 })
> db.tester.find()
{ "_id" : ObjectId("58528543b049609a5fa74f7c"), "foo" : "bar", "baz" : 0, "z" : 10 }
......

Type "it" for more
> db.tester.drop()//插入一百万条数据,使用drop删除,只需1ms
true
>

MongoDB使用 dot 访问数组的成分,或内嵌doc字段。

(贰)创设测试类

只要当前是二个物联网数据收集项目,个中有不少个传感器节点(SensorNode),每一种节点都会时有发生记录(Records),一条记下(Record)由数据值(Data)和记录时间(RecordDateTime)组成。要求对其Recods内嵌数组举行增删改查操作。

这正是说由上急需可以抽象出如下目的关联,在实质上采取中,不提出将记录第3手放在SensorNode下,因为Mongodb数据库对单个文书档案有1陆MB的大小限制

    /// <summary>
    /// 传感器节点
    /// </summary>
    public class SensorNode
    {
        /// <summary>
        /// ID
        /// </summary>
        public ObjectId Id { get; set; }

        /// <summary>
        /// 记录数
        /// </summary>
        public List<Record> Records { get; set; }
    }

    /// <summary>
    /// 数据记录
    /// </summary>
    public class Record
    {
        /// <summary>
        /// 数据值
        /// </summary>
        public double Data { get; set; }

        /// <summary>
        /// 记录时间
        /// </summary>
        public DateTime RecorDateTime { get; set; }
    }

测试类所对应的Bson结构,如下所示.

{
    "_id" : ObjectId("5aa877e4aa25752ab4d4cae3"),
    "Records" : [ 
        {
            "Data" : 1962163552.0,
            "RecorDateTime" : ISODate("2018-03-16T10:01:14.931Z")
        }, 
        {
            "Data" : 1111405346.0,
            "RecorDateTime" : ISODate("2018-03-16T08:53:14.931Z")
        },
        ......
    ]
}

立异文书档案update

Update有四个必须参数:

一是查询文档,用于固定供给立异的对象文书档案

贰是修改器文档,用于注明要找到的文书档案进行哪些修改

更新操作是不可分割的:就算八个更新还要发生,先抵达服务器的先实施,接着执行另三个。

db.foo.insert({
... "name":"yyb",
... "friends":32,
... "enemies":2
... })
WriteResult({ "nInserted" : 1 })
> db.foo.update({"name":"yyb"},{"name":"joe"})//将yyb这个文档修改成{“name”:“joe”}
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.foo.find()
{ "_id" : ObjectId("58528a2bb049609a5fb691bc"), "name" : "joe" }
> 

履新文书档案update

Update有八个必须参数:

一是查询文档,用于固定须要立异的指标文书档案

二是修改器文书档案,用于注脚要找到的文书档案进行什么样修改

增加和删除改文书档案上,MongoDB学习笔记3。履新操作是不可分割的:假设五个立异还要产生,先到达服务器的先实行,接着执行另3个。

db.foo.insert({
... "name":"yyb",
... "friends":32,
... "enemies":2
... })
WriteResult({ "nInserted" : 1 })
> db.foo.update({"name":"yyb"},{"name":"joe"})//将yyb这个文档修改成{“name”:“joe”}
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.foo.find()
{ "_id" : ObjectId("58528a2bb049609a5fb691bc"), "name" : "joe" }
> 

MongoDB uses the dot notation to access
the elements of an array and to access the fields of an embedded
document.

(三) 成立测试代码

新建一个控制台程序,加入以下代码。对MongodbContext进行初始化,插入用于测试的SensorNode.

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Bson;
using MongoDB.Driver.Linq; // <---- 此引用非常重要
using MongoDB.Driver;

......

private static ObjectId _sensorNodeId;
private static MongoDbContext _dbContext;
private static IMongoCollection<SensorNode> _sensorNodes;
static void Main(string[] args)
{
    // 使用链接字符串创建dbContext对象
    _dbContext = new MongoDbContext("mongodb://hynuAdmin:123456@localhost:27017/HynuIOTA");
    // 创建_Sensors数据库,入口方法不能使用异步,我们等待结果返回
    _sensorNodes = _dbContext.GetCollectionAsync<SensorNode>().Result;
    // 创建一个SensorNode 存入MongoDb数据库中
    _sensorNodeId = ObjectId.Parse("5aa877e4aa25752ab4d4cae3");
    #region 创建测试用例
    var sensorNode = new SensorNode()
    {
        Id = _sensorNodeId,
        Records = new List<Record>()
    };
    // 插入数据库中
    _sensorNodes.InsertOne(sensorNode);
    #endregion
}

添加一个方法,用于随机生成Record对象。

/// <summary>
/// 生成count个Rocred对象
/// </summary>
/// <param name="count">生成数量</param>
/// <returns></returns>
static List<Record> GetRandomRecord(int count)
{
    var records = new List<Record>();
    var rd = new Random();
    for (int i = 0; i < count; i++)
    {
        records.Add(new Record()
        {
            Data = rd.Next(),
            RecorDateTime = DateTime.Now.AddMinutes(rd.Next() % 100)
        });
    }
    return records;
}

文档替换

用二个新文书档案完全替换匹配的文书档案,那契合大面积格局迁移的场地。

  db.user.insert({
... ... "name":"joe",
... ... "friends":32,
... ... "enemies":2
... ... })
WriteResult({ "nInserted" : 1 })
//将上面这个文档的后两个字段移到子文档为realtionships中
> var joe=db.user.findOne({"name":"joe"})
> joe.relationships={"friends":joe.friends,"enemies":joe.enemies};
{ "friends" : 32, "enemies" : 2 }
> delete joe.friends
true
> delete joe.enemies
true
> db.user.update({"name":"joe"},joe);
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("58529188b049609a5fb691bf"), "name" : "joe", "relationships" : { "friends" : 32, "enemies" : 2 } }
> 

大面积的荒谬是询问条件非凡到了多少个文书档案,然后更新时由于第1个参数的存在就产生重复的 _id 值。数据库会抛出相当。

> db.user.find()
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 21 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> joe=db.user.findOne({"name":"yyb","age":30})
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
> joe.age++;
30
> db.user.update({"name":"yyb"},joe)
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 16837,
                "errmsg" : "The _id field cannot be changed from {_id: ObjectId('585295e3b049609a5fb691c5')} to {_id: ObjectId('585295e3b049609a5fb691c6')}."
        }
})
> 

文书档案替换

用一个新文书档案完全替换匹配的文书档案,那符合广大格局迁移的情景。

  db.user.insert({
... ... "name":"joe",
... ... "friends":32,
... ... "enemies":2
... ... })
WriteResult({ "nInserted" : 1 })
//将上面这个文档的后两个字段移到子文档为realtionships中
> var joe=db.user.findOne({"name":"joe"})
> joe.relationships={"friends":joe.friends,"enemies":joe.enemies};
{ "friends" : 32, "enemies" : 2 }
> delete joe.friends
true
> delete joe.enemies
true
> db.user.update({"name":"joe"},joe);
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find()
{ "_id" : ObjectId("58529188b049609a5fb691bf"), "name" : "joe", "relationships" : { "friends" : 32, "enemies" : 2 } }
> 

普遍的谬误是查询条件合作到了八个文书档案,然后更新时出于首个参数的留存就生出重复的 _id 值。数据库会抛出很是。

> db.user.find()
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 21 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> joe=db.user.findOne({"name":"yyb","age":30})
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
> joe.age++;
30
> db.user.update({"name":"yyb"},joe)
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 16837,
                "errmsg" : "The _id field cannot be changed from {_id: ObjectId('585295e3b049609a5fb691c5')} to {_id: ObjectId('585295e3b049609a5fb691c6')}."
        }
})
> 
users=
{
name:"t1",
age:21,
address: {phone:123,email:"xxx@163.com"},
followers:[{name:"a"},{name:"b"},{name:"c"}]
}

三、内嵌数组增日币素操作

使用修改器

运用原子性的更新修改器,内定对文书档案的一点字段进行创新。更新修改器是种新鲜的键,用来钦点复杂的立异操作,比如修改、添加恐怕删除键,还恐怕是操作数组大概内嵌文书档案。

> db.user.find()
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 21 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> db.user.update({"name":"yyb"},{$inc:{"age":5}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })> db.user.find({"name":"yyb"})
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 26 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> 

明明匹配三条,却只改了一条。原来MongoDB暗中认可只会更新匹配的第三条,若是要立异多条,还得钦赐参数。

利用修改器时,_id的值无法更改。(整个文书档案替换时得以变更“_id”)

使用修改器

采纳原子性的换代修改器,内定对文书档案的少数字段进行翻新。更新修改器是种奇特的键,用来内定复杂的立异操作,比如修改、添加或许删除键,还可能是操作数组恐怕内嵌文书档案。

> db.user.find()
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 21 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> db.user.update({"name":"yyb"},{$inc:{"age":5}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })> db.user.find({"name":"yyb"})
{ "_id" : ObjectId("585295e3b049609a5fb691c5"), "name" : "yyb", "age" : 26 }
{ "_id" : ObjectId("585295e3b049609a5fb691c6"), "name" : "yyb", "age" : 30 }
{ "_id" : ObjectId("585295e3b049609a5fb691c7"), "name" : "yyb", "age" : 40 }
> 

明明匹配三条,却只改了一条。原来MongoDB暗中同意只会更新匹配的率先条,若是要翻新多条,还得内定参数。

使用修改器时,_id的值不能够改变。(整个文书档案替换时得以转移“_id”)

address 字段是内嵌文档,查找phone是12三的doc

(一) Update.Set()方法 替换内嵌数组(不引进应用)

此办法重要使用操作符[$set],它的思路是先将内嵌文书档案的父成分查找出来,然后对子文书档案数组进行增加和删除改操作,最终将子文书档案数组重新沟通。此措施质量较低,除非涉及到大批量改观,不然不引进应用。

    #region 方法一. 查出sensor再更新Records, $set操作 - 随机插入100个元素(不推荐)
    // 查询需修改的sensorNode对象
    var sensor = await _sensorNodes.Find(s => s.Id == _sensorNodeId).FirstOrDefaultAsync();
    // 往Records里面增加随机元素
    sensor.Records.AddRange(GetRandomRecord(100));
    // 构建update Bson, 将原有Records替换为新的Records
    var update = Builders<SensorNode>.Update.Set(d => d.Records, sensor.Records);
    // 使用Update方法
    await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, update);
    #endregion

$set与$unset

用来钦点贰个字段的值。假设那些字段不设有,则创建它。

> db.user.insert({
... "name":"yyb",
... "age":20,
... "sex":"male",
... "location":"cd"})
WriteResult({ "nInserted" : 1 })
>> db.user.update({"name":"yyb"},{"$set":{"email":"123@qq.com"}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd",
        "email" : "123@qq.com"
}
> 

用 $set 甚至可以修改键的种类。用 $unset 能够将键完全除去。

>  db.user.update(
... ... {"name":"yyb"},
... ... {"$set":{"email":["xx@qq.com","xl@sina.com"]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd",
        "email" : [
                "xx@qq.com",
                "xl@sina.com"
        ]
}
> db.user.update({"name":"yyb"},{"$unset":{"email":1}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd"
}

也得以用 $set 修改内嵌文档:

{
        "_id" : ObjectId("5853e17ff7720722b4ded850"),
        "title" : "a blog post",
        "content" : "...",
        "author" : {
                "name" : "yyb",
                "email" : "aaa@sina.com"
        }
}
> db.blog.update(
... {"author.name":"yyb"},
... {"$set":{"author.name":"joe"}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.findOne()
{
        "_id" : ObjectId("5853e17ff7720722b4ded850"),
        "title" : "a blog post",
        "content" : "...",
        "author" : {
                "name" : "joe",
                "email" : "aaa@sina.com"
        }
}

扩展、删除、修改键时,应该利用$早先的修改器,不然可能会将全方位文书档案替换掉。

$set与$unset

用来钦定三个字段的值。假诺这几个字段不设有,则创设它。

> db.user.insert({
... "name":"yyb",
... "age":20,
... "sex":"male",
... "location":"cd"})
WriteResult({ "nInserted" : 1 })
>> db.user.update({"name":"yyb"},{"$set":{"email":"123@qq.com"}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd",
        "email" : "123@qq.com"
}
> 

用 $set 甚至能够修改键的品种。用 $unset 能够将键完全除去。

>  db.user.update(
... ... {"name":"yyb"},
... ... {"$set":{"email":["xx@qq.com","xl@sina.com"]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd",
        "email" : [
                "xx@qq.com",
                "xl@sina.com"
        ]
}
> db.user.update({"name":"yyb"},{"$unset":{"email":1}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.user.find().pretty()
{
        "_id" : ObjectId("58529e66b049609a5fb691c9"),
        "name" : "yyb",
        "age" : 20,
        "sex" : "male",
        "location" : "cd"
}

也能够用 $set 修改内嵌文书档案:

{
        "_id" : ObjectId("5853e17ff7720722b4ded850"),
        "title" : "a blog post",
        "content" : "...",
        "author" : {
                "name" : "yyb",
                "email" : "aaa@sina.com"
        }
}
> db.blog.update(
... {"author.name":"yyb"},
... {"$set":{"author.name":"joe"}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.findOne()
{
        "_id" : ObjectId("5853e17ff7720722b4ded850"),
        "title" : "a blog post",
        "content" : "...",
        "author" : {
                "name" : "joe",
                "email" : "aaa@sina.com"
        }
}

追加、删除、修改键时,应该选择$起始的修改器,不然恐怕会将全体文书档案替换掉。

db.users.find({"addr.phone":123})

(二)Update.Push()方法 直接将成分压入内嵌数组(推荐)

此方法首要行使操作符[$push]来增澳成分到子文书档案数组,品质好,推荐应用。

// 构建update Bson ,添加一条记录使用Push方法
var updateOne = Builders<SensorNode>.Update.Push(d => d.Records, GetRandomRecord(1).First());
// 更新
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, updateMany);

$inc

 $inc 用来充实已有键的值,也许该键不存在这就创办三个。对于立异分析数据、因果关系、投票只怕其余有变动数值的地点很方便。

> db.games.insert({"games":"pinball","user":"joe"})
WriteResult({ "nInserted" : 1 })
> db.games.update({"games":"pinball"},{"$inc":{"score":50}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.games.findOne()
{
        "_id" : ObjectId("5853e517f7720722b4ded851"),
        "games" : "pinball",
        "user" : "joe",
        "score" : 50
}
> db.games.update({"games":"pinball"},{"$inc":{"score":10000}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.games.findOne()
{
"_id" : ObjectId("5853e517f7720722b4ded851"),
"games" : "pinball",
"user" : "joe",
"score" : 10050
}
>

 $inc 就是专门用来增减数字的。且不得不用来整型、长整型可能双精度浮点型的值。其余类型的数据会操作失利。

> db.foo.insert({"count":"1"})
WriteResult({ "nInserted" : 1 })

> db.foo.update({},{"$inc":{"count":1}})
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 16837,
                "errmsg" : "Cannot apply $inc to a value of non-numeric type. {_id: ObjectId('5853e73df7720722b4ded853')} has the field 'count' of non-numeric type String"
        }
})
> 

 $inc 键的值必须为数字”,不能够应用字符串、数组也许别的非数字的值。要修改别的品类,应该运用 $set 大概数字修改器。

> db.foo.insert({"count":1})
WriteResult({ "nInserted" : 1 })

> db.foo.update({},{"$inc":{"count":"5"}})
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 14,
                "errmsg" : "Cannot increment with non-numeric argument: {count: \"5\"}"
        }
})
> 

$inc

 $inc 用来扩充已有键的值,大概该键不设有那就成立一个。对于立异分析数据、因果关系、投票或然别的有浮动数值的地方很方便。

> db.games.insert({"games":"pinball","user":"joe"})
WriteResult({ "nInserted" : 1 })
> db.games.update({"games":"pinball"},{"$inc":{"score":50}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.games.findOne()
{
        "_id" : ObjectId("5853e517f7720722b4ded851"),
        "games" : "pinball",
        "user" : "joe",
        "score" : 50
}
> db.games.update({"games":"pinball"},{"$inc":{"score":10000}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.games.findOne()
{
"_id" : ObjectId("5853e517f7720722b4ded851"),
"games" : "pinball",
"user" : "joe",
"score" : 10050
}
>

 $inc 就是特别用来增减数字的。且不得不用来整型、长整型只怕双精度浮点型的值。其余类别的数据会操作退步。

> db.foo.insert({"count":"1"})
WriteResult({ "nInserted" : 1 })

> db.foo.update({},{"$inc":{"count":1}})
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 16837,
                "errmsg" : "Cannot apply $inc to a value of non-numeric type. {_id: ObjectId('5853e73df7720722b4ded853')} has the field 'count' of non-numeric type String"
        }
})
> 

 $inc 键的值必须为数字”,不能够动用字符串、数组大概其余非数字的值。要修改其余品种,应该使用 $set 大概数字修改器。

> db.foo.insert({"count":1})
WriteResult({ "nInserted" : 1 })

> db.foo.update({},{"$inc":{"count":"5"}})
WriteResult({
        "nMatched" : 0,
        "nUpserted" : 0,
        "nModified" : 0,
        "writeError" : {
                "code" : 14,
                "errmsg" : "Cannot increment with non-numeric argument: {count: \"5\"}"
        }
})
> 

followers 字段是数组,查询followers中存在name=“b”的doc

(叁) Update.PushEach()方法 将八个因素压入内嵌数组(推荐)

此办法运用的也是[$push]操作符,只是在生成BsonDocument时允许收取数组。

#region 方法二. $push操作 - 随机插入100个元素(推荐)
// 构建update Bson 添加多条记录使用PushEach方法
var updateMany = Builders<SensorNode>.Update.PushEach(d => d.Records, GetRandomRecord(100));
// 更新
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, updateMany);
#endregion

数组修改器

数组修改器

db.users.find({"followers.name":"b"})

4、内嵌数组删除成分操作

$push

$push 添日币素。假设数组已经存在,会向已部分数组末尾参与三个要素,假设未有就创办三个新的数组。

> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "..."
}
> db.blog.post.update(
... {"title":"a blog post"},
... {"$push":{"comments":{"name":"joe","email":"joe@qq.com","content":"nice post"}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "...",
        "comments" : [
                {
                        "name" : "joe",
                        "email" : "joe@qq.com",
                        "content" : "nice post"
                }
        ]
}
> 

> db.blog.post.update(
... {"title":"a blog post"},
... {"$push":{"comments":{"name":"bob","email":"bob@sina.com","content":"good post."}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "...",
        "comments" : [
                {
                        "name" : "joe",
                        "email" : "joe@qq.com",
                        "content" : "nice post"
                },
                {
                        "name" : "bob",
                        "email" : "bob@sina.com",
                        "content" : "good post."
                }
        ]
}
> 

$push

$push 添美金素。假如数组已经存在,会向已有的数组末尾加入多少个因素,借使未有就成立贰个新的数组。

> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "..."
}
> db.blog.post.update(
... {"title":"a blog post"},
... {"$push":{"comments":{"name":"joe","email":"joe@qq.com","content":"nice post"}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "...",
        "comments" : [
                {
                        "name" : "joe",
                        "email" : "joe@qq.com",
                        "content" : "nice post"
                }
        ]
}
> 

> db.blog.post.update(
... {"title":"a blog post"},
... {"$push":{"comments":{"name":"bob","email":"bob@sina.com","content":"good post."}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.blog.post.findOne()
{
        "_id" : ObjectId("5853ea01f7720722b4ded855"),
        "title" : "a blog post",
        "content" : "...",
        "comments" : [
                {
                        "name" : "joe",
                        "email" : "joe@qq.com",
                        "content" : "nice post"
                },
                {
                        "name" : "bob",
                        "email" : "bob@sina.com",
                        "content" : "good post."
                }
        ]
}
> 

二,修改字段的值

(壹) Update.Set()方法 替换内嵌数组(不引进应用)

此办法思路和增法郎素的思路同样,品质较低,不引进应用。

#region 方法一 . $set方式删除 - 删除前5个元素(不推荐)
// 查询需修改的sensorNode对象
var sensor = await _sensorNodes.Find(s => s.Id == _sensorNodeId).FirstOrDefaultAsync();
// 删除Record
for (int i = 0; i < 5; i++)
{
    sensor.Records.RemoveAt(i);
}
// 构建update Bson, 将原有Records替换为新的Records
var update = Builders<SensorNode>.Update.Set(d => d.Records, sensor.Records);
// 使用Update方法
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, update);
#endregion

$each

能够将它利用在壹部分相比复杂的数组操作中。使用 $each 子操作符,能够由此二遍 $push 操作添加多个值。

诸如:下边将多少个新因素添加到数组中。若是钦赐的数组中只含有叁个成分,那么相同和未有利用“$each”的家常的“$push”操作。

db.stock.ticket.insert({"_id":"goog"})
WriteResult({ "nInserted" : 1 })
>  db.stock.ticket.update(
... ... ... {"_id":"goog"},
... ... ... {"$push":{"hourly":{"$each":[562.776,562.790,559.123]}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ 562.776, 562.79, 559.123 ] }

要促成地方的操作,上面方法也得以。

db.stock.ticket.update(
... ... ... ... ... {"_id":"goog"},
... ... ... ... ... {"$set":{"hourly":[562.776,562.790,559.123]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ 562.776, 562.79, 559.123 ] }

而下边那样是那三个的

 db.stock.ticket.update(
... ... ... ... {"_id":"goog"},
... ... ... ... {"$push":{"hourly":[562.776,562.790,559.123]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ [ 562.776, 562.79, 559.123 ] ] }

 

$each

能够将它采取在局部相比较复杂的数组操作中。使用 $each 子操作符,可以通过一遍 $push 操作添加多个值。

比如说:上边将多少个新因素添加到数组中。倘使钦点的数组中只包涵3个因素,那么同样和尚未行使“$each”的一般的“$push”操作。

db.stock.ticket.insert({"_id":"goog"})
WriteResult({ "nInserted" : 1 })
>  db.stock.ticket.update(
... ... ... {"_id":"goog"},
... ... ... {"$push":{"hourly":{"$each":[562.776,562.790,559.123]}}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ 562.776, 562.79, 559.123 ] }

要落到实处地方的操作,上边方法也能够。

db.stock.ticket.update(
... ... ... ... ... {"_id":"goog"},
... ... ... ... ... {"$set":{"hourly":[562.776,562.790,559.123]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ 562.776, 562.79, 559.123 ] }

而上面那样是老大的

 db.stock.ticket.update(
... ... ... ... {"_id":"goog"},
... ... ... ... {"$push":{"hourly":[562.776,562.790,559.123]}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
> db.stock.ticket.findOne()
{ "_id" : "goog", "hourly" : [ [ 562.776, 562.79, 559.123 ] ] }

 

在MongoDB中,修改操作首要采取四个修改器:$set 和
$inc,这三个修改器具有upsert天性:即使doc中存在对应的字段,那么修改该字段的值;就算doc中不设有对应的字段,那么在doc中开立异的字段。$inc用于整数型字段,扩张或调整和缩短字段的值,$set用于任意数据类型,替换字段的值。

(二) Update.Pull()方法 Pull删除1个要素(推荐)

// 假设需要删除的Record已经被查询转换为对象,那么使用Pull方式删除一个元素
var record = new Record() 
{ Data = 1670941112.0, RecorDateTime = DateTime.Parse("2018-03-16T09:36:14.930Z") };
// 构建Pull删除Bson
var update = Builders<SensorNode>.Update.Pull(s => s.Records, record);
// 使用Update方法
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, update);

壹,使用$set修改器,扩展followers数组,使用empty
filter:{},表示更新集合中的全部doc

(三)Update.PullFilter()方法 删除过滤器删除元素(推荐)

#region 方法三. PullFilter方式删除 - 删除符合Filter条件的元素(推荐)
// 如果r.Data == 339119843.0,那么从数组中删除
var update = Builders<SensorNode>.Update.PullFilter(s => s.Records, r => r.Data == 339119843.0);
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, update);
#endregion
db.users.updateMany(
{},
{$set:
   {
    followers:[ {name:"t5"},{name:"t7"} ]
   }
}
)

伍、内嵌数组修改成分操作

亚洲必赢官网 1

(壹) Update.Set() Set先查询后修改(不引进)

此办法质量较低,不引进。

#region 方法一. $set方式修改(将某个元素记录时间改为最小值) - 先查询后修改(不推荐)
// 查询需修改的sensorNode对象
var sensor = await _sensorNodes.Find(s => s.Id == _sensorNodeId).FirstOrDefaultAsync();
// 修改Record值
sensor.Records[0].RecorDateTime = DateTime.MinValue;
// 构建update Bson, 将原有Records替换为新的Records
var update = Builders<SensorNode>.Update.Set(d => d.Records, sensor.Records);
// 使用Update方法
await _sensorNodes.UpdateOneAsync(s => s.Id == _sensorNodeId, update);
#endregion

二,使用$inc修改器,扩展age字段的值,每一个doc的age字段的都扩大一

(②) Update.Set() 同盟过滤器修改(推荐)

在数据库内部形成过滤和改动,品质高,推荐使用。

#region 方法二. $set方式修改(将Data = 1835821478.0的元素记录时间改为最大值) - 直接过滤修改(推荐)
// 构造filter 
var filter = Builders<SensorNode>.Filter.Where(s => s.Id == _sensorNodeId) 
& Builders<SensorNode>.Filter.Where(d => d.Records.Any(r => r.Data == 1835821478.0));
// 执行更新
var update = Builders<SensorNode>.Update.Set(d => d.Records[-1].RecorDateTime, DateTime.MaxValue);
await _sensorNodes.UpdateOneAsync(filter, update);
#endregion
db.users.updateMany(
{},
{$inc:{age:1}}
)

陆、内嵌数组查找成分操作(Linq)

对于内嵌数组/文档的查询,在.net里建议直接使用Linq或拼接BsonDocument。笔者着重使用Linq方式。

需要先using MongoDB.Driver.Linq,不然Linq不能使用。

亚洲必赢官网 2

(1)Linq查询一条记下(推荐)

重大是SelectMany()方法的利用,此措施用于选取二个数组。

#region SelectMany查询内嵌数组(查询Data = 1340695206.0的第一条记录) - (推荐)
// 转换为Queryable
var result = await _sensorNodes.AsQueryable()
    // 查找对应的sensorNode
    .Where(s => s.Id == _sensorNodeId)
    // 选择Records内嵌数组
    .SelectMany(s => s.Records)
    // 查找Data == 1340695206.0的元素
    .Where(r => r.Data == 1340695206.0)
    // 取第一个
    .FirstOrDefaultAsync();
#endregion

三,$set 和
$inc的不相同之处在于:$set是替换现有字段的值,而$inc是在现有字段值的底子上,增添或减少钦定的数值

(二)Linq查询分页 (推荐)

第一差距使用SelectMany别的与EF Linq格局大多

#region SelectMany、Skip、Take内嵌数组排序分页 - (推荐)
// 页码
var index = 4;
// 页面大小
var size = 10;
// 转换为Queryable
var page = await _sensorNodes.AsQueryable()
    // 查找对应的sensorNode
    .Where(s => s.Id == _sensorNodeId)
    // 选择Records内嵌数组
    .SelectMany(s => s.Records)
    // 根据记录时间排序
    .OrderBy(r => r.RecorDateTime)
    // 跳过 index - 1页数据
    .Skip((index - 1) * size)
    // 选取一页数据
    .Take(size)
    // 转换为集合
    .ToListAsync();
#endregion

对内嵌数组的查询操作主要是通过聚合来实现,以上代码转换为Native方式后是以下命令。

aggregate(
[
    {"$match" : { "_id" : ObjectId("5aa877e4aa25752ab4d4cae3") } }, 
    { "$unwind" : "$Records" }, 
    { "$project" : { "Records" : "$Records", "_id" : 0 } }, 
    { "$sort" : { "Records.RecorDateTime" : 1 } }, { "$skip" : 30 }, { "$limit" : 10 }
]);

即使还要引述了System.Linq 和 MongoDB.Driver.Linq
调用Linq方法会发生办法二义性,化解方案链接如下。

Linq方法2义性解决方案:

演示,使用$set修改age的值,更新结束后,种种doc的age字段都是一

七、总结

  本文简单的介绍了MongoDB C#驱动对内嵌文档的增删改查操作,笔者水平有限,如有错误请批评指正!
  欢迎转载,请注明来源!
db.users.updateMany(
{},
{$set:{age:1}}
)

3,修改数组

假若要向数组中扩张或删除八个要素,$set和$inc
都不可能很好的满足那种供给,MongoDB有专用的 Array
Operator,用于修改数组字段。

一,使用$push向doc中增添数组,或插队新的因素

$push:借使doc中留存对应的数组字段,那么向数组的尾巴部分插入3个元素;假如doc中不存在对应的数组字段,那么向doc中创立三个数组字段,并起先化。

演示,第一回调用$push,由于doc中不存在comments字段,由此MongoDB向doc中新建comments
数组字段,并开首化数组

db.users.updateMany(
{},
{$push:{comments:{msg:"c1"}}}
)

示范,后续再一次调用$push,向已有个别数组字段的尾部扩展2个成分

db.users.updateMany(
{},
{$push:{comments:{msg:"c2"}}}
)

图示,左侧是数组的首先个因素,左侧是数组的结尾3个要素,使用$push每一回向数组的尾巴部分增添二个成分

亚洲必赢官网 3

二,向数组字段插入四个成分

$push 修改器每一遍只好向数组字段的尾巴插入二个因素,搭配使用$each
修改器,每一回能向数组字段中插入多少个成分

db.users.updateMany(
{},
{$push:
   {
     comments:{ $each:[ {msg:"c3"}, {msg:"c4"} ] }
   }
}
)

图示,使用$each,三回将多少个因素插入到数组的尾巴

亚洲必赢官网 4

三,从数组字段的一定岗位处起初插入成分

采用$push 修改器只可以将成分插入到数组字段的尾巴,搭配使用$position
修改器,能够钦定元素插入的发轫地点,$position
必须和$each搭配使用。数组的下标是从0初阶的。

db.users.updateMany
(
{},
{$push:
    {comments:
        {
           $each:[ { msg:"c5"}, {msg:"c6"} ],
           $position:2
        }
    }
}
)

图示,使用$position
内定成分插入的上马地点,将c5,c六依次插入都数组的二,三岗位处,由于数组的小标是从0开端的,c伍,c陆是数组的第2,多少个要素亚洲必赢官网 5

只要不使用$position 修改器,那么 $push
每回都向数组的末梢写入成分;使用$position
修改器,内定$push插入成分的上马地点。

$position :The $position modifier
specifies the location in the array at which the
$push
operator insert elements. Without the $position modifier, the
$push
operator inserts elements to the end of the array.

四,限制数组八月素的数目

在$push
成分时,使用$slice=马克斯Num限制数组元素的最大数额。只要未有达到最大数据,就会向数组中插入新的因素,直到达到最大值。$slice必须和$each搭配使用,假若数组字段的成分的数码已经达到规定的标准最大值,根据MaxNum值的例外,会有差别的一颦一笑:

  • 假设马克斯Num=0,表示将数组清空;
  • 倘使马克斯Num是正整数,表示数组只保留前边的马克斯Num个因素;
  • 假诺马克斯Num是负整数,表示数组只保留后边的马克斯Num个因素;

演示,保留各类comments的终极多少个因素

db.users.updateMany(
{},
{$push:
   {comments:
      {
        $each:[ {msg:"c7"}, {msg:"c8"}, {msg:"c9"}],
        $slice:-5
      }
   }
}
)

图示,$slice:-5,MongoDB先将新的要素插入到数组中,将保存数组末尾的五个成分,将数组的任何因素删除

亚洲必赢官网 6

五,对数组字段的成分实行排序

在限制数组字段的要素数量事先,使用$sort
操作符对成分举办排序,是数组成分有序排列。在$sort操作之后采纳$slice:马克斯Num
修改器,由于数组成分是稳步的,能够只保留体系后边或前面包车型地铁特定数量的成分。

db.users.updateMany(
{},
{$push:
   {comments:
      {
        $each:[ {msg:"c7"}, {msg:"c8"}, {msg:"c9"}],
        $sort:{msg:-1},
        $slice:-5
      }
   }
}
)

图示,$each 向现有的数组的尾乌海插入两个成分:c七,c8,c玖,$sort:{msg:-壹}
对数组依据msg的降序排序,$slice:-5操作符限制数组的要素数量,只保留数组尾部的四个要素。

亚洲必赢官网 7

假如数组是[1,2,3]那类别型,那么$sort:一,遵照一,二,3 升序排列;
$sort:-1,安装3,二,1 降序排列。

六,使用$addToSet向数组插入无重复的成分

透过$push
插入元素,有望插入重复的成分,MongoDB允许数组中的成分重复;要是3个数组无法插入重复值,能够应用$addToSet修改器,
$addToSet在向数组插入成分时,首先检查成分是或不是业已存在于数组中,若是不设有,那么$addToSet将成分插入到数组中;假若存在,那么$addToSet不会插入任何因素。$addToSet只会确定保证不会插入重复的成分,不应影响数组中早已存在的重新元素。

$addToSet 能够2遍性向数组中插入七个成分。

$addToSet only ensures that there are
no duplicate items added to the set and does not affect existing
duplicate elements. $addToSet does not guarantee a particular ordering
of elements in the modified set.

以身作则,向comments 数组中插入多少个messge

db.users.updateMany(
{},
{$addToSet:
   {comments:[ {msg:"c7"}, {msg:"c8"}, {msg:"c9"}] }
}
)

七,使用$pop删除数组的第二个或最终贰个成分

把数组看作是队列,下标为0的要素是在队列尾部,是数组的第多少个成分,小标最大的因素是数组的末尾三个因素。使用$pop删除成分时,{$pop:{array:一}}
表示删除数组的结尾多少个成分,{$pop:{array:-一}}
表示删除数组的首先个因素。

db.users.updateMany(
{},
{$pop:{comments:1}}
)

图示,删除数组的末段一个要素

亚洲必赢官网 8

8,依照queyr filter删除数组成分

db.users.updateMany(
{},
{$pull:{comments:{msg:"c7"}}}
)

图示,删除数组中msg字段是”c7″的保有因素

亚洲必赢官网 9

9,依照数组的下标修改元素,数组下标是从0初叶的

对此js的数组 arr,包涵四个element,修改第2个成分的like
字段,将其值设置为2.

var arr=[{name:"t1",like:1},{name:"t2",like:2}]
arr[0].like=2
print(tojoson(arr))

在MongoDB中,若是要修改doc中的数组,能够使用 dot notation,使用
arrary.index.田野同志 对数组中一定岗位的要素举行修改。

db.users.updateMany(
{},
{$inc:{"comments.0.likes":1}}
)

图示,向数组的第3个成分中加进likes字段,并早先化为一

亚洲必赢官网 10

借使不亮堂数组成分的下标,MongoDB提供占位符
$,用于表示从数组中追寻满意query filter的首先个因素。占位符 $
必要对数组实行搜寻,查找的query
filter必须显式提供,就算存在数据成分满足query filter,那么$
占位符表示第一个门道非常的数组成分的position,如若未有数组成分知足query
filter,那么MongoDB不会对数据任何意义。

$占位符的运用格式,跟数组的要素类型有关:

  • 假定数组成分是doc,那么使用 $ 占位符的格式是:arrary.$.田野先生。
  • 倘使数组的因素类型是原子类型,例如,[1,2,3]等,那么使用那么使用
    $ 占用符的格式是:arrary.$。

$:
Acts as a placeholder to update the first element that matches the query
condition in an update.

示例1,使用empty filter作为query
filter

db.users.updateMany(
{},
{$inc:{"comments.$.unlikes":1}}
)

MongoDB抛出错误音讯:

“errmsg” : “The
positional operator did not find the match needed from the query.
Unexpanded update: comments.$.unlikes”

表明 query filter 无法接纳empty filter,必须显式提供query filter。

示例二,对数组成分进行询问,只要存在任何一个要素的msg字段的值c4,就在该因素中追加多个unlikes字段,并开首化为壹.

db.users.updateMany(
{comments:
    {$elemMatch:{msg:"c4"}}
},
{$inc:
    {"comments.$.unlikes":1}
}
)

图示,$ 占位符表示匹配query filter的第二个因素

亚洲必赢官网 11

肆,数组的询问

1,成分匹配符 $elemMatch,使用数组成分进行规范协作

$elemMatch
是对数组成分的字段实行匹配,若是成分或因素的字段满意查询条件,那么重临该因素所在的doc。

格式是:{array:{$elemMatch:{field_query_filter,,,,}}}

The $elemMatch operator matches
documents that contain an array field with at least one element that
matches all the specified query criteria.

db.users.find({comments:{$elemMatch:{like:1}}})

以身作则一,数组成分是整数类型(原子类型)

{ _id: 1, results: [ 82, 85, 88 ] }
{ _id: 2, results: [ 75, 88, 89 ] }

db.scores.find(
   { results: { $elemMatch: { $gte: 80, $lt: 85 } } }
)

查询结果是:只有_id为壹的doc的数组成分8二满足query filter

{ "_id" : 1, "results" : [ 82, 85, 88 ] }

示例二,数组元素是doc

{ _id: 1, results: [ { product: "abc", score: 10 }, { product: "xyz", score: 5 } ] }
{ _id: 2, results: [ { product: "abc", score: 8 }, { product: "xyz", score: 7 } ] }
{ _id: 3, results: [ { product: "abc", score: 7 }, { product: "xyz", score: 8 } ] }

db.survey.find(
   { results: { $elemMatch: { product: "xyz", score: { $gte: 8 } } } }
)

查询结果是:

{ "_id" : 3, "results" : [ { "product" : "abc", "score" : 7 }, { "product" : "xyz", "score" : 8 } ] }

二,数组的可比,使用数组进行规范卓殊

应用数组实行相比时,只要数组中的任何因素满意query filter,就格外成功。

若果有以下八个doc,各样doc中都有2个grades 数组:

{ "_id" : 1, "grades" : [ 80, 85, 90 ] }
{ "_id" : 2, "grades" : [ 88, 90, 92 ] }
{ "_id" : 3, "grades" : [ 85, 100, 90 ] }

示范一,对于query filter:{grades:{$gt:八伍,
$lt:十0}},分析那三个数组是还是不是满意:

  • 第2个数组:成分 90 知足抢先 8伍,全体的成分都自愧不比拾0
  • 第三个数组:全数的成分满意条件
  • 第3个数组:成分90,100
    满足当先八5的条件,成分八五,90满足小于100的原则 

因而,只要数组中有其它3个成分满意qeury filter,固然满足qeury
filter,那1个数组都满意query filter。
示例2,query filter:{grades:90}

只要数组中有一个要素的值是90,就满足query
filter,由此,那么些数组都满意条件。

三,查询数组成分的多寡

$size操作符,要是doc中留存数组,并且数组的成分满意$size内定的规格,那么重返该doc。

The $size operator matches any array with
the number of elements specified by the argument.

db.collection.find( { array: { $size: n } } );

四,数组包蕴钦命的五个因素

The $all operator selects the documents
where the value of a field is an array that contains all the specified
elements.

{ array : { $all: [ <value1> , <value2> ... ] } }

$all
表示集合的蕴藏关系,全集包含子集的有所因素。要是数组A包涵数组B,那么A是B的全集,B是A的子集。子集中的装有因素,都留存于全集;全集中的成分,不肯定期存款在于子集。

壹旦array包蕴钦命的数组,那么满意$all条件,再次回到doc,表示钦命数组的成分都设有于array。

示范一,假如四个数组相等,那么那七个数组的要素和及其地方都一致,即在数组的均等地方上,其成分相同。

这八个数组并肩前进,arr壹 和 arr2成分数量1样,不过存在壹样地点上(下标是:一,2)的因素区别;

arr1=[1,2,3] 
arr2=[1,3,2]
arr3=[1,2]

示例2,包括关系(数组成分是int,字符串等原子类型)

$all代表的是带有关系,对于arr=[1,2,3],满意条件{arr:{$all:[2,1]}},arr存在元素壹,二。

以身作则,查询数组中并且存在二,三的doc

{ "_id" : 1, "g" : [ 1, 2, 3 ] }
{ "_id" : 2, "g" : [ 4, 2, 3 ] }
{ "_id" : 3, "g" : [ 4, 2, 5 ] }

db.foo.find({g:{$all:[2,3]}})

查询结果是

{ "_id" : 1, "g" : [ 1, 2, 3 ] }
{ "_id" : 2, "g" : [ 4, 2, 3 ] }

示例三,包涵关系(数组成分是doc)

示范,对于以下集合,每种doc中都有3个数组字段qty,种种数组中蕴涵多少个要素,每一个成分都以内嵌doc。

{_id:1,
   qty: [
          { size: "S", num: 10, color: "yellow" },
          { size: "M", num: 45, color: "blue" },
          { size: "L", num: 100, color: "green" }
        ]
}
{_id:2,
   qty: [
          { size: "S", num: 10, color: "blue" },
          { size: "M", num: 100, color: "red" },
          { size: "L", num: 100, color: "green" }
        ]
}

查询数组成分中color字段同时存在blue 和 green的doc,那三个doc都满意条件。

 db.foo.find({"qty.color":{$all:["blue","green"]}})

 

参考doc:

Update
Operators

Array Update
Operators

Query and Projection
Operators

网站地图xml地图