Amazon DocumentDB 基础语法 #

# 基本连接
mongo --host my-cluster.cluster-abc123.us-east-1.docdb.amazonaws.com \
      --port 27017 \
      --username admin \
      --password \
      --ssl

# 使用连接字符串
mongo "mongodb://admin:password@my-cluster.cluster-abc123.us-east-1.docdb.amazonaws.com:27017/?ssl=true&replicaSet=rs0"

// 默认提示符
>

// 显示当前数据库
rs0:PRIMARY>

// 自定义提示符
prompt = function() {
  return db.getName() + "> ";
}

// 显示帮助
help

// 数据库操作
show dbs              // 显示所有数据库
use mydb              // 切换数据库
db                    // 显示当前数据库
db.dropDatabase()     // 删除当前数据库

// 集合操作
show collections      // 显示所有集合
db.createCollection("users")  // 创建集合
db.users.drop()       // 删除集合

// 查看集合统计
db.users.stats()
db.users.dataSize()
db.users.indexStats()

// DocumentDB在首次插入数据时创建数据库
use mydb

// 插入数据后数据库才真正创建
db.users.insertOne({ name: "张三" })

// 查看数据库
show dbs

// 切换到指定数据库
use mydb

// 查看当前数据库
db.getName()

// 删除当前数据库
use mydb
db.dropDatabase()

// 输出
{ "dropped": "mydb", "ok": 1 }

// 显式创建
db.createCollection("users")

// 带选项创建
db.createCollection("logs", {
  capped: false,
  max: 10000,
  size: 5242880
})

// 隐式创建（插入时自动创建）
db.products.insertOne({ name: "商品A" })

// 显示所有集合
show collections

// 获取集合列表
db.getCollectionNames()

// 查看集合详情
db.users.stats()

// 删除集合
db.users.drop()

// 输出
true

// 重命名集合
db.users.renameCollection("customers")

// 跨数据库重命名（不支持）
// DocumentDB不支持跨数据库重命名

// insertOne
db.users.insertOne({
  name: "张三",
  age: 30,
  email: "zhangsan@example.com",
  createdAt: new Date()
})

// 返回结果
{
  "acknowledged": true,
  "insertedId": ObjectId("65a1b2c3d4e5f67890123456")
}

// insertMany
db.users.insertMany([
  {
    name: "李四",
    age: 25,
    email: "lisi@example.com"
  },
  {
    name: "王五",
    age: 28,
    email: "wangwu@example.com"
  }
])

// 返回结果
{
  "acknowledged": true,
  "insertedIds": [
    ObjectId("65a1b2c3d4e5f67890123457"),
    ObjectId("65a1b2c3d4e5f67890123458")
  ]
}

// 有序插入（遇到错误停止）
db.users.insertMany(
  [
    { _id: 1, name: "用户1" },
    { _id: 1, name: "用户2" },  // 重复ID
    { _id: 2, name: "用户3" }
  ],
  { ordered: true }
)

// 无序插入（继续插入其他文档）
db.users.insertMany(
  [
    { _id: 1, name: "用户1" },
    { _id: 1, name: "用户2" },
    { _id: 2, name: "用户3" }
  ],
  { ordered: false }
)

// 查询所有文档
db.users.find({})

// 格式化输出
db.users.find({}).pretty()

// 查询特定字段
db.users.find({ name: "张三" })

// 查询单个文档
db.users.findOne({ name: "张三" })

// 比较操作符
db.products.find({ price: { $eq: 100 } })      // 等于
db.products.find({ price: { $ne: 100 } })      // 不等于
db.products.find({ price: { $gt: 100 } })      // 大于
db.products.find({ price: { $gte: 100 } })     // 大于等于
db.products.find({ price: { $lt: 100 } })      // 小于
db.products.find({ price: { $lte: 100 } })     // 小于等于
db.products.find({ price: { $in: [100, 200] } })  // 在列表中
db.products.find({ price: { $nin: [100, 200] } }) // 不在列表中

// 逻辑操作符
db.users.find({
  $and: [
    { age: { $gte: 18 } },
    { status: "active" }
  ]
})

db.users.find({
  $or: [
    { role: "admin" },
    { role: "superuser" }
  ]
})

db.users.find({
  age: { $not: { $lt: 18 } }
})

db.users.find({
  $nor: [
    { status: "deleted" },
    { status: "banned" }
  ]
})

// 元素操作符
db.users.find({ email: { $exists: true } })
db.users.find({ age: { $type: "int" } })

// 数组操作符
db.users.find({ tags: "编程" })                    // 数组包含
db.users.find({ tags: { $all: ["编程", "阅读"] } }) // 包含所有
db.users.find({ tags: { $size: 3 } })              // 数组长度
db.users.find({ tags: { $elemMatch: { $gt: 5 } } }) // 数组元素匹配

// 包含字段
db.users.find(
  { name: "张三" },
  { name: 1, email: 1 }
)

// 排除字段
db.users.find(
  { name: "张三" },
  { password: 0, createdAt: 0 }
)

// 数组切片
db.posts.find(
  {},
  { comments: { $slice: 5 } }  // 前5条评论
)

db.posts.find(
  {},
  { comments: { $slice: [10, 5] } }  // 跳过10条，取5条
)

