MongoDB Mongoose：使用点表示法精准更新嵌套对象字段

{
  _id: ObjectId('XXX'),
  tenant_id: 'tenantId_123',
  ck_details: {
    leadId: 'lead_abc',
    refNum: 'ref_xyz'
  }
}

{
  _id: ObjectId('XXX'),
  tenant_id: 'tenantId_123',
  ck_details: {
    leadId: 'lead_abc',
    refNum: 'ref_xyz',
    appId: 'app_123' // 新增属性
  }
}

// 错误示例：会替换整个 ck_details 对象
TenantModel.updateOne(
  { tenant_id: 'tenantId_123' },
  { $set: { ck_details: { appId: 'app_123' } } }
);

// 错误示例：$push 用于数组，不适用于对象
TenantModel.updateOne(
  { tenant_id: 'tenantId_123' },
  { $set: { ck_details: { $push: { appId: 'app_123' } } } }
);

import { Schema, model, connect, Document } from 'mongoose';

// 1. 定义接口和 Mongoose Schema
interface ICkDetails {
  leadId: string;
  refNum: string;
  appId?: string; // appId 是可选的，因为最初可能不存在
}

interface ITenant extends Document {
  tenant_id: string;
  ck_details: ICkDetails;
}

const CkDetailsSchema = new Schema<ICkDetails>({
  leadId: { type: String, required: true },
  refNum: { type: String, required: true },
  appId: { type: String, required: false }
});

const TenantSchema = new Schema<ITenant>({
  tenant_id: { type: String, required: true, unique: true },
  ck_details: { type: CkDetailsSchema, required: true }
});

const TenantModel = model<ITenant>('Tenant', TenantSchema);

// 2. 数据库连接（示例，实际应用中请替换为您的连接字符串）
async function connectDB() {
  try {
    await connect('mongodb://localhost:27017/myDatabase');
    console.log('MongoDB connected successfully.');
  } catch (error) {
    console.error('MongoDB connection error:', error);
    process.exit(1);
  }
}

// 3. 演示更新操作
async function updateTenantCkDetails() {
  await connectDB();

  const tenantId = 'tenantId_123';
  const newAppId = 'app_123';

  // 确保有一个初始文档用于演示
  await TenantModel.findOneAndUpdate(
    { tenant_id: tenantId },
    {
      $setOnInsert: { // 如果文档不存在则插入
        tenant_id: tenantId,
        ck_details: {
          leadId: 'lead_abc',
          refNum: 'ref_xyz'
        }
      }
    },
    { upsert: true, new: true, setDefaultsOnInsert: true }
  );
  console.log('初始或更新后的文档：');
  let initialDoc = await TenantModel.findOne({ tenant_id: tenantId });
  console.log(JSON.stringify(initialDoc?.toObject(), null, 2));


  console.log(`\n正在更新 tenant_id 为 '${tenantId}' 的文档，添加 'ck_details.appId' 为 '${newAppId}'...`);

  try {
    const result = await TenantModel.updateOne(
      { tenant_id: tenantId },
      { $set: { 'ck_details.appId': newAppId } } // 正确使用点表示法
    );

    if (result.matchedCount > 0) {
      console.log(`更新成功！匹配 ${result.matchedCount} 个文档，修改 ${result.modifiedCount} 个文档。`);
      const updatedDoc = await TenantModel.findOne({ tenant_id: tenantId });
      console.log('更新后的文档：');
      console.log(JSON.stringify(updatedDoc?.toObject(), null, 2));
    } else {
      console.log(`未找到 tenant_id 为 '${tenantId}' 的文档进行更新。`);
    }
  } catch (error) {
    console.error('更新失败:', error);
  } finally {
    // await mongoose.disconnect(); // 生产环境中通常不会立即断开
  }
}

updateTenantCkDetails();