Skip to main content
Version: 6.3

MongoConnection

Hierarchy

Index

Constructors

constructor

Methods

aggregate

  • aggregate<T>(collection, pipeline, ctx, loggerContext): Promise<T[]>
  • Type parameters

    • T: object = any

    Parameters

    • collection: string
    • pipeline: any[]
    • optionalctx: ClientSession
    • optionalloggerContext: LoggingOptions

    Returns Promise<T[]>

begin

  • begin(options): Promise<ClientSession>
  • Parameters

    Returns Promise<ClientSession>

bulkUpdateMany

  • bulkUpdateMany<T>(collection, where, data, ctx, upsert, upsertOptions): Promise<QueryResult<T>>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • where: FilterQuery<T>[]
    • data: Partial<T>[]
    • optionalctx: ClientSession
    • optionalupsert: boolean
    • optionalupsertOptions: UpsertManyOptions<T>

    Returns Promise<QueryResult<T>>

checkConnection

  • checkConnection(): Promise<{ error?: Error; ok: boolean; reason?: string }>
  • Are we connected to the database


    Returns Promise<{ error?: Error; ok: boolean; reason?: string }>

close

  • close(force): Promise<void>
  • Closes the database connection (aka disconnect)


    Parameters

    • optionalforce: boolean

    Returns Promise<void>

commit

  • commit(ctx, eventBroadcaster): Promise<void>

connect

  • connect(): Promise<void>
  • Establishes connection to database


    Returns Promise<void>

countDocuments

  • countDocuments<T>(collection, where, ctx): Promise<number>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • where: FilterQuery<T>
    • optionalctx: ClientSession

    Returns Promise<number>

createCollection

  • createCollection<T>(name): Promise<Collection<T>>
  • Type parameters

    • T: object

    Parameters

    Returns Promise<Collection<T>>

deleteMany

  • deleteMany<T>(collection, where, ctx): Promise<QueryResult<T>>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • where: FilterQuery<T>
    • optionalctx: ClientSession

    Returns Promise<QueryResult<T>>

dropCollection

  • dropCollection(name): Promise<boolean>
  • Parameters

    Returns Promise<boolean>

ensureConnection

  • ensureConnection(): Promise<void>
  • Ensure the connection exists, this is used to support lazy connect when using MikroORM.initSync()


    Returns Promise<void>

execute

  • execute(query): Promise<any>
  • Parameters

    • query: string

    Returns Promise<any>

find

  • find<T>(collection, where, orderBy, limit, offset, fields, ctx, loggerContext): Promise<EntityData<T>[]>

getClient

  • getClient(): MongoClient
  • Returns MongoClient

getClientUrl

  • getClientUrl(): string
  • Returns string

getCollection

  • getCollection<T>(name): Collection<T>
  • Type parameters

    • T: object

    Parameters

    Returns Collection<T>

getConnectionOptions

  • Returns MongoClientOptions & ConnectionConfig

getDb

  • getDb(): Db
  • Returns Db

getDefaultClientUrl

  • getDefaultClientUrl(): string
  • Returns default client url for given driver (e.g. mongodb://127.0.0.1:27017 for mongodb)


    Returns string

getPlatform

  • Returns Platform

insertMany

  • insertMany<T>(collection, data, ctx): Promise<QueryResult<T>>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • data: Partial<T>[]
    • optionalctx: ClientSession

    Returns Promise<QueryResult<T>>

insertOne

  • insertOne<T>(collection, data, ctx): Promise<QueryResult<T>>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • data: Partial<T>
    • optionalctx: ClientSession

    Returns Promise<QueryResult<T>>

isConnected

  • isConnected(): Promise<boolean>
  • Are we connected to the database


    Returns Promise<boolean>

listCollections

  • listCollections(): Promise<string[]>
  • Returns Promise<string[]>

rollback

  • rollback(ctx, eventBroadcaster): Promise<void>

setMetadata

  • setMetadata(metadata): void
  • Parameters

    Returns void

setPlatform

  • setPlatform(platform): void
  • Parameters

    Returns void

transactional

  • transactional<T>(cb, options): Promise<T>
  • Type parameters

    • T

    Parameters

    Returns Promise<T>

updateMany

  • updateMany<T>(collection, where, data, ctx, upsert, upsertOptions): Promise<QueryResult<T>>
  • Type parameters

    • T: object

    Parameters

    • collection: string
    • where: FilterQuery<T>
    • data: Partial<T>
    • optionalctx: ClientSession
    • optionalupsert: boolean
    • optionalupsertOptions: UpsertOptions<T>

    Returns Promise<QueryResult<T>>