MongoDB ¸ßÊÖ¿Î

tar -xvf dump.tar.gz
mongorestore --uri="mongodb://root:root@10.130.0.12/?&authMechanism=SCRAM-SHA-1"

// ²åÈë
db.fruit.insertOne({name: "apple"})
db.fruit.insertMany([
  {name: "apple"},
  {name: "pear"},
  {name: "orange"},
])
// ²éѯ
db.customers.find({username: "fmiller", name: "Elizabeth Ray"})
db.customers.find({username: /^f/})
db.customers.find({$or: [{username: /^f/}, {name: /^E/}]})

// ͬʱÂú×ã
{$eleMatch: {"city": "Rome", "country": "USA"}}

// ͶӰ projection
// like select
db.customers.find({username: /^f/}, {name: 0, email: 0})
db.customers.find({username: /^f/}, {_id: 1, name: 1})

// remove
db.customers.remove({username: "abrown"})

// update
db.customers.updateOne({username: "fmiller"}, {$set: {from: "China"}})
db.customers.updateMany({username: "fmiller"}, {$set: {from: "China"}})
// $set $unset
// $push $pushAll $pop Êý×é²Ù×÷
// $pull $pullAll Èç¹ûÆ¥Å䣬´ÓÊý×éÖÐɾ³ýÏàÓ¦µÄ¶ÔÏó
// $addToSet Èç¹û²»´æÔÚÔòÔö¼ÓÒ»¸öÖµµ½Êý×é

// drop
db.fruit.drop()
show collections

db
db.dropDatabase()
show dbs

pipeline = [stage1, stage2, ...]
db.<collection>.aggregate(
  pipeline,
  { option }
)

// ¼ÆËã×ܺϼÆ
db.orders.aggregate([
    {
        $group: {
            _id: null,
            total: {$sum: "$total"}
        }
    }
])
// {
//     "_id": null,
//     "total": NumberDecimal("44019609")
// }

// ²éѯ 2019 µÚÒ»¼¾¶È£¬ÒÑÍê³É¶©µ¥£¨completed£©×ܽð¶î£¨½ð¶î+ÔË·Ñ£©ºÍ¶©µ¥×ÜÊý
db.orders.aggregate([
    {
        $match: {
            status: "completed",
            orderDate: { $gte: ISODate("2019-01-01"), $lt: ISODate("2019-04-01") }
        }
    },
    {
        $group: {
            _id: null,
            total: { $sum: "$total" },
            shippingFee: { $sum: "$shippingFee" },
            count: { $sum: 1 }
        }
    },
    {
        $project: {
            grandTotal: { $add: ["$total", "$shippingFee"] },
            count: 1,
            _id: 0
        }
    }
])
// {
//     "count": 5875,
//     "grandTotal": NumberDecimal("2636376")
// }

mkdir -p runtime/data_db{1,2,3} && \
mkdir -p runtime/data_configdb{1,2,3}

hostname -f

rs.status()

db.contacts.aggregate([
  $lookup: {
    form: "groups",
    localField: "groups_ids",
    foreignField: "groups_id",
    as: "groups",
  }
])

{ w: <value>, j: <boolean>, wtimeout: <number> }

rs.status();
db.test.drop()
db.test.insert({count:2}, {writeConcern: {w: "majority"}})
db.test.insert({count:2}, {writeConcern: {w: 3}})
db.test.insert({count:2}, {writeConcern: {w: 1}})
// WriteResult({ "nInserted" : 1, "writeConcernError" : [ ] })

db.test.insert({count:2}, {writeConcern: {w: 4}})
// [Error] 100 - Not enough data-bearing nodes

db.test.find()

