Method query

lib/connectors/mongodb-connector.ts:64–303

(queryDescription: QueryDescription)

  }

  async query(queryDescription: QueryDescription): Promise<any | any[]> {
    await this._makeConnection();

    if (queryDescription.type === "create") {
      // There is no need to initialize collections in MongoDB
      return [];
    }

    const collection = this._database!.collection(queryDescription.table!);

    let wheres: { [k: string]: any } = {};
    if (queryDescription.wheres) {
      for (const whereClause of queryDescription.wheres) {
        if (whereClause.field === "_id") {
          whereClause.value = new Bson.ObjectId(whereClause.value);
        }
      }

      wheres = queryDescription.wheres.reduce((prev, curr) => {
        let mongoOperator = "$eq";

        switch (curr.operator) {
          case "<":
            mongoOperator = "$lt";
            break;

          case "<=":
            mongoOperator = "$lte";
            break;

          case ">":
            mongoOperator = "$gt";
            break;

          case ">=":
            mongoOperator = "$gte";
            break;
        }

        return {
          ...prev,
          [curr.field]: {
            [mongoOperator]: curr.value,
          },
        };
      }, {});
    }

    let results: any[] = [];

    switch (queryDescription.type) {
      case "drop":
        await collection.deleteMany({});
        break;

      case "insert":
        const defaultedValues = queryDescription.schema.defaults;
        let values = Array.isArray(queryDescription.values)