Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def aggregate[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): AggregateObservable[C]

   Aggregates documents according to the specified aggregation pipeline.

   Aggregates documents according to the specified aggregation pipeline.

   clientSession

   the client session with which to associate this operation

   pipeline

   the aggregate pipeline

   returns

   a Observable containing the result of the aggregation operation Aggregation

   Since

   2.6

   Note

   Requires MongoDB 3.6 or greater

5.  def aggregate[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): AggregateObservable[C]

   Aggregates documents according to the specified aggregation pipeline.

   Aggregates documents according to the specified aggregation pipeline.

   pipeline

   the aggregate pipeline

   returns

   a Observable containing the result of the aggregation operation Aggregation

   Since

   2.6

   Note

   Requires MongoDB 3.6 or greater

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

8.  lazy val codecRegistry: CodecRegistry

   Get the codec registry for the MongoDatabase.

   Get the codec registry for the MongoDatabase.

   returns

   the { @link org.bson.codecs.configuration.CodecRegistry}

9.  def createCollection(clientSession: ClientSession, collectionName: String, options: CreateCollectionOptions): SingleObservable[Completed]

   Create a new collection with the selected options

   Create a new collection with the selected options

   Create Command

   clientSession

   the client session with which to associate this operation

   collectionName

   the name for the new collection to create

   options

   various options for creating the collection

   returns

   a Observable identifying when the collection has been created

   Since

   2.2

   Note

   Requires MongoDB 3.6 or greater

10.  def createCollection(clientSession: ClientSession, collectionName: String): SingleObservable[Completed]

    Create a new collection with the given name.

    Create a new collection with the given name.

    Create Command

    clientSession

    the client session with which to associate this operation

    collectionName

    the name for the new collection to create

    returns

    a Observable identifying when the collection has been created

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

11.  def createCollection(collectionName: String, options: CreateCollectionOptions): SingleObservable[Completed]

    Create a new collection with the selected options

    Create a new collection with the selected options

    Create Command

    collectionName

    the name for the new collection to create

    options

    various options for creating the collection

    returns

    a Observable identifying when the collection has been created

12.  def createCollection(collectionName: String): SingleObservable[Completed]

    Create a new collection with the given name.

    Create a new collection with the given name.

    Create Command

    collectionName

    the name for the new collection to create

    returns

    a Observable identifying when the collection has been created

13.  def createView(clientSession: ClientSession, viewName: String, viewOn: String, pipeline: Seq[Bson], createViewOptions: CreateViewOptions): SingleObservable[Completed]

    Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

    Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

    Create Command

    clientSession

    the client session with which to associate this operation

    viewName

    the name of the view to create

    viewOn

    the backing collection/view for the view

    pipeline

    the pipeline that defines the view

    createViewOptions

    various options for creating the view

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

14.  def createView(clientSession: ClientSession, viewName: String, viewOn: String, pipeline: Seq[Bson]): SingleObservable[Completed]

    Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

    Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

    Create Command

    clientSession

    the client session with which to associate this operation

    viewName

    the name of the view to create

    viewOn

    the backing collection/view for the view

    pipeline

    the pipeline that defines the view

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

15.  def createView(viewName: String, viewOn: String, pipeline: Seq[Bson], createViewOptions: CreateViewOptions): SingleObservable[Completed]

    Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

    Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.

    Create Command

    viewName

    the name of the view to create

    viewOn

    the backing collection/view for the view

    pipeline

    the pipeline that defines the view

    createViewOptions

    various options for creating the view

    Since

    1.2

    Note

    Requires MongoDB 3.4 or greater

16.  def createView(viewName: String, viewOn: String, pipeline: Seq[Bson]): SingleObservable[Completed]

    Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

    Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.

    Create Command

    viewName

    the name of the view to create

    viewOn

    the backing collection/view for the view

    pipeline

    the pipeline that defines the view

    Since

    1.2

    Note

    Requires MongoDB 3.4 or greater

17.  def drop(clientSession: ClientSession): SingleObservable[Completed]

    Drops this database.

    Drops this database.

    Drop database

    clientSession

    the client session with which to associate this operation

    returns

    a Observable identifying when the database has been dropped

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

18.  def drop(): SingleObservable[Completed]

    Drops this database.

    Drops this database.

    Drop database

    returns

    a Observable identifying when the database has been dropped

19.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

21.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

22.  def getCollection[TResult](collectionName: String)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): MongoCollection[TResult]

    Gets a collection, with a specific default document class.

    Gets a collection, with a specific default document class.

    TResult

    the type of the class to use instead of Document.

    collectionName

    the name of the collection to return

    returns

    the collection

23.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

24.  def listCollectionNames(clientSession: ClientSession): Observable[String]

    Gets the names of all the collections in this database.

    Gets the names of all the collections in this database.

    clientSession

    the client session with which to associate this operation

    returns

    a Observable with all the names of all the collections in this database

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

25.  def listCollectionNames(): Observable[String]

    Gets the names of all the collections in this database.

    Gets the names of all the collections in this database.

    returns

    a Observable with all the names of all the collections in this database

