MongoDB: ドキュメント更新：updateOneとupdateManyの詳解

// ❌ 反例：先に確認してから更新（競合状態）
app.post('/api/orders', async (req, res) => {
  const product = await Product.findOne({ sku: 'PHONE-001' });

  if (product.stock <= 0) {
    return res.status(400).json({ error: 'Out of stock' });
  }

  // ⚠️ 同時実行の問題：両方のリクエストが stock=1 を読み取り
  await Product.updateOne(
    { sku: 'PHONE-001' },
    { $inc: { stock: -1 } }
  );
  // 両方のリクエストが正常に引当、結果として在庫が-1になる
});

// ✅ 正例：フィルター条件 + 原子操作
app.post('/api/orders', async (req, res) => {
  const result = await Product.updateOne(
    { sku: 'PHONE-001', stock: { $gt: 0 } },  // 重要：条件フィルタリング
    { $inc: { stock: -1 } }
  );

  if (result.modifiedCount === 0) {
    return res.status(400).json({ error: 'Out of stock' });
  }
  // 変更された件数が1の場合のみ成功
});

// === updateOne基本使用法 ===
db.products.updateOne(
  { sku: "PHONE-001" },        // フィルター
  { $set: { price: 699.99 } }  // 更新
);

const result = await Product.updateOne(
  { sku: 'PHONE-001' },
  { $set: { stock: 50 } }
);

result.acknowledged;   // true（書き込み確認済み）
result.matchedCount;    // 1（1件マッチ）
result.modifiedCount;   // 1（実際に1件変更）
result.upsertedCount;   // 0（挿入なし）

const result = await Product.updateOne(
  { sku: 'NOT_EXIST' },
  { $set: { stock: 0 } }
);
print(result.matchedCount);   // 0
print(result.modifiedCount);  // 0
// エラーなし、変更なし

// === 単一フィールドを変更 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { price: 699.99 } }
);

// === 複数フィールドを変更 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  {
    $set: {
      price: 699.99,
      stock: 50,
      lastUpdated: new Date()
    }
  }
);

// === ネストフィールドを更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "specs.battery": "5000mAh" } }
);

// === Mongoose相当の記述 ===
const result = await Product.updateOne(
  { sku: 'PHONE-001' },
  { $set: { price: 699.99, lastUpdated: new Date() } }
);

// === updateMany基本使用法 ===
db.products.updateMany(
  { category: 'Electronics' },   // フィルター（複数マッチ）
  { $set: { discount: 0.1 } }    // 更新（一括適用）
);

// ⚠️ updateManyはトランザクションによるロールバックに対応していない
// 途中で失敗した場合、既に変更された内容はロールバックされない

// ⚠️ 大規模な更新はコレクションをロックする可能性がある
// バッチサイズ制御の使用を推奨：
const BATCH_SIZE = 1000;
let modified = 0;
let lastId = null;

while (true) {
  const result = await Product.updateMany(
    {
      category: 'Electronics',
      _id: { $gt: lastId }
    },
    { $set: { onSale: true } },
    { limit: BATCH_SIZE }  // Mongooseオプション
  );
  if (result.modifiedCount === 0) break;
  modified += result.modifiedCount;
}

// === 全Electronics商品に10%割引を適用 ===
db.products.updateMany(
  { category: 'Electronics' },
  { $mul: { price: 0.9 } }
);

// === 全ての期限切れ商品を出品停止 ===
db.products.updateMany(
  { expiryDate: { $lt: new Date() } },
  { $set: { isActive: false } }
);

// === 5つ星評価の商品全てにタグを追加 ===
db.products.updateMany(
  { rating: { $gte: 4.8 } },
  { $addToSet: { tags: 'top-rated' } }
);

// === updateOne：指定フィールドのみ変更 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { price: 699 } }
);
// 結果：{ _id, sku, title, price: 699, stock, category, ... }（他フィールドを保持）

// === replaceOne：ドキュメント全体を置換 ===
db.products.replaceOne(
  { sku: 'PHONE-001' },
  { sku: 'PHONE-001', title: 'New Phone', price: 799 }
);
// 結果：{ _id, sku, title: 'New Phone', price: 799 }
// ⚠️ 他のフィールド（stock、categoryなど）は全て失われる！

// ✅ 適用：ドキュメントを完全に書き直し
db.users.replaceOne(
  { _id: 'user_001' },
  {
    _id: 'user_001',
    name: 'Alice',
    email: 'alice@example.com',
    role: 'admin',
    updatedAt: new Date()
  }
);

