MongoConnection

Hierarchy

• Connection
  • MongoConnection

Index

Constructors

• constructor

Methods

• aggregate
• begin
• bulkUpdateMany
• checkConnection
• close
• commit
• connect
• countDocuments
• createCollection
• deleteMany
• dropCollection
• ensureConnection
• execute
• find
• getClient
• getClientUrl
• getCollection
• getConnectionOptions
• getDb
• getDefaultClientUrl
• getPlatform
• insertMany
• insertOne
• isConnected
• listCollections
• rollback
• setMetadata
• setPlatform
• transactional
• updateMany

Constructors

constructor

• new MongoConnection(config: Configuration<IDatabaseDriver<Connection>, EntityManager<IDatabaseDriver<Connection>>>, options?: ConnectionOptions, type?: ConnectionType): MongoConnection

• Overrides Connection.constructor

  Parameters

  • config: Configuration<IDatabaseDriver<Connection>, EntityManager<IDatabaseDriver<Connection>>>

  • optionaloptions: ConnectionOptions

  • type: ConnectionType = 'write'

  Returns MongoConnection

Methods

aggregate

• aggregate(collection: string, pipeline: any[], ctx?: ClientSession, loggerContext?: LoggingOptions): Promise<T[]>

• Parameters

  • collection: string

  • pipeline: any[]

  • optionalctx: ClientSession

  • optionalloggerContext: LoggingOptions

  Returns Promise<T[]>

begin

• begin(options?: { ctx?: ClientSession; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel } & TransactionOptions): Promise<ClientSession>

• Overrides Connection.begin

  Parameters

  • options: { ctx?: ClientSession; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel } & TransactionOptions = {}

  Returns Promise<ClientSession>

bulkUpdateMany

• bulkUpdateMany(collection: string, where: FilterQuery<T>[], data: Partial<T>[], ctx?: ClientSession, upsert?: boolean, upsertOptions?: UpsertManyOptions<T, never>): Promise<QueryResult<T>>

• Parameters

  • collection: string

  • where: FilterQuery<T>[]

  • data: Partial<T>[]

  • optionalctx: ClientSession

  • optionalupsert: boolean

  • optionalupsertOptions: UpsertManyOptions<T, never>

  Returns Promise<QueryResult<T>>

checkConnection

• checkConnection(): Promise<{ ok: true } | { error?: Error; ok: false; reason: string }>

• Overrides Connection.checkConnection

  Are we connected to the database

  ---

  Returns Promise<{ ok: true } | { error?: Error; ok: false; reason: string }>

close

• close(force?: boolean): Promise<void>

• Overrides Connection.close

  Closes the database connection (aka disconnect)

  ---

  Parameters

  • optionalforce: boolean

  Returns Promise<void>

commit

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

• Overrides Connection.commit

  Parameters

  • ctx: ClientSession

  • optionaleventBroadcaster: TransactionEventBroadcaster

  Returns Promise<void>

connect

• connect(): Promise<void>

• Overrides Connection.connect

  Establishes connection to database

  ---

  Returns Promise<void>

countDocuments

• countDocuments(collection: string, where: FilterQuery<T>, ctx?: ClientSession): Promise<number>

• Parameters

  • collection: string

  • where: FilterQuery<T>

  • optionalctx: ClientSession

  Returns Promise<number>

createCollection

• createCollection(name: EntityName<T>): Promise<Collection<T>>

• Parameters

  • name: EntityName<T>

  Returns Promise<Collection<T>>

deleteMany

• deleteMany(collection: string, where: FilterQuery<T>, ctx?: ClientSession): Promise<QueryResult<T>>

• Parameters

  • collection: string

  • where: FilterQuery<T>

  • optionalctx: ClientSession

  Returns Promise<QueryResult<T>>

dropCollection

• dropCollection(name: EntityName<Partial<any>>): Promise<boolean>

• Parameters

  • name: EntityName<Partial<any>>

  Returns Promise<boolean>

inheritedensureConnection

• ensureConnection(): Promise<void>

