MongoDB

部署文档

格式化，挂载磁盘

mkdir /data
mkfs.xfs -f -i size=512 /dev/vdb
blkid | grep vdb
/dev/vdb: UUID="34ce2c2f-66f6-46e6-9a5a-b0919458e1d8" TYPE="xfs"
echo 'UUID="34ce2c2f-66f6-46e6-9a5a-b0919458e1d8" /data xfs defaults 0 0' >> /etc/fstab
mount -a

创建数据目录

mkdir /data/mongodb/mo_primary
mkdir /var/log/mongodb

编辑配置文件

cat << Rainy > /etc/mongodb/primary.conf
net:
    bindIp: 1.mongodb.private
    port: 27017
security:
    authorization: enabled
    keyFile: "/etc/mongodb/mongo_key"
storage:
    journal:
        enabled: true
    dbPath: "/data/mongodb/mo_primary"
    directoryPerDB: true
    engine: wiredTiger
    wiredTiger:
        engineConfig:
            directoryForIndexes: true
        collectionConfig:
            blockCompressor: zlib
        indexConfig:
            prefixCompression: true
systemLog:
    path: "/var/log/mongodb/mo_sxszxl_primary.log"
    logAppend: true
    destination: file
processManagement:
    fork: true
replication:
    replSetName: mo_sxszxl
Rainy

密钥文件

cat << Rainy > /etc/mongodb/mongo_key
eXpJNT8VwRtreerwfyLnn4FdG/ajAlksa2s0C720F6TRMxLDiGw8Jchdk7c+Zfhp
Va6nX4iZTT1MukiFSnv9D3l4JY5UeX/qewAo06Jg3cOpwEhfAzIQO+mGnHtRetsj
YxFVQ2lKqclpSAoQLFyv1AqW71z8LxcizPGQymS/hWwEMFd2Lj65d26KjCQaRDTZ
LiXkjJ0zfsPcZqyOeOJ2TDKnuUbLYPwtuYc5a2EAOrDAkBeXwadoiY8qi0S2fDoN
FGR9IAE3mQMHs/MqjFtUmHa3lrW2i3EejR4EuoyuYvSUBRdvmVs8ARP2LLYIga7M
lijeH97hCVT8M5KLDO2Zf9mZpRBwXojjBVf0MSGd+/gpOSprKl6McQd+qCvQWBBs
1aWFqyOJwOUeQwCc8wvZx/BMHqDW7YT4IpAjcVhvWI+/dQbsMKNkXIES22LatdZl
D8BYJXUjqHgrNyv6s8p/zxk9Ffho3s+cyP0BbuLkR8rCyT+jUGKx/NW29xxttA04
5prcXdyScOKmg4WyVRD9DoXmHDNx9uVnbjXWN4bwSfiVG6uY1cN6ibAvdiBbOaI0
RatKcR1X+DPnuKFV8xVGiFDN1UjWoW+GJQQWTgY16PErzs7PT9eHwTh7DqY9Cj+6
ryHsxT1baCrWHzYD6BjJLT9ytiCJ2F5wW1TQg0jlCMjnsy0tHpY6HVMQFVgvzZR2
3bsFOzcp+VFwVjzW9HpOKFIru35mKv8gTMPROVU5ZUQZBabjX4hQp4Q4x+Xjn15p
EG7fVpbYhEkbAuVIMBTTPZUN0x0rUDwVY79sXfw523ri+VtbUAnSGqiFUWUkbtUm
vOf8vP0el+6UdEbdG0lQNWbrUVyUCJG5S/WYjv3ect47YGHkAH1PC3E00hCK+1Ph
taJYE4oVz6ZMe9KXal+QbRQP3RcAvW42/5DBc9zXhyFufb62+m3mUgrR1mZWq/YZ
85Cu4ebnXuRuDZ95RKvzRBBE7aprkyAk4/upOUH7Mvt4zK5
Rainy

搭建集群

# /opt/mongodb/bin/mongo --port 27017
rs_config = {
    _id: "mo_sxszga",
    members: [
        {
            _id: 0,
            host: "1.mongodb.private:27017",
            arbiterOnly: false
        },
        {
            _id: 1,
            host: "2.mongodb.private:27017",
            arbiterOnly: false
        },
        {
            _id: 2,
            host: "3.mongodb.private:27017",
            arbiterOnly: false
        },
    ]
}
rs.initiate(rs_config)
exit

查询操作

MongoDB 查询文档使用 find() 方法。
find() 方法以非结构化的方式来显示所有文档。

语法

MongoDB 查询数据的语法格式如下：

db.collection.find(query, projection)

• query ：可选，使用查询操作符指定查询条件
• projection ：可选，使用投影操作符指定返回的键。查询时返回文档中所有键值， 只需省略该参数即可（默认省略）。

