Method runQuery

packages/mongodb/src/MongoConnection.ts:449–589

(
    method: 'insertOne' | 'insertMany' | 'updateMany' | 'bulkUpdateMany' | 'deleteMany' | 'countDocuments',
    entityName: EntityName<T>,
    data?: Partial<T> | Partial<T>[],
    where?: FilterQuery<T> | FilterQuery<T>[],
    ctx?: Transaction<ClientSession>,
    opts?: {
      upsert?: boolean;
      upsertOptions?: UpsertOptions<T>;
      loggerContext?: LoggingOptions;
      collation?: CollationOptions;
      indexHint?: string | Dictionary;
      maxTimeMS?: number;
      signal?: AbortSignal;
    },
  )

  }

  private async runQuery<T extends object, U extends QueryResult<T> | number = QueryResult<T>>(
    method: 'insertOne' | 'insertMany' | 'updateMany' | 'bulkUpdateMany' | 'deleteMany' | 'countDocuments',
    entityName: EntityName<T>,
    data?: Partial<T> | Partial<T>[],
    where?: FilterQuery<T> | FilterQuery<T>[],
    ctx?: Transaction<ClientSession>,
    opts?: {
      upsert?: boolean;
      upsertOptions?: UpsertOptions<T>;
      loggerContext?: LoggingOptions;
      collation?: CollationOptions;
      indexHint?: string | Dictionary;
      maxTimeMS?: number;
      signal?: AbortSignal;
    },
  ): Promise<U> {
    await this.ensureConnection();
    const { upsert, upsertOptions, loggerContext, collation, indexHint, maxTimeMS, signal } = opts ?? {};
    const collection = this.getCollectionName(entityName);
    const logger = this.config.getLogger();
    const options: Dictionary = ctx ? { session: ctx, upsert } : { upsert };

    if (options.upsert === undefined) {
      delete options.upsert;
    }

    if (signal) {
      options.signal = signal;
    }

    const now = Date.now();
    let res: InsertOneResult<T> | InsertManyResult<T> | UpdateResult | DeleteResult | BulkWriteResult | number;
    let query: string;
    const log = (msg: () => string) => (logger.isEnabled('query') ? msg() : '');

    switch (method) {
      case 'insertOne':
        Object.keys(data as Dictionary)
          .filter(k => typeof (data as Dictionary)[k] === 'undefined')
          .forEach(k => delete (data as Dictionary)[k]);
        query = log(
          () => `db.getCollection('${collection}').insertOne(${this.logObject(data)}, ${this.logObject(options)});`,
        );
        res = await this.rethrow(
          this.getCollection(entityName).insertOne(data as OptionalUnlessRequiredId<T>, options),
          query,
        );
        break;
      case 'insertMany':
        (data as Dictionary[]).forEach(data =>
          Object.keys(data)
            .filter(k => typeof data[k] === 'undefined')
            .forEach(k => delete data[k]),
        );
        query = log(
          () => `db.getCollection('${collection}').insertMany(${this.logObject(data)}, ${this.logObject(options)});`,
        );
        res = await this.rethrow(