目录

插入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。

  • 一、前言
    • (一)
      运转环境
  • 二、先前时代准备工作
    • (一) 创制 MongoDBContext
      MongoDb操作上下文类
    • (2)创造测试类
    • 金沙注册送58 ,(3)
      创制测试代码
  • 三、内嵌数组增法郎素操作
    • (1) Update.Set()方法
      替换内嵌数组(不推荐使用)
    • (2)Update.Push()方法
      直接将成分压入内嵌数组(推荐)
    • (叁) Update.PushEach()方法
      将多少个因素压入内嵌数组(推荐)
  • 四、内嵌数组删除成分操作
    • (一) Update.Set()方法
      替换内嵌数组(不引入应用)
    • (二) Update.Pull()方法
      Pull删除2个要素(推荐)
    • (叁)Update.PullFilter()方法
      删除过滤器删除成分(推荐)
  • 5、内嵌数组修改成分操作
    • (一) Update.Set()
      Set先查询后修改(不引入)
    • (二) Update.Set()
      合作过滤器修改(推荐)
  • 6、内嵌数组查找成分操作(Linq)
    • (1)Linq查询一条记下(推荐)
    • (2)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 }
> 

【金沙注册送58】停放文档的操作,MongoDB学习笔记三。只要在推行批量布置的经过中有叁个文档插入失利,那么在这一个文书档案在此以前的有着文书档案都会插入成功,之后的有着一切战败。

> 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.5本子驱动,大家能够通过下载GitHub源码自行编写翻译,或许通过NuGet包管理工科具安装。
GitHub地址:戳1戳查看、Link
NuGet地址:戳1戳查看、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 }
> 

壹,使用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字段。

(2)创设测试类

若果当前是2个物联网数据搜集项目,在那之中有多如牛毛个传感器节点(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有四个必须参数:

1是查询文书档案,用于固定需求立异的靶子文书档案

二是修改器文书档案,用于阐明要找到的文书档案实行怎样修改

履新操作是不可分割的:借使多个更新还要产生,先抵达服务器的先实施,接着执行另贰个。

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有八个必须参数:

1是查询文书档案,用于固定须求立异的对象文书档案

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

更新操作是不可分割的:若是七个更新还要爆发,先抵达服务器的先实施,接着执行另贰个。

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;
}

文书档案替换

用3个新文书档案完全替换相称的文档,那符合广大形式迁移的情况。

  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')}."
        }
})
> 

文书档案替换

用四个新文书档案完全替换匹配的文书档案,那契合广大方式迁移的景况。

  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暗中同意只会更新匹配的第2条,假如要立异多条,还得钦定参数。

应用修改器时,_id的值不能够更改。(整个文书档案替换时能够更改“_id”)

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

(1) 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})

(2)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

(3) 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"})

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

$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 添澳元素。倘使数组已经存在,会向已部分数组末尾出席二个因素,借使未有就创办2个新的数组。

> 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."
                }
        ]
}
> 

二,修改字段的值

(1) 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 子操作符,能够透过1次 $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 操作添加八个值。

譬如:上边将七个新因素添加到数组中。倘诺钦命的数组中只包蕴1个要素,那么等同和尚未采取“$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用于任意数据类型,替换字段的值。

(2) Update.Pull()方法 Pull删除一个因素(推荐)

// 假设需要删除的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

(3)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"} ]
   }
}
)

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

金沙注册送58 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字段的都扩张一

(2) 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不能使用。

金沙注册送58 2

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

关键是SelectMany()方法的采取,此情势用于选取1个数组。

#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

3,$set 和
$inc的不一致之处在于:$set是替换现有字段的值,而$inc是在现有字段值的根基上,扩展或回落钦命的数值

(2)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方法二义性解决方案:

示范,使用$set修改age的值,更新截止后,每一个doc的age字段都以一

七、总结

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

3,修改数组

只要要向数组中追加或删除贰个成分,$set和$inc
都不能够很好的满意那种须要,MongoDB有专用的 Array
Operator,用于修改数组字段。

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

$push:假设doc中留存对应的数组字段,那么向数组的尾巴部分插入1个元素;借使doc中不存在对应的数组字段,那么向doc中创制三个数组字段,并初叶化。

演示,第壹次调用$push,由于doc中不存在comments字段,由此MongoDB向doc中新建comments
数组字段,并初阶化数组

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

以身作则,后续再一次调用$push,向已有的数组字段的尾巴增添二个因素

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

图示,左侧是数组的率先个要素,右侧是数组的末梢一个成分,使用$push每便向数组的尾巴扩大1个因素

金沙注册送58 3

2,向数组字段插入多少个要素

$push 修改器每回只好向数组字段的后面部分插入1个成分,搭配使用$each
修改器,每一回能向数组字段中插入七个要素

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