• Inherited from Connection.ensureConnection

  Ensure the connection exists, this is used to support lazy connect when using MikroORM.initSync()

  ---

  Returns Promise<void>

execute

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

• Overrides Connection.execute

  Parameters

  • query: string

  Returns Promise<any>

find

• find(collection: string, where: FilterQuery<T>, orderBy?: QueryOrderMap<T> | QueryOrderMap<T>[], limit?: number, offset?: number, fields?: string[], ctx?: ClientSession, loggerContext?: LoggingOptions): Promise<EntityData<T>[]>

• Parameters

  • collection: string

  • where: FilterQuery<T>

  • optionalorderBy: QueryOrderMap<T> | QueryOrderMap<T>[]

  • optionallimit: number

  • optionaloffset: number

  • optionalfields: string[]

  • optionalctx: ClientSession

  • optionalloggerContext: LoggingOptions

  Returns Promise<EntityData<T>[]>

getClient

• getClient(): MongoClient

• Returns MongoClient

getClientUrl

• getClientUrl(): string

• Overrides Connection.getClientUrl

  Returns string

getCollection

• getCollection(name: EntityName<T>): Collection<T>

• Parameters

  • name: EntityName<T>

  Returns Collection<T>

getConnectionOptions

• getConnectionOptions(): MongoClientOptions & ConnectionConfig

• Overrides Connection.getConnectionOptions

  Returns MongoClientOptions & ConnectionConfig

getDb

• getDb(): Db

• Returns Db

getDefaultClientUrl

• getDefaultClientUrl(): string

• Overrides Connection.getDefaultClientUrl

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

  ---

  Returns string

inheritedgetPlatform

• getPlatform(): Platform

• Inherited from Connection.getPlatform

  Returns Platform

insertMany

• insertMany(collection: string, data: Partial<T>[], ctx?: ClientSession): Promise<QueryResult<T>>

• Parameters

  • collection: string

  • data: Partial<T>[]

  • optionalctx: ClientSession

  Returns Promise<QueryResult<T>>

insertOne

• insertOne(collection: string, data: Partial<T>, ctx?: ClientSession): Promise<QueryResult<T>>

• Parameters

  • collection: string

  • data: Partial<T>

  • optionalctx: ClientSession

  Returns Promise<QueryResult<T>>

isConnected

• isConnected(): Promise<boolean>

• Overrides Connection.isConnected

  Are we connected to the database

  ---

  Returns Promise<boolean>

listCollections

• listCollections(): Promise<string[]>

• Returns Promise<string[]>

rollback

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

• Overrides Connection.rollback

  Parameters

  • ctx: ClientSession

  • optionaleventBroadcaster: TransactionEventBroadcaster

  Returns Promise<void>

inheritedsetMetadata

• setMetadata(metadata: MetadataStorage): void

• Inherited from Connection.setMetadata

  Parameters

  • metadata: MetadataStorage

  Returns void

inheritedsetPlatform

• setPlatform(platform: Platform): void

• Inherited from Connection.setPlatform

  Parameters

  • platform: Platform

  Returns void

transactional

• transactional(cb: (trx: ClientSession) => Promise<T>, options?: { ctx?: ClientSession; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel } & TransactionOptions): Promise<T>

• Overrides Connection.transactional

  Parameters

  • cb: (trx: ClientSession) => Promise<T>

  • options: { ctx?: ClientSession; eventBroadcaster?: TransactionEventBroadcaster; isolationLevel?: IsolationLevel } & TransactionOptions = {}

  Returns Promise<T>

updateMany

• updateMany(collection: string, where: FilterQuery<T>, data: Partial<T>, ctx?: ClientSession, upsert?: boolean, upsertOptions?: UpsertOptions<T, never>): Promise<QueryResult<T>>

• Parameters

  • collection: string

  • where: FilterQuery<T>

  • data: Partial<T>

  • optionalctx: ClientSession

  • optionalupsert: boolean

  • optionalupsertOptions: UpsertOptions<T, never>

  Returns Promise<QueryResult<T>>