// 数组元素匹配
db.users.find(
  {},
  { grades: { $elemMatch: { $gte: 80 } } }
)

// 排序
db.users.find({}).sort({ age: 1 })      // 升序
db.users.find({}).sort({ age: -1 })     // 降序
db.users.find({}).sort({ age: -1, name: 1 })  // 多字段排序

// 分页
db.users.find({}).skip(0).limit(10)     // 第1页
db.users.find({}).skip(10).limit(10)    // 第2页
db.users.find({}).skip(20).limit(10)    // 第3页

// 计数
db.users.countDocuments({})
db.users.countDocuments({ status: "active" })

// 去重
db.users.distinct("city")

// $set - 设置字段值
db.users.updateOne(
  { name: "张三" },
  { $set: { age: 31, city: "上海" } }
)

// $unset - 删除字段
db.users.updateOne(
  { name: "张三" },
  { $unset: { tempField: "" } }
)

// $inc - 数值增减
db.products.updateOne(
  { _id: 1 },
  { $inc: { stock: -1 } }
)

// $mul - 数值乘法
db.products.updateOne(
  { _id: 1 },
  { $mul: { price: 1.1 } }
)

// $rename - 重命名字段
db.users.updateOne(
  { name: "张三" },
  { $rename: { "oldName": "newName" } }
)

// $setOnInsert - 仅在插入时设置
db.users.updateOne(
  { _id: 1 },
  { $setOnInsert: { createdAt: new Date() } },
  { upsert: true }
)

// $push - 添加数组元素
db.users.updateOne(
  { name: "张三" },
  { $push: { tags: "新标签" } }
)

// $push带选项
db.users.updateOne(
  { name: "张三" },
  {
    $push: {
      scores: {
        $each: [90, 85, 88],
        $sort: -1,
        $slice: 5
      }
    }
  }
)

// $pull - 删除匹配元素
db.users.updateOne(
  { name: "张三" },
  { $pull: { tags: "旧标签" } }
)

// $pullAll - 删除多个元素
db.users.updateOne(
  { name: "张三" },
  { $pullAll: { tags: ["标签1", "标签2"] } }
)

// $addToSet - 添加唯一元素
db.users.updateOne(
  { name: "张三" },
  { $addToSet: { tags: "新标签" } }
)

// $pop - 删除首尾元素
db.users.updateOne(
  { name: "张三" },
  { $pop: { tags: 1 } }  // 1删除最后一个，-1删除第一个
)

// $ - 更新第一个匹配元素
db.users.updateOne(
  { "grades.grade": 85 },
  { $set: { "grades.$.comment": "良好" } }
)

// updateOne - 更新一个文档
db.users.updateOne(
  { name: "张三" },
  { $set: { age: 31 } }
)

// updateMany - 更新多个文档
db.users.updateMany(
  { status: "pending" },
  { $set: { status: "active" } }
)

// replaceOne - 替换整个文档
db.users.replaceOne(
  { _id: 1 },
  { name: "张三", age: 30, city: "北京" }
)

// findOneAndUpdate - 查找并更新
db.users.findOneAndUpdate(
  { name: "张三" },
  { $inc: { loginCount: 1 } },
  { returnDocument: "after" }
)

// upsert选项
db.users.updateOne(
  { email: "new@example.com" },
  { $set: { name: "新用户" } },
  { upsert: true }
)

// deleteOne - 删除一个文档
db.users.deleteOne({ name: "张三" })

// deleteMany - 删除多个文档
db.users.deleteMany({ status: "inactive" })

// findOneAndDelete - 查找并删除
db.users.findOneAndDelete(
  { name: "张三" },
  { sort: { createdAt: -1 } }
)

// 删除所有文档
db.users.deleteMany({})

// 带写关注删除
db.users.deleteOne(
  { _id: 1 },
  { writeConcern: { w: "majority" } }
)

// 带条件删除
db.users.deleteMany({
  createdAt: { $lt: new Date("2023-01-01") }
})

// 批量操作
db.users.bulkWrite([
  {
    insertOne: {
      document: { name: "用户1", age: 25 }
    }
  },
  {
    updateOne: {
      filter: { name: "用户2" },
      update: { $set: { age: 26 } }
    }
  },
  {
    deleteOne: {
      filter: { name: "用户3" }
    }
  },
  {
    replaceOne: {
      filter: { name: "用户4" },
      replacement: { name: "用户4", age: 27 }
    }
  }
])

// 有序批量操作
db.users.bulkWrite([...], { ordered: true })

// 无序批量操作
db.users.bulkWrite([...], { ordered: false })

// 带写关注
db.users.bulkWrite([...], {
  ordered: false,
  writeConcern: { w: "majority" }
})

数据库命名规则：
├── 不能包含：/\. "$*<>:|?
├── 不能以"system."开头
├── 长度限制：64字节
├── 区分大小写
└── 建议：使用小写和下划线

集合命名规则：
├── 不能包含：$ 或 null
├── 不能以"system."开头
├── 不能包含点号（嵌套除外）
├── 长度限制：120字节
├── 区分大小写
└── 建议：使用复数形式

字段命名规则：
├── 不能包含：.
├── 不能以$开头
├── 区分大小写
├── _id为保留字段
└── 建议：使用驼峰命名