在Nodejs中执行动态mongoDB查询的最佳方法

const { MongoClient } = require('mongodb');

async function executeDynamicQuery(collectionName, queryConditions) {
  const uri = 'mongodb://localhost:27017'; // MongoDB连接URI
  const client = new MongoClient(uri);

  try {
    await client.connect();

    const database = client.db('mydatabase');
    const collection = database.collection(collectionName);

    const queryBuilder = collection.find();

    // 添加查询条件
    if (queryConditions.name) {
      queryBuilder.filter({ name: queryConditions.name });
    }
    if (queryConditions.age) {
      queryBuilder.filter({ age: queryConditions.age });
    }

    // 添加投影字段
    if (queryConditions.fields) {
      queryBuilder.project(queryConditions.fields);
    }

    // 添加排序规则
    if (queryConditions.sort) {
      queryBuilder.sort(queryConditions.sort);
    }

    const result = await queryBuilder.toArray();
    return result;
  } finally {
    await client.close();
  }
}

// 示例用法
const queryConditions = {
  name: 'John',
  age: { $gt: 30 },
  fields: { name: 1, age: 1 },
  sort: { age: -1 }
};

executeDynamicQuery('users', queryConditions)
  .then(result => {
    console.log(result);
  })
  .catch(error => {
    console.error(error);
  });