// ❌ 非適用：1つのフィールドを変更したいだけ（updateOne + $setを使用）

// === フィールド設定 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { stock: 50, isActive: true } }
);

// === ネストフィールド設定 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "specs.battery": "5000mAh" } }
);

// === 配列要素設定 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "tags.0": "5g", "tags.1": "amoled" } }
);

// === 単一フィールド削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $unset: { discount: "" } }
);

// === 複数フィールド削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $unset: { discount: "", internalNotes: "" } }
);

// === ネストフィールド削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $unset: { "specs.battery": "" } }
);

// === 在庫減少 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $inc: { stock: -1 } }
);

// === 閲覧数+1 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $inc: { viewCount: 1 } }
);

// === 複数フィールドの累積スコア ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $inc: { stock: -1, soldCount: 1, viewCount: 1 } }
);

// === 10%割引を適用 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $mul: { price: 0.9 } }
);

// === 価格を倍増 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $mul: { price: 2 } }
);

// === フィールド名変更 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $rename: { "stock": "inventory" } }
);
// stock → inventory

// === ネストフィールド名変更 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $rename: { "specs.battery": "specs.batteryCapacity" } }
);

// === $min：値が小さい場合のみ更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $min: { price: 500 } }
);
// 現在の価格 > 500 の場合、500に変更、それ以外は変更なし

// === $max：値が大きい場合のみ更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $max: { price: 1000 } }
);

// === 現在時刻を設定 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $currentDate: { lastModified: true } }
);

// === Date型で設定 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $currentDate: { lastModified: { $type: "date" } } }
);

// === upsert時のみデフォルト値を設定 ===
db.products.updateOne(
  { sku: 'NEW-001' },
  {
    $set: { price: 599 },
    $setOnInsert: { createdAt: new Date(), stock: 0 }
  },
  { upsert: true }
);
// 挿入時：{ sku: 'NEW-001', price: 599, createdAt: ..., stock: 0 }
// 更新時：{ sku: 'NEW-001', price: 599 }（createdAt、stockは設定されない）

// === 支払い成功後に注文ステータスを更新 ===
db.orders.updateOne(
  { _id: orderId },
  {
    $set: {
      status: 'paid',
      paidAt: new Date(),
      paymentMethod: 'credit_card'
    },
    $inc: { version: 1 },         // 楽観ロックバージョン番号
    $currentDate: { updatedAt: true }
  }
);

// === ユーザーログイン後に最終ログイン時刻を更新 ===
db.users.updateOne(
  { _id: userId },
  {
    $set: { lastLoginAt: new Date(), lastLoginIp: '192.168.1.1' },
    $inc: { loginCount: 1 }
  }
);

// === 単一要素追加 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $push: { tags: 'bestseller' } }
);

// === 複数要素追加（$each）===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $push: { tags: { $each: ['5g', 'amoled', 'fast-charging'] } } }
);

// === 配列サイズを制限（$slice + $position）===
db.products.updateOne(
  { sku: 'PHONE-001' },
  {
    $push: {
      tags: {
        $each: ['new1', 'new2', 'new3'],
        $slice: -5,            // 最後の5件のみ保持
        $position: 0           // 先頭から挿入
      }
    }
  }
);

// === 指定値を削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $pull: { tags: 'old-tag' } }
);

// === 条件を満たす全要素を削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $pull: { tags: { $in: ['outdated1', 'outdated2'] } } }
);

// === 存在しない要素のみ追加 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $addToSet: { tags: 'new-tag' } }
);
// tagsに'new-tag'が含まれている場合は追加しない

// === 複数追加（$each）===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $addToSet: { tags: { $each: ['tag1', 'tag2'] } } }
);

// === 末尾要素を削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $pop: { tags: 1 } }
);

// === 先頭要素を削除 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $pop: { tags: -1 } }
);

// === 位置インデックスで更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "tags.0": "updated-first-tag" } }
);

// === $位置演算子で更新（最初にマッチした要素）===
db.products.updateOne(
  { sku: 'PHONE-001', "reviews.userId": 'user_001' },
  { $set: { "reviews.$.helpful": 10 } }
);
// userId='user_001'のコメントを見つけ、helpfulフィールドを設定

// === 全配列要素を一括更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "reviews.$[].status": "approved" } }
);
// 全コメントのstatus → approved

// === 全配列要素を更新 ===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "reviews.$[].status": "approved" } }
);

// === 条件に基づいて配列要素を更新（arrayFilters）===
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "reviews.$[lowRating].flagged": true } },
  {
    arrayFilters: [{ "lowRating.rating": { $lt: 2 } }]
  }
);
// rating < 2のコメントのみ対象

