第3章 数据建模与 Schema 设计 ​

// mongosh：插入带内嵌评论数组的文档
db.posts.insertOne({
  title: "MongoDB 建模",
  author: { id: ObjectId("..."), name: "tom" },        // 少量作者信息快照
  comments: [
    { user: "amy", text: "写得真好", time: new Date() },
    { user: "bo",  text: "受教了",   time: new Date() }
  ],
  commentCount: 2
});

// 追加一条评论：单文档原子，无需事务
db.posts.updateOne({ _id: postId }, {
  $push: { comments: newComment },
  $inc:  { commentCount: 1 }
});

// mongosh：帖子只存 authorId（≈ 外键，但无约束）
db.users.insertOne({ username: "tom", email: "tom@yjoffer.com" });
db.posts.insertOne({
  title: "新文章",
  authorId: authorOid,
  tags: ["mongodb"]
});

// 「查文章带作者名」：应用层拿 authorId 再查（$lookup 服务端联法见第 5 章）
db.users.find({ _id: { $in: [authorOid] } }, { username: 1 });

// mongosh：一个文档装一天的 5 分钟粒度数据（12KB 级，远小于 16MB）
db.readings.updateOne(
  { deviceId: devId, date: "2026-10-02", startHour: 10 },
  { $push: { points: { t: 36.5, m: 50 } },   // m = 桶内第几分钟
    $inc:  { count: 1 } },
  { upsert: true }                            // 桶不存在就开新桶
);

// mongosh：按动态字段名写入（点号路径）并只读关心的测点
db.collectors.updateOne({ deviceId: devId }, { $set: { "sensors.temp_1": 36.5, "sensors.temp_2": 36.7 } });
db.collectors.find({}, { "sensors.temp_1": 1 });

// mongosh 对照：同一个校验器，就是 createCollection 的一个参数
db.createCollection("t_user_validated", {
  validator: {
    $jsonSchema: {
      bsonType: "object",
      required: ["username", "age", "status"],
      properties: {
        username: { bsonType: "string", description: "必填用户名" },
        age:      { bsonType: "int", minimum: 0, maximum: 150 },
        status:   { enum: [0, 1, 2] },
        tags:     { bsonType: "array", items: { bsonType: "string" } }
      }
    }
  },
  validationLevel: "strict",      // 全部写入都校验
  validationAction: "error"       // 违规则拒写
});

// 给已存在的集合加校验（对照 ALTER TABLE ADD CONSTRAINT）
db.runCommand({ collMod: "t_user", validator: { $jsonSchema: { /* 同上 */ } } });

// 试写一条非法文档：age 是字符串 → 被拒
db.t_user_validated.insertOne({ username: "x", age: "25", status: 1 });  // DocumentValidationFailure

// t_product：分类名快照内嵌 + SKU 内嵌数组（数量有界，几十级）
{ _id: 1, name: "Java实战", category: 7, categoryName: "图书",   // categoryName 冗余快照，改名需刷数据（权衡！）
  skus: [ { spec: "平装版", price: NumberDecimal("99.00") },
          { spec: "电子书", price: NumberDecimal("49.00") } ] }

// t_stock：独立集合，「商品×仓」一行，$inc 原子扣减不在商品文档上制造写热点
db.t_stock.updateOne({ productId: 1, warehouse: "HZ" }, { $inc: { qty: -2 } })

db.createCollection("t_order_validated", {
  validator: { $jsonSchema: {
    bsonType: "object",
    required: ["orderNo", "amount", "currency", "items"],
    properties: {
      orderNo:  { bsonType: "string", pattern: "^[A-Z]{2}\\d{10}$", description: "两位大写字母+10位数字" },
      amount:   { bsonType: "decimal", minimum: 0 },
      currency: { enum: ["CNY", "USD", "EUR"] },
      items: {
        bsonType: "array", minItems: 1,
        items: {                                          // 数组元素自身的校验
          bsonType: "object",
          required: ["skuId", "qty", "snapshotPrice"],
          properties: {
            skuId:         { bsonType: "string" },
            qty:           { bsonType: "int", minimum: 1 },   // 数量 > 0
            snapshotPrice: { bsonType: "decimal" }            // 下单时刻快照价（3.2.3 的冗余快照）
          }
        }
      }
    }
  }},
  validationLevel: "strict", validationAction: "error"
});

// ✅ 通过
db.t_order_validated.insertOne({ orderNo: "AB2026100001",
  amount: NumberDecimal("128.00"), currency: "CNY",
  items: [{ skuId: "S001", qty: 2, snapshotPrice: NumberDecimal("64.00") }] });

// ❌ 被拒：qty=0 违反 minimum:1；currency="JPY" 不在 enum；输出报错信息：
// DocumentValidationFailure: Document does not match validator...
//   "items.0.qty" : "0 does not satisfy \"minimum\""
db.t_order_validated.insertOne({ orderNo: "AB2026100002",
  amount: NumberDecimal("50.00"), currency: "JPY",
  items: [{ skuId: "S002", qty: 0, snapshotPrice: NumberDecimal("50.00") }] });

db.posts.updateOne({ _id: pid }, {
  $push: { topComments: { $each: [newComment], $slice: -10, $sort: { time: -1 } } },
  $inc:  { commentCount: 1 } })