如果你需要以易读的方式来读取数据，可以使用 pretty() 方法，语法格式如下：

db.col.find().pretty()

pretty() 方法以格式化的方式来显示所有文档。

实例

> db.col.find().pretty()
{
        "_id" : ObjectId("56063f17ade2f21f36b03133"),
        "title" : "MongoDB 教程",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
}
---
> db.col.find({"title" : "MongoDB 教程"}).pretty()
{
        "_id" : ObjectId("56063f17ade2f21f36b03133"),
        "title" : "MongoDB 教程",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
}

除了 find() 方法之外，还有一个 findOne() 方法，它只返回一个文档。

MongoDB 与 RDBMS Where 语句比较

MongoDB AND 条件

MongoDB 的 find() 方法可以传入多个键(key)，每个键(key)以逗号隔开，即常规 SQL 的 AND 条件。
语法格式如下：

db.col.find({key1:value1, key2:value2}).pretty()

实例

以下实例通过 by 和 title 键来查询 菜鸟教程 中 MongoDB 教程 的数据

> db.col.find({"by":"菜鸟教程", "title":"MongoDB 教程"}).pretty()
{
        "_id" : ObjectId("56063f17ade2f21f36b03133"),
        "title" : "MongoDB 教程",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
}

以上实例中类似于 WHERE 语句：WHERE by=’菜鸟教程’ AND title=’MongoDB 教程’

MongoDB OR 条件

MongoDB OR 条件语句使用了关键字 $or,语法格式如下：

>db.col.find(
   {
      $or: [
         {key1: value1}, {key2:value2}
      ]
   }
).pretty()

实例

以下实例中，我们演示了查询键 by 值为 菜鸟教程 或键 title 值为 MongoDB 教程 的文档。

db.col.find({$or:[{"by":"菜鸟教程"},{"title": "MongoDB 教程"}]}).pretty()
{
        "_id" : ObjectId("56063f17ade2f21f36b03133"),
        "title" : "MongoDB 教程",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
}

AND 和 OR 联合使用

以下实例演示了 AND 和 OR 联合使用，类似常规 SQL 语句为： ‘where likes>50 AND (by = ‘菜鸟教程’ OR title = ‘MongoDB 教程’)’

db.col.find({"likes": {$gt:50}, $or: [{"by": "菜鸟教程"},{"title": "MongoDB 教程"}]}).pretty()
{
        "_id" : ObjectId("56063f17ade2f21f36b03133"),
        "title" : "MongoDB 教程",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
}

MongoDB 排序

MongoDB sort() 方法

在 MongoDB 中使用 sort() 方法对数据进行排序，sort() 方法可以通过参数指定排序的字段，并使用 1 和 -1 来指定排序的方式，其中 1 为升序排列，而 -1 是用于降序排列。

语法

sort()方法基本语法如下所示：

db.COLLECTION_NAME.find().sort({KEY:1})

实例

col 集合中的数据如下：

{ "_id" : ObjectId("56066542ade2f21f36b0313a"), "title" : "PHP 教程", "description" : "PHP 是一种创建动态交互性站点的强有力的服务器端脚本语言。", "by" : "菜鸟教程", "url" : "http://www.runoob.com", "tags" : [ "php" ], "likes" : 200 }
{ "_id" : ObjectId("56066549ade2f21f36b0313b"), "title" : "Java 教程", "description" : "Java 是由Sun Microsystems公司于1995年5月推出的高级程序设计语言。", "by" : "菜鸟教程", "url" : "http://www.runoob.com", "tags" : [ "java" ], "likes" : 150 }
{ "_id" : ObjectId("5606654fade2f21f36b0313c"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by" : "菜鸟教程", "url" : "http://www.runoob.com", "tags" : [ "mongodb" ], "likes" : 100 }

以下实例演示了 col 集合中的数据按字段 likes 的降序排列：

db.col.find({},{"title":1,_id:0}).sort({"likes":-1})
{ "title" : "PHP 教程" }
{ "title" : "Java 教程" }
{ "title" : "MongoDB 教程" }

更新操作

MongoDB 使用 update() 和 save() 方法来更新集合中的文档。接下来让我们详细来看下两个函数的应用及其区别。

update() 方法

update() 方法用于更新已存在的文档。语法格式如下：

db.collection.update(
   <query>,
   <update>,
   {
     upsert: <boolean>,
     multi: <boolean>,
     writeConcern: <document>
   }
)

参数说明：

• query : update的查询条件，类似sql update查询内where后面的。
• update : update的对象和一些更新的操作符（如$,$inc…）等，也可以理解为sql update查询内set后面的
• upsert : 可选，这个参数的意思是，如果不存在update的记录，是否插入objNew,true为插入，默认是false，不插入。
• multi : 可选，mongodb 默认是false,只更新找到的第一条记录，如果这个参数为true,就把按条件查出来多条记录全部更新。

• writeConcern :可选，抛出异常的级别。

  实例

  我们在集合 col 中插入如下数据：

  db.col.insert({
    title: 'MongoDB 教程', 
    description: 'MongoDB 是一个 Nosql 数据库',
    by: '菜鸟教程',
    url: 'http://www.runoob.com',
    tags: ['mongodb', 'database', 'NoSQL'],
    likes: 100
  })

  接着我们通过 update() 方法来更新标题(title):

  db.col.update({'title':'MongoDB 教程'},{$set:{'title':'MongoDB'}})
  WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })   # 输出信息
  > db.col.find().pretty()
  {
        "_id" : ObjectId("56064f89ade2f21f36b03136"),
        "title" : "MongoDB",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "菜鸟教程",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "database",
                "NoSQL"
        ],
        "likes" : 100
  }

  可以看到标题(title)由原来的 “MongoDB 教程” 更新为了 “MongoDB”。
  以上语句只会修改第一条发现的文档，如果你要修改多条相同的文档，则需要设置 multi 参数为 true。

  db.col.update({'title':'MongoDB 教程'},{$set:{'title':'MongoDB'}},{multi:true})

  save() 方法

  save() 方法通过传入的文档来替换已有文档，_id 主键存在就更新，不存在就插入。语法格式如下：

  db.collection.save(
   <document>,
   {
     writeConcern: <document>
   }
  )

  参数说明：

