MongoDB从0到1:高效数据使用方法
// 引入MongoDB客户端
const MongoClient = require('mongodb').MongoClient;
// 定义连接字符串
const url = 'mongodb://localhost:27017';
// 创建新的MongoClient实例
const client = new MongoClient(url);
// 连接到服务器
async function connectToServer() {
try {
await client.connect();
console.log('Connected successfully to server');
} catch (err) {
console.error('Error connecting to server:', err);
}
}
// 选择数据库和集合
const dbName = 'myDatabase';
const collectionName = 'myCollection';
// 插入文档
async function insertDocuments(client) {
const db = client.db(dbName);
const collection = db.collection(collectionName);
try {
const insertResult = await collection.insertOne({ a: 1 });
console.log('Inserted document:', insertResult);
} catch (err) {
console.error('Error inserting document:', err);
}
}
// 关闭连接
async function closeConnection(client) {
try {
await client.close();
console.log('Connection closed');
} catch (err) {
console.error('Error closing connection:', err);
}
}
// 异步函数,从连接到关闭连接
async function main() {
try {
await connectToServer();
await insertDocuments(client);
await closeConnection(client);
} catch (err) {
console.error('Error in main function:', err);
}
}
// 执行主函数
main();
这段代码展示了如何使用MongoDB Node.js驱动程序连接到MongoDB服务器,选择数据库和集合,插入一个文档,然后关闭连接。这是一个简单的流程,但在实际应用中,你可能需要处理更复杂的逻辑,例如查询、更新、删除操作,以及错误处理。
评论已关闭