// ÅäÖÃÑӳٽڵ㣬ģÄâÍøÂçÑÓ³Ù
conf=rs.conf()
// {
//     "_id": 3,
//     "host": "mongo3:27017",
//     "arbiterOnly": false,
//     "buildIndexes": true,
//     "hidden": false,
//     "priority": 1,
//     "tags": { },
//     "slaveDelay": NumberLong("0"),
//     "votes": 1
// }
conf.members[2].slaveDelay=5
// ûÓÐÑ¡¾ÙȨ
conf.members[2].priority=0
rs.reconfig(conf)
// {
//     "_id": 3,
//     "host": "mongo3:27017",
//     "arbiterOnly": false,
//     "buildIndexes": true,
//     "hidden": false,
//     "priority": 0,
//     "tags": { },
//     "slaveDelay": NumberLong("5"),
//     "votes": 1
// }

db.test.insert({count:2}, {writeConcern: {w: 3}})
// Result Time 5s

// 3s ³¬Ê±
db.test.insert({count:5}, {writeConcern: {w: 3, wtimeout:3000}})
// writeResult({
//         "nInserted" : 1,
//         "writeConcernError" : {
//                 "code" : 64,
//                 "codeName" : "WriteConcernFailed",
//                 "errmsg" : "waiting for replication timed out",
//                 "errInfo" : {
//                         "wtimeout" : true,
//                         "writeConcern" : {
//                                 "w" : 3,
//                                 "wtimeout" : 3000,
//                                 "provenance" : "clientSupplied"
//                         }
//                 }
//         }
// })

// Ö÷½Úµã
db.test.drop()
db.test.insert({count:2}, {writeConcern: {w: 3}})
db.test.find({})
// 1 line
db.test.find({}).readPref("secondary")
// 1 line

// ´Ó½Úµã 1¡¢2
db.test.find({})
// 1 line
db.fsyncLock()
// now locked against writes, use db.fsyncUnlock() to unlock ËøסдÈë

// Ö÷½Úµã
db.test.insert({count:3})
db.test.find({})
// 2 line
db.test.find().readPref("secondary")
// 1 line

// ´Ó½Úµã 1¡¢2
db.fsyncUnlock()
// Ö÷½Úµã
db.test.find().readPref("secondary")

// ´Ó½Úµã 1¡¢2
db.fsyncLock()
// Ö÷½Úµã
db.test.insert({count:3})
db.test.find().readConcern("local")
// Èç¹ûÔÚÒ»¸öд²Ù×÷µ½´ï´ó¶àÊý½ÚµãÇ°¶ÁÈ¡ÁËÕâ¸öд²Ù×÷£¬È»ºóÒòΪϵͳ¹ÊÕϸòÙ×÷»Ø¹öÁË£¬Ôò·¢ÉúÁËÔà¶Á
// {readConcern: "majority"} ¿ÉÒÔ±ÜÃâÔà¶Á
db.test.find().readConcern("majority")

db.tx.drop();
db.tx.insertMany([{x:1},{x:2}]);
var session = db.getMongo().startSession();
session.startTransaction();
var coll = session.getDatabase('test').getCollection('tx');
coll.updateOne({x:2}, {$set: {y:1}});
// {
//   acknowledged: true,
//   insertedId: null,
//   matchedCount: 1,
//   modifiedCount: 1,
//   upsertedCount: 0
// }
coll.find();
// [
//   { _id: ObjectId("64478074fcfac90fb90f1a65"), x: 1 },
//   { _id: ObjectId("64478074fcfac90fb90f1a66"), x: 2, y: 1 }
// ]
db.tx.find();
// [
//   { _id: ObjectId("64478074fcfac90fb90f1a65"), x: 1 },
//   { _id: ObjectId("64478074fcfac90fb90f1a66"), x: 2 }
// ]
session.commitTransaction();
db.tx.find();