• document : 文档数据。

• writeConcern :可选，抛出异常的级别.

  实例

  以下实例中我们替换了 _id 为 56064f89ade2f21f36b03136 的文档数据：

  db.col.save({
    "_id" : ObjectId("56064f89ade2f21f36b03136"),
    "title" : "MongoDB",
    "description" : "MongoDB 是一个 Nosql 数据库",
    "by" : "Runoob",
    "url" : "http://www.runoob.com",
    "tags" : [
            "mongodb",
            "NoSQL"
    ],
    "likes" : 110
  })

  替换成功后，我们可以通过 find() 命令来查看替换后的数据

  db.col.find().pretty()
  {
        "_id" : ObjectId("56064f89ade2f21f36b03136"),
        "title" : "MongoDB",
        "description" : "MongoDB 是一个 Nosql 数据库",
        "by" : "Runoob",
        "url" : "http://www.runoob.com",
        "tags" : [
                "mongodb",
                "NoSQL"
        ],
        "likes" : 110
  }

  更多实例

  只更新第一条记录：
  db.col.update( { “count” : { $gt : 1 } } , { $set : { “test2” : “OK”} } );
  全部更新：
  db.col.update( { “count” : { $gt : 3 } } , { $set : { “test2” : “OK”} },false,true );
  只添加第一条：
  db.col.update( { “count” : { $gt : 4 } } , { $set : { “test5” : “OK”} },true,false );
  全部添加进去:
  db.col.update( { “count” : { $gt : 5 } } , { $set : { “test5” : “OK”} },true,true );
  全部更新：
  db.col.update( { “count” : { $gt : 15 } } , { $inc : { “count” : 1} },false,true );
  只更新第一条记录：
  db.col.update( { “count” : { $gt : 10 } } , { $inc : { “count” : 1} },false,false );

导出数据

方式一

/opt/mongodb/bin/mongoexport --host 3.mongodb.private  --port 27017 -p F2ja7pPxsLUsPmbGMvq1y87j -d gbadmin -u gbadmin -c gbadmin_channel --type=csv -f channel_id,cid,civil_code,device_id,name,parent_id,status,  -q '{"platform_id" : ObjectId("5fe07ab61d41c85117cf555b")}' -o ./pan_20211006.csv
/opt/mongodb/bin/mongoexport --host 2.mongodb.private  --port 27017 -p 14Mfgt721AM7MSMNXzoSmEMu -d gbadmin -u gbadmin -c gbadmin_device --type=csv -f channel_id,cid,name,device_id,parent_id,server_id,deleted -q '{"deleted" : 0}' -o ./GB_devices.csv

方式二

cat test.js
var c = db.gbadmin_channel.find({"platform_id" : ObjectId("5fe07ab61d41c85117cf555b"),  "deleted" : 0})
while(c.hasNext()) {
    printjsononeline(c.next());
}
/opt/mongodb/bin/mongo --port 27017 --host 1.mongodb.private -u gbadmin -p F2ja7pPxsLUsPmbGMvq1y87j --authenticationDatabase gbadmin gbadmin test.js > 1.txt