Method createClient

packages/mongodb/src/MongoConnection.ts:76–103

()

  }

  createClient(): void {
    let driverOptions = this.options.driverOptions ?? this.config.get('driverOptions');

    if (typeof driverOptions === 'function') {
      driverOptions = driverOptions();
    }

    if (driverOptions instanceof MongoClient) {
      this.logger.log('info', 'Reusing MongoClient provided via `driverOptions`');
      this.#client = driverOptions;
    } else {
      this.#client = new MongoClient(
        this.config.get('clientUrl'),
        this.mapOptions(driverOptions as MongoClientOptions),
      );
      this.#client.appendMetadata({
        name: 'MikroORM',
        version: Utils.getORMVersion(),
      });
      const onCreateConnection = this.options.onCreateConnection ?? this.config.get('onCreateConnection');
      /* v8 ignore next */
      this.#client.on('connectionCreated', () => {
        void onCreateConnection?.(this.#client);
      });
    }

    this.#db = this.#client.db(this.config.get('dbName'));
  }

  override async close(force?: boolean): Promise<void> {
    await this.#client?.close(force);