1. 安装 mongodb 驱动程序：
在你的 Node.js 项目中安装 mongodb 驱动程序：
npm install mongodb
2. 连接到 MongoDB 数据库：
const { MongoClient } = require('mongodb');
// 连接到 MongoDB 数据库
const uri = 'mongodb://localhost:27017/your-database-name';
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });
// 连接数据库
client.connect((err) => {
if (err) {
console.error('Error connecting to MongoDB:', err);
return;
}
console.log('Connected to MongoDB database');
});
请将上述代码中的 mongodb://localhost:27017/your-database-name 替换为你的 MongoDB 数据库的实际连接字符串。
3. 执行 MongoDB 操作：
// 获取对集合的引用
const collection = client.db('your-database-name').collection('your-collection-name');
// 插入文档
collection.insertOne({ name: 'John Doe', age: 30 }, (insertErr, result) => {
if (insertErr) {
console.error('Error inserting document:', insertErr);
return;
}
console.log('Inserted document:', result.ops[0]);
});
// 查询文档
collection.find({ name: 'John Doe' }).toArray((findErr, documents) => {
if (findErr) {
console.error('Error finding documents:', findErr);
return;
}
console.log('Found documents:', documents);
});
在实际应用中，你可能会执行更多复杂的操作，例如更新文档、删除文档、使用过滤器等。
4. 使用连接池：
对于生产环境，建议使用连接池来管理 MongoDB 连接，以提高性能和效率。以下是使用连接池的示例：
const { MongoClient } = require('mongodb');
// 创建 MongoDB 连接池
const uri = 'mongodb://localhost:27017/your-database-name';
const poolSize = 10;
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true, poolSize });
// 在需要时从连接池中获取连接
async function exampleUsingConnectionPool() {
const connection = await client.connect();
try {
const collection = connection.db().collection('your-collection-name');
// 执行 MongoDB 操作
} finally {
connection.release(); // 释放连接回连接池
}
}
// 连接池连接不再使用时，关闭连接
process.on('SIGINT', () => {
client.close();
process.exit();
});
使用连接池可以更好地管理 MongoDB 连接，避免每次操作都手动创建和关闭连接。
这是一个基本的使用 MongoDB 数据库的示例。在实际应用中，你可能需要更多的错误处理、索引优化、使用 Mongoose 等 ORM（对象-文档映射器）库等。确保根据项目的需求使用适当的安全措施。
转载请注明出处：http://www.pingtaimeng.com/article/detail/13175/Node.js