// === シーン：eコマースレビューシステム ===
// 1. コメントを追加
db.products.updateOne(
  { sku: 'PHONE-001' },
  {
    $push: {
      reviews: {
        userId: 'user_001',
        rating: 5,
        content: 'Excellent phone!',
        createdAt: new Date(),
        helpful: 0
      }
    }
  }
);

// 2. 特定ユーザーのコメントを削除
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $pull: { reviews: { userId: 'user_001' } } }
);

// 3. 低評価のレビューにフラグを立てる
db.products.updateOne(
  { sku: 'PHONE-001' },
  { $set: { "reviews.$[r].flagged": true } },
  { arrayFilters: [{ "r.rating": { $lt: 2 } }] }
);

// 4. コメント数を最大100件に制限
db.products.updateOne(
  { sku: 'PHONE-001' },
  {
    $push: {
      reviews: {
        $each: [newReview],
        $slice: -100
      }
    }
  }
);

// === upsert: false（デフォルト）===
const result1 = await Product.updateOne(
  { sku: 'NEW-001' },
  { $set: { price: 599 } }
);
print(result1.matchedCount);   // 0（マッチなし）
print(result1.modifiedCount);  // 0
print(result1.upsertedCount);  // 0

// === upsert: true ===
const result2 = await Product.updateOne(
  { sku: 'NEW-001' },
  { $set: { price: 599 } },
  { upsert: true }
);
print(result2.upsertedCount);  // 1（1件挿入）
print(result2.upsertedId);     // ObjectId('...')

// === 完全なupsertパターン ===
db.products.updateOne(
  { sku: 'NEW-001' },
  {
    $set: { price: 599, updatedAt: new Date() },
    $setOnInsert: { createdAt: new Date(), stock: 0, viewCount: 0 }
  },
  { upsert: true }
);

// === 存在しない場合に挿入：{ sku: 'NEW-001', price: 599, updatedAt: ..., createdAt: ..., stock: 0, viewCount: 0 }
// === 存在する場合に更新：{ sku: 'NEW-001', price: 599, updatedAt: ..., createdAt: <古い値> }

// === ユーザーログイン履歴upsert ===
db.user_logins.updateOne(
  {
    userId: 'user_001',
    date: '2026-07-01'
  },
  {
    $set: { lastLoginAt: new Date() },
    $inc: { loginCount: 1 },
    $setOnInsert: { firstLoginAt: new Date() }
  },
  { upsert: true }
);
// 毎日の初回ログイン時にレコードを作成、以降は更新

// === ショッピングカートupsert ===
db.carts.updateOne(
  { userId: 'user_001' },
  {
    $set: { updatedAt: new Date() },
    $inc: { totalItems: 2 }
  },
  { upsert: true }
);

// ✅ 安全：フィルター条件 + 原子操作
const result = await Product.updateOne(
  { sku: 'PHONE-001', stock: { $gt: 0 } },
  { $inc: { stock: -1 } }
);

// ❌ 安全でない：先に確認してから更新（競合状態）
const product = await Product.findOne({ sku: 'PHONE-001' });
if (product.stock > 0) {
  await Product.updateOne(
    { sku: 'PHONE-001' },
    { $inc: { stock: -1 } }
  );
}

// === 最適化1：一括更新で複数回の個別更新を代替 ===
// ❌ 低速：100回のupdateOne
for (const item of items) {
  await Product.updateOne({ sku: item.sku }, { $inc: { stock: -item.qty } });
}

// ✅ 高速：1回のbulkWrite
await Product.bulkWrite(
  items.map(item => ({
    updateOne: {
      filter: { sku: item.sku, stock: { $gte: item.qty } },
      update: { $inc: { stock: -item.qty, soldCount: item.qty } }
    }
  })),
  { ordered: false }
);

// === 最適化2：インデックスフィールドでフィルタリング ===
// ✅ インデックスあり：db.products.updateOne({ sku: 'PHONE-001' }, ...)
// ⚠️ インデックスなし：db.products.updateOne({ title: 'Phone' }, ...)

// === UpdateResult処理 ===
async function updateProductStock(sku, qty) {
  const result = await Product.updateOne(
    { sku, stock: { $gte: qty } },
    { $inc: { stock: -qty, soldCount: qty } }
  );

  if (result.matchedCount === 0) {
    throw new Error(`Out of stock or item not available: ${sku}`);
  }

  if (result.modifiedCount === 0) {
    throw new Error('Update Failed');
  }

  return result;
}