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：
- 集合中数据结构不固定或无Schema： 当MongoDB集合中的文档结构高度动态，或根本没有预设的Schema时。
- 需要直接访问原生MongoDB驱动功能： Mongoose是MongoDB Node.js驱动的抽象层，有时我们需要使用驱动提供的某些Mongoose未封装的低级功能。
- 绕过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。
具有服装类网店的常用的功能和完善的商品类型管理、商品管理、配送支付管理、订单管理、会员分组、会员管理、查询统计和多项商品促销功能。系统具有静态HTML生成、UTF-8多语言支持、可视化模版引擎等技术特点，适合建立服装、鞋帽、服饰类网店。系统具有以下主要功能模块： 网站参数设置 - 对网站的一些参数进行个性化定义 会员类型设置 - 可以任意创建多个会员类型，设置不同会员类型的权限和价格级别 货币类型
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提供的诸多便利特性，因此在使用前务必权衡其利弊，并确保理解其对应用数据管理和维护的影响。
