Node.js 上 MongoDB 连接的最佳实践是什么

Node.js 上 MongoDB 连接的最佳实践

javascript
const { MongoClient } = require('mongodb');
const { MONGO_URI, MONGO_POOL_SIZE } = require('./config');
const options = {
  poolSize: MONGO_POOL_SIZE,
  useNewUrlParser: true,
  useUnifiedTopology: true,
};
const client = new MongoClient(MONGO_URI, options);
// 在应用程序启动时初始化连接池
async function initializeMongoDB() {
  try {
    await client.connect();
    console.log('MongoDB 连接成功');
  } catch (error) {
    console.error('连接 MongoDB 失败', error);
    process.exit(1);
  }
}
// 在需要访问数据库时从连接池中获取连接
async function getDataFromMongoDB() {
  try {
    const db = client.db('myDatabase');
    const collection = db.collection('myCollection');
    const data = await collection.find().toArray();
    return data;
  } catch (error) {
    console.error('从 MongoDB 获取数据失败', error);
    throw error;
  }
}
// 在数据库操作完成后将连接放回连接池
function releaseMongoDBConnection() {
  client.close();
  console.log('MongoDB 连接已释放');
}

javascript
async function initializeMongoDB() {
  try {
    await client.connect();
    console.log('MongoDB 连接成功');
  } catch (error) {
    if (error instanceof MongoNetworkError) {
      console.error('无法连接到 MongoDB，请检查网络连接', error);
    } else if (error instanceof MongoServerSelectionError) {
      console.error('无法选择 MongoDB 服务器', error);
    } else {
      console.error('连接 MongoDB 失败', error);
    }
    process.exit(1);
  }
}

javascript
async function createIndex() {
  try {
    const db = client.db('myDatabase');
    const collection = db.collection('myCollection');
    await collection.createIndex({ fieldName: 1 });
    console.log('索引创建成功');
  } catch (error) {
    console.error('创建索引失败', error);
  }
}

javascript
const options = {
  poolSize: MONGO_POOL_SIZE,
  maxPoolSize: MONGO_MAX_POOL_SIZE,
  useNewUrlParser: true,
  useUnifiedTopology: true,
};
const client = new MongoClient(MONGO_URI, options);