26.  def listCollections[TResult](clientSession: ClientSession)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): ListCollectionsObservable[TResult]

    Finds all the collections in this database.

    Finds all the collections in this database.

    listCollections

    TResult

    the target document type of the iterable.

    clientSession

    the client session with which to associate this operation

    returns

    the fluent list collections interface

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

27.  def listCollections[TResult]()(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): ListCollectionsObservable[TResult]

    Finds all the collections in this database.

    Finds all the collections in this database.

    listCollections

    TResult

    the target document type of the iterable.

    returns

    the fluent list collections interface

28.  lazy val name: String

    Gets the name of the database.

    Gets the name of the database.

    returns

    the database name

29.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

30.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

31.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

32.  lazy val readConcern: ReadConcern

    Get the read concern for the MongoDatabase.

    Get the read concern for the MongoDatabase.

    returns

    the ReadConcern

    Since

    1.1

33.  lazy val readPreference: ReadPreference

    Get the read preference for the MongoDatabase.

    Get the read preference for the MongoDatabase.

    returns

    the { @link com.mongodb.ReadPreference}

34.  def runCommand[TResult](clientSession: ClientSession, command: Bson, readPreference: ReadPreference)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): SingleObservable[TResult]

    Executes command in the context of the current database.

    Executes command in the context of the current database.

    TResult

    the type of the class to use instead of Document.

    command

    the command to be run

    readPreference

    the ReadPreference to be used when executing the command

    returns

    a Observable containing the command result

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

35.  def runCommand[TResult](clientSession: ClientSession, command: Bson)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): SingleObservable[TResult]

    Executes command in the context of the current database using the primary server.

    Executes command in the context of the current database using the primary server.

    TResult

    the type of the class to use instead of Document.

    clientSession

    the client session with which to associate this operation

    command

    the command to be run

    returns

    a Observable containing the command result

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

36.  def runCommand[TResult](command: Bson, readPreference: ReadPreference)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): SingleObservable[TResult]

    Executes command in the context of the current database.

    Executes command in the context of the current database.

    TResult

    the type of the class to use instead of Document.

    command

    the command to be run

    readPreference

    the ReadPreference to be used when executing the command

    returns

    a Observable containing the command result

37.  def runCommand[TResult](command: Bson)(implicit e: DefaultsTo[TResult, Document], ct: ClassTag[TResult]): SingleObservable[TResult]

    Executes command in the context of the current database using the primary server.

    Executes command in the context of the current database using the primary server.

    TResult

    the type of the class to use instead of Document.

    command

    the command to be run

    returns

    a Observable containing the command result

38.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

39.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

40.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

41.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

42.  def watch[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ChangeStreamObservable[C]

    Creates a change stream for this collection.

    Creates a change stream for this collection.

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    pipeline

    the aggregation pipeline to apply to the change stream

    returns

    the change stream observable

    Since

    2.4

    Note

    Requires MongoDB 4.0 or greater

43.  def watch[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ChangeStreamObservable[C]

    Creates a change stream for this collection.

    Creates a change stream for this collection.

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    returns

    the change stream observable

    Since

    2.4

    Note

    Requires MongoDB 4.0 or greater

44.  def watch[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ChangeStreamObservable[C]

    Creates a change stream for this collection.

    Creates a change stream for this collection.

    C

    the target document type of the observable.

    pipeline

    the aggregation pipeline to apply to the change stream

    returns

    the change stream observable

    Since

    2.4

    Note

    Requires MongoDB 4.0 or greater

45.  def watch[C]()(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ChangeStreamObservable[C]

    Creates a change stream for this collection.

    Creates a change stream for this collection.

    C

    the target document type of the observable.

    returns

    the change stream observable

    Since

    2.4

    Note

    Requires MongoDB 4.0 or greater

46.  def withCodecRegistry(codecRegistry: CodecRegistry): MongoDatabase

    Create a new MongoDatabase instance with a different codec registry.

    Create a new MongoDatabase instance with a different codec registry.

    codecRegistry

    the new { @link org.bson.codecs.configuration.CodecRegistry} for the collection

    returns

    a new MongoDatabase instance with the different codec registry

47.  def withReadConcern(readConcern: ReadConcern): MongoDatabase

    Create a new MongoDatabase instance with a different read concern.

    Create a new MongoDatabase instance with a different read concern.

    readConcern

    the new ReadConcern for the collection

    returns

    a new MongoDatabase instance with the different ReadConcern

    Since

    1.1

48.  def withReadPreference(readPreference: ReadPreference): MongoDatabase

    Create a new MongoDatabase instance with a different read preference.

    Create a new MongoDatabase instance with a different read preference.

    readPreference

    the new { @link com.mongodb.ReadPreference} for the collection

    returns

    a new MongoDatabase instance with the different readPreference

49.  def withWriteConcern(writeConcern: WriteConcern): MongoDatabase

    Create a new MongoDatabase instance with a different write concern.

    Create a new MongoDatabase instance with a different write concern.

    writeConcern

    the new { @link com.mongodb.WriteConcern} for the collection

    returns

    a new MongoDatabase instance with the different writeConcern

50.  lazy val writeConcern: WriteConcern

    Get the write concern for the MongoDatabase.

    Get the write concern for the MongoDatabase.

    returns

    the { @link com.mongodb.WriteConcern}