db.tx.drop();
db.tx.insertMany([{x:1},{x:2}]);
var session = db.getMongo().startSession();
session.startTransaction({
  readConcern: {"level": "snapshot"},
  writeConcern: {"w": "majority"}
});
var coll = session.getDatabase('test').getCollection('tx');
coll.findOne({x: 1});
// Ä£ÄâÊÂÎñÖ®ÍâµÄ²Ù×÷
db.tx.updateOne({x:1}, {$set: {y:1}});
db.tx.find();
// [
//   { _id: ObjectId("644782c3fcfac90fb90f1a69"), x: 1, y: 1 },
//   { _id: ObjectId("644782c3fcfac90fb90f1a6a"), x: 2 }
// ]
coll.findOne({x: 1});
// { _id: ObjectId("644782c3fcfac90fb90f1a69"), x: 1 }
session.abortTransaction();

db.tx.drop();
db.tx.insertMany([{x:1},{x:2}]);
// shell 1¡¢2
var session = db.getMongo().startSession();
session.startTransaction({
  readConcern: {"level": "snapshot"},
  writeConcern: {"w": "majority"}
});
var coll = session.getDatabase('test').getCollection('tx');
// shell 1
coll.updateOne({x:1}, {$set: {y:1}});
// ok

// shell 2
coll.updateOne({x:1}, {$set: {y:1}});
// MongoServerError: WriteConflict error: this operation conflicted with another operation. Please retry your operation or multi-document transaction.
// session.abortTransaction();

# 1 ÅäÖÃÓòÃû½âÎö
# 2 ×¼±¸·ÖƬĿ¼

# 3 ´´½¨µÚ1¸ö·ÖƬ¸´ÖƼ¯ member1:27010 member3:27010 member5:27010
mongod --bind_ip_all --replSet shard1 --shardsvr --wiredTigerCacheSizeGB 1
# --shardsvr ±êעΪ·ÖƬ½Úµã
# --wiredTigerCacheSizeGB 1 »º´æ´óС
# 4 ³õʼ»¯·ÖƬ¸´ÖƼ¯

# 5 ´´½¨ config server ¸´ÖƼ¯ member1:27019 member3:27019 member5:27019
mongod --bind_ip_all --replSet config --configsvr --wiredTigerCacheSizeGB 1
# --configsvr ±êעΪÅäÖýڵã
# 6 ´´½¨ config server ¸´ÖƼ¯

# 7 ´î½¨ mongos member1:27017
mongos --bind_ip_all --configdb config/member1:27019,member3:27019,member5:27019,
# Á¬½Óµ½ mongos Ìí¼Ó·ÖƬ
sh.addShard("shard1/member1:27010,member3:27010,member5:27010")

# 8 ´´½¨·ÖƬ±í
# Á¬½Óµ½ mongos member1:27017
sh.enableSharding("foo");
sh.shardCollection("foo.bar", {_id: "hashed"});
sh.status();
# ²åÈë²âÊÔÊý¾Ý
use foo
for(var i=0;1<10000;i++) {
  db.bar.insert({i:i))
}

# 9 ´´½¨µÚ2¸ö·ÖƬ¸´ÖƼ¯  member2:27011 member4:27011 member6:27011
# 10 ³õʼ»¯µÚ2¸ö·ÖƬ¸´ÖƼ¯
# 11 ¼ÓÈëµÚ2¸ö·ÖƬ
# Á¬½Óµ½ mongos Ìí¼Ó·ÖƬ
sh.addShard("shard2/member2:27011,member4:27011,member6:27011")

db.createRole({
   role: "readWriteRole",
   privileges: [
      {
        resource: { db: "myDatabase", collection: "sample" },
        actions: [ "find", "insert", "update", "remove" ]
      }
   ],
   roles: [{
      role: 'read',
      db: 'sampledb',
   }]
})
db.createUser({
  user: 'sampleUser',
  pwd: 'pwd',
  roles: [{
      role: 'readWriteRole',
      db: 'admin',
   }]
})

# ½ûÖ¹½Å±¾Ö´ÐÐ
--noscripting
# ±ØÐë¼øȨ
--auth