图示,使用$each,三次将三个要素插入到数组的尾巴

金沙注册送58 4

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

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

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

图示,使用$position
钦命成分插入的始发地点,将c伍,c6依次插入都数组的二,三岗位处,由于数组的小标是从0伊始的,c5,c陆是数组的第1,四个要素金沙注册送58 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.

4,限制数组相月素的多寡

在$push
成分时,使用$slice=马克斯Num限制数组成分的最大数量。只要未有直达最大数目,就会向数组中插入新的要素,直到达到最大值。$slice必须和$each搭配使用,假诺数组字段的因素的数量已经达到最大值,根据马克斯Num值的不等,会有两样的行事:

  • 借使马克斯Num=0,表示将数组清空;
  • 假诺MaxNum是正整数,表示数组只保留前边的马克斯Num个要素;
  • 1旦马克斯Num是负整数,表示数组只保留后边的马克斯Num个成分;

以身作则,保留每种comments的末梢三个成分

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

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

金沙注册送58 6

伍,对数组字段的因素进行排序

在限定数组字段的成分数量事先,使用$sort
操作符对成分进行排序,是数组成分有序排列。在$sort操作之后选取$slice:马克斯Num
修改器,由于数组成分是已成定论的,能够只保留类别前边或前面包车型地铁特定数量的要素。

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

图示,$each 向现有的数组的尾部中插入八个成分:c7,c八,c九,$sort:{msg:-一}
对数组遵照msg的降序排序,$slice:-5操作符限制数组的要素数量,只保留数组尾巴部分的两个成分。

金沙注册送58 7

只要数组是[1,2,3]那体系型,那么$sort:壹,依据壹,二,三 升序排列;
$sort:-一,安装三,二,一 降序排列。

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

通过$push
插入成分,有望插入重复的因素,MongoDB允许数组中的成分重复;要是三个数组不可能插入重复值,能够采取$addToSet修改器,
$addToSet在向数组插入成分时,首先检查成分是或不是曾经存在于数组中,就算不存在,那么$addToSet将成分插入到数组中;假若存在,那么$addToSet不会插入任何因素。$addToSet只会保险不会插入重复的要素,不应影响数组中曾经存在的再度成分。

$addToSet 能够3次性向数组中插入多少个成分。

$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的因素是在队列尾部,是数组的首先个要素,小标最大的要素是数组的末段3个成分。使用$pop删除成分时,{$pop:{array:一}}
表示删除数组的末梢一个要素,{$pop:{array:-一}}
表示删除数组的首先个因素。

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

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

金沙注册送58 8

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

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

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

金沙注册送58 9

玖,依据数组的下标修改成分,数组下标是从0早先的

对此js的数组 arr,包蕴八个element,修改第3个成分的like
字段,将其值设置为贰.

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}}
)

图示,向数组的首先个因素中追加likes字段,并开端化为一

金沙注册送58 10

一旦不晓得数组成分的下标,MongoDB提供占位符
$,用于表示从数组中搜寻满足query filter的第一个成分。占位符 $
须要对数组举办检索,查找的query
filter必须显式提供,若是存在多少成分满足query filter,那么$
占位符表示第二个地位11分的数组成分的position,即使未有数组成分满意query
filter,那么MongoDB不会对数据任何效用。

$占位符的选拔格式,跟数组的因素类型有关:

  • 比方数组成分是doc,那么使用 $ 占位符的格式是:arrary.$.田野先生。
  • 1经数组的要素类型是原子类型,例如,[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。

示例二,对数组成分实行询问,只要存在别的3个成分的msg字段的值c四,就在该因素中扩充1个unlikes字段,并初步化为一.

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

图示,$ 占位符表示匹配query filter的率先个要素

金沙注册送58 11

四,数组的询问

一,元素匹配符 $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中都有3个grades 数组:

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

示范1,对于query filter:{grades:{$gt:八伍,
$lt:十0}},分析那1个数组是或不是知足:

  • 第二个数组:成分 90 满意超越 85,全体的因素都低于拾0
  • 第贰个数组:全体的因素知足条件
  • 首个数组:成分90,100
    满足超越八五的规格,成分捌伍,90满足小于十0的口径 

为此,只要数组中有其余贰个成分满意qeury filter,固然满意qeury
filter,这叁个数组都满意query filter。
示例2,query filter:{grades:90}

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

3,查询数组成分的多寡

$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一 和 arr二元素数量壹样,可是存在一样地点上(下标是:壹,二)的因素差异;

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

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

$all表示的是富含关系,对于arr=[1,2,3],满意条件{arr:{$all:[2,1]}},arr存在成分一,二。

以身作则,查询数组中并且存在2,三的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 ] }

示例3,包蕴关系(数组成分是doc)

示范,对于以下集合,每一个doc中都有贰个数组字段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地图