Mongoose中不使用模型和Schema进行数据查询

mongoose通常通过模型和schema来操作数据，但当需要直接访问mongodb集合而不定义mongoose schema时，可以使用`connection.prototype.collection()`方法。此方法允许开发者绕过mongoose的orm层，直接利用mongodb node.js驱动的功能进行查询和操作，适用于处理无schema数据或需要原生驱动行为的场景。

Mongoose的常规操作与挑战

在使用Mongoose进行数据操作时，我们通常会遵循以下模式：首先定义一个Schema来描述数据的结构和类型，然后基于这个Schema创建一个Mongoose Model。所有的数据查询、创建、更新和删除操作都通过这个Model进行。例如：

import mongoose from 'mongoose';

const yourSchema = new mongoose.Schema({
  name: {
    first: String,
    last: String
  },
  occupation: String
});

const Person = mongoose.model('Person', yourSchema);

async function queryWithModel() {
  await mongoose.connect('mongodb://localhost:27017/yourDatabase');
  // 使用Model进行查询，Mongoose会进行类型转换、验证等操作
  const person = await Person.findOne({ 'name.last': 'Ghost' }, 'name occupation');
  console.log(person);
  await mongoose.disconnect();
}

// queryWithModel();

这种方式提供了强大的数据验证、类型转换、中间件以及关联查询等ORM（对象关系映射）功能，极大地简化了开发。然而，在某些特定场景下，我们可能不希望或不需要定义Mongoose Schema和Model：

1. 集合中数据结构不固定或无Schema： 当MongoDB集合中的文档结构高度动态，或根本没有预设的Schema时。
2. 需要直接访问原生MongoDB驱动功能： Mongoose是MongoDB Node.js驱动的抽象层，有时我们需要使用驱动提供的某些Mongoose未封装的低级功能。
3. 绕过Mongoose的验证和中间件： 在某些性能敏感或特殊的数据导入/导出场景中，可能需要跳过Mongoose的验证、类型转换和中间件处理，直接与数据库交互。

解决方案：直接访问MongoDB集合

Mongoose提供了一个方法，允许我们绕过其ORM层，直接获取底层的MongoDB Node.js驱动的集合实例。这个方法就是Connection.prototype.collection()。

根据Mongoose官方文档的描述：

Connection.prototype.collection()检索一个原始的集合实例，如果未缓存则创建它。此方法返回一个围绕MongoDB Node.js驱动集合的轻量级包装。使用Collection会绕过Mongoose中间件、验证和类型转换，让您可以直接使用MongoDB Node.js驱动的功能。

这意味着，通过此方法获得的collection对象，你可以像使用MongoDB Node.js驱动那样对其进行操作，而无需先定义Mongoose Model。

实际操作示例

下面是一个详细的示例，演示如何使用Connection.prototype.collection()方法直接查询数据库中的chats集合，而无需定义Mongoose Model。

import mongoose from 'mongoose';

// 替换为你的MongoDB连接字符串
const MONGODB_URI = 'mongodb://localhost:27017/yourDatabaseName';

async function queryRawCollection() {
  let db; // 声明db变量以便在finally块中访问

  try {
    // 1. 建立Mongoose连接
    // 使用 createConnection 以便独立管理连接，而不是使用默认连接
    db = await mongoose.createConnection(MONGODB_URI);
    console.log('数据库连接成功。');

    // 2. 获取原始的MongoDB集合实例
    // 'chats' 是你数据库中已存在的集合名称
    const collection = db.collection('chats');
    console.log('成功获取 "chats" 集合实例。');

    // 3. 使用MongoDB驱动的find方法进行查询
    // 注意：这里的find方法是MongoDB驱动的，不是Mongoose Model的
    console.log('正在查询 "chats" 集合中的所有文档...');
    const cursor = await collection.find({}); // 查询所有文档
    const docs = await cursor.toArray(); // 将游标转换为数组以获取所有结果

    console.log('查询结果:', docs);

  } catch (error) {
    console.error('查询过程中发生错误:', error);
  } finally {
    // 4. 确保关闭数据库连接
    if (db) {
      await db.close();
      console.log('数据库连接已关闭。');
    }
  }
}

// 执行主函数
queryRawCollection().catch(console.error);

代码说明：

• mongoose.createConnection(MONGODB_URI)：我们使用createConnection方法创建一个独立的数据库连接。这比使用mongoose.connect()（它会使用Mongoose的默认连接）更灵活，尤其是在需要管理多个数据库连接或进行特定连接操作时。
• db.collection('chats')：这是核心步骤。通过已建立的db连接实例，调用collection()方法并传入集合的名称（例如'chats'），即可获得一个直接操作该集合的MongoDB驱动Collection对象。
• collection.find({})：现在你可以像使用MongoDB Node.js驱动那样调用find、insertOne、updateOne等方法。find()方法返回一个游标（Cursor），需要使用toArray()或forEach()等方法来迭代结果。
• try...catch...finally：为了确保代码的健壮性，我们使用try...catch来捕获可能发生的错误，并在finally块中确保数据库连接被正确关闭。

使用场景与注意事项

何时使用：

• 处理无Schema数据： 当你的MongoDB集合中的文档结构不固定，或者你不想为它们定义一个严格的Mongoose Schema时。
• 性能优化： 在一些对性能要求极高的场景下，绕过Mongoose的中间件、验证和类型转换可以减少一些开销。
• 访问原生驱动功能： 当Mongoose没有提供你需要的特定MongoDB驱动功能时，这是直接访问这些功能的途径。
• 数据迁移或批量操作： 在进行大量数据的导入、导出或转换时，直接使用原生驱动可能更高效和灵活。

注意事项：

• 失去Mongoose特性： 一旦你绕过Mongoose Model直接操作集合，你将失去Mongoose提供的所有便利功能，包括：
  • Schema验证： 数据将不会根据Mongoose Schema进行验证。
  • 类型转换： Mongoose的自动类型转换（如字符串转ObjectId）将不再生效。
  • 中间件： pre和post钩子（如加密密码、更新时间戳）将不会被触发。
  • 虚拟属性（Virtuals）和关联查询（Population）： 这些高级ORM功能将无法使用。
• 手动错误处理： 你需要更细致地处理MongoDB驱动可能返回的错误。
• 一致性风险： 如果你的应用同时使用Mongoose Model和直接集合操作，可能会导致数据不一致或难以维护。建议在明确需要且理解其影响的情况下使用此方法。

总结

Connection.prototype.collection()方法是Mongoose提供的一个强大工具，它允许开发者在必要时绕过Mongoose的ORM层，直接与底层的MongoDB集合交互。这为处理无Schema数据、访问原生驱动功能或进行性能优化提供了灵活性。然而，使用此方法意味着放弃Mongoose提供的诸多便利特性，因此在使用前务必权衡其利弊，并确保理解其对应用数据管理和维护的影响。