Package com.alpha.mongodb.sharding.core.database

Class CollectionShardedReactiveMongoDatabase

  • All Implemented Interfaces:
    com.mongodb.reactivestreams.client.MongoDatabase
    public class CollectionShardedReactiveMongoDatabase
extends Object
implements com.mongodb.reactivestreams.client.MongoDatabase
    CollectionShardedReactiveMongoDatabase to query for collections that are sharded within a single database.
    Author:
    Shashank Sharma

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.mongodb.reactivestreams.client.AggregatePublisher<org.bson.Document> aggregate​(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list)  
      <T> com.mongodb.reactivestreams.client.AggregatePublisher<T> aggregate​(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list, Class<T> aClass)  
      com.mongodb.reactivestreams.client.AggregatePublisher<org.bson.Document> aggregate​(List<? extends org.bson.conversions.Bson> list)  
      <T> com.mongodb.reactivestreams.client.AggregatePublisher<T> aggregate​(List<? extends org.bson.conversions.Bson> list, Class<T> aClass)  
      org.reactivestreams.Publisher<Void> createCollection​(com.mongodb.reactivestreams.client.ClientSession clientSession, String s)  
      org.reactivestreams.Publisher<Void> createCollection​(com.mongodb.reactivestreams.client.ClientSession clientSession, String s, com.mongodb.client.model.CreateCollectionOptions createCollectionOptions)  
      org.reactivestreams.Publisher<Void> createCollection​(String s)  
      org.reactivestreams.Publisher<Void> createCollection​(String s, com.mongodb.client.model.CreateCollectionOptions createCollectionOptions)  
      org.reactivestreams.Publisher<Void> createView​(com.mongodb.reactivestreams.client.ClientSession clientSession, String s, String s1, List<? extends org.bson.conversions.Bson> list)  
      org.reactivestreams.Publisher<Void> createView​(com.mongodb.reactivestreams.client.ClientSession clientSession, String s, String s1, List<? extends org.bson.conversions.Bson> list, com.mongodb.client.model.CreateViewOptions createViewOptions)  
      org.reactivestreams.Publisher<Void> createView​(String s, String s1, List<? extends org.bson.conversions.Bson> list)  
      org.reactivestreams.Publisher<Void> createView​(String s, String s1, List<? extends org.bson.conversions.Bson> list, com.mongodb.client.model.CreateViewOptions createViewOptions)  
      org.reactivestreams.Publisher<Void> drop()  
      org.reactivestreams.Publisher<Void> drop​(com.mongodb.reactivestreams.client.ClientSession clientSession)  
      org.bson.codecs.configuration.CodecRegistry getCodecRegistry()  
      com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> getCollection​(String s)  
      <T> com.mongodb.reactivestreams.client.MongoCollection<T> getCollection​(String s, Class<T> aClass)  
      String getName()  
      com.mongodb.ReadConcern getReadConcern()  
      com.mongodb.ReadPreference getReadPreference()  
      com.mongodb.WriteConcern getWriteConcern()  
      org.reactivestreams.Publisher<String> listCollectionNames()  
      org.reactivestreams.Publisher<String> listCollectionNames​(com.mongodb.reactivestreams.client.ClientSession clientSession)  
      com.mongodb.reactivestreams.client.ListCollectionsPublisher<org.bson.Document> listCollections()  
      com.mongodb.reactivestreams.client.ListCollectionsPublisher<org.bson.Document> listCollections​(com.mongodb.reactivestreams.client.ClientSession clientSession)  
      <T> com.mongodb.reactivestreams.client.ListCollectionsPublisher<T> listCollections​(com.mongodb.reactivestreams.client.ClientSession clientSession, Class<T> aClass)  
      <T> com.mongodb.reactivestreams.client.ListCollectionsPublisher<T> listCollections​(Class<T> aClass)  
      org.reactivestreams.Publisher<org.bson.Document> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession, org.bson.conversions.Bson bson)  
      org.reactivestreams.Publisher<org.bson.Document> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession, org.bson.conversions.Bson bson, com.mongodb.ReadPreference readPreference)  
      <T> org.reactivestreams.Publisher<T> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession, org.bson.conversions.Bson bson, com.mongodb.ReadPreference readPreference, Class<T> aClass)  
      <T> org.reactivestreams.Publisher<T> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession, org.bson.conversions.Bson bson, Class<T> aClass)  
      org.reactivestreams.Publisher<org.bson.Document> runCommand​(org.bson.conversions.Bson bson)  
      org.reactivestreams.Publisher<org.bson.Document> runCommand​(org.bson.conversions.Bson bson, com.mongodb.ReadPreference readPreference)  
      <T> org.reactivestreams.Publisher<T> runCommand​(org.bson.conversions.Bson bson, com.mongodb.ReadPreference readPreference, Class<T> aClass)  
      <T> org.reactivestreams.Publisher<T> runCommand​(org.bson.conversions.Bson bson, Class<T> aClass)  
      com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch()  
      com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession)  
      <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession, Class<T> aClass)  
      com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list)  
      <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list, Class<T> aClass)  
      <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(Class<T> aClass)  
      com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(List<? extends org.bson.conversions.Bson> list)  
      <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(List<? extends org.bson.conversions.Bson> list, Class<T> aClass)  
      com.mongodb.reactivestreams.client.MongoDatabase withCodecRegistry​(org.bson.codecs.configuration.CodecRegistry codecRegistry)  
      com.mongodb.reactivestreams.client.MongoDatabase withReadConcern​(com.mongodb.ReadConcern readConcern)  
      com.mongodb.reactivestreams.client.MongoDatabase withReadPreference​(com.mongodb.ReadPreference readPreference)  
      com.mongodb.reactivestreams.client.MongoDatabase withWriteConcern​(com.mongodb.WriteConcern writeConcern)  

    • Constructor Detail

      • CollectionShardedReactiveMongoDatabase

        public CollectionShardedReactiveMongoDatabase​(com.mongodb.reactivestreams.client.MongoDatabase delegatedMongoDatabase,
                                              CollectionShardingOptions shardingOptions)

    • Method Detail

      • getName

        public String getName()
        Specified by:
        getName in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getCodecRegistry

        public org.bson.codecs.configuration.CodecRegistry getCodecRegistry()
        Specified by:
        getCodecRegistry in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getReadPreference

        public com.mongodb.ReadPreference getReadPreference()
        Specified by:
        getReadPreference in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getWriteConcern

        public com.mongodb.WriteConcern getWriteConcern()
        Specified by:
        getWriteConcern in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getReadConcern

        public com.mongodb.ReadConcern getReadConcern()
        Specified by:
        getReadConcern in interface com.mongodb.reactivestreams.client.MongoDatabase

      • withCodecRegistry

        public com.mongodb.reactivestreams.client.MongoDatabase withCodecRegistry​(org.bson.codecs.configuration.CodecRegistry codecRegistry)
        Specified by:
        withCodecRegistry in interface com.mongodb.reactivestreams.client.MongoDatabase

      • withReadPreference

        public com.mongodb.reactivestreams.client.MongoDatabase withReadPreference​(com.mongodb.ReadPreference readPreference)
        Specified by:
        withReadPreference in interface com.mongodb.reactivestreams.client.MongoDatabase

      • withWriteConcern

        public com.mongodb.reactivestreams.client.MongoDatabase withWriteConcern​(com.mongodb.WriteConcern writeConcern)
        Specified by:
        withWriteConcern in interface com.mongodb.reactivestreams.client.MongoDatabase

      • withReadConcern

        public com.mongodb.reactivestreams.client.MongoDatabase withReadConcern​(com.mongodb.ReadConcern readConcern)
        Specified by:
        withReadConcern in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getCollection

        public com.mongodb.reactivestreams.client.MongoCollection<org.bson.Document> getCollection​(String s)
        Specified by:
        getCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • getCollection

        public <T> com.mongodb.reactivestreams.client.MongoCollection<T> getCollection​(String s,
                                                                               Class<T> aClass)
        Specified by:
        getCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public org.reactivestreams.Publisher<org.bson.Document> runCommand​(org.bson.conversions.Bson bson)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public org.reactivestreams.Publisher<org.bson.Document> runCommand​(org.bson.conversions.Bson bson,
                                                                   com.mongodb.ReadPreference readPreference)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public <T> org.reactivestreams.Publisher<T> runCommand​(org.bson.conversions.Bson bson,
                                                       Class<T> aClass)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public <T> org.reactivestreams.Publisher<T> runCommand​(org.bson.conversions.Bson bson,
                                                       com.mongodb.ReadPreference readPreference,
                                                       Class<T> aClass)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public org.reactivestreams.Publisher<org.bson.Document> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                   org.bson.conversions.Bson bson)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public org.reactivestreams.Publisher<org.bson.Document> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                   org.bson.conversions.Bson bson,
                                                                   com.mongodb.ReadPreference readPreference)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public <T> org.reactivestreams.Publisher<T> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                       org.bson.conversions.Bson bson,
                                                       Class<T> aClass)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • runCommand

        public <T> org.reactivestreams.Publisher<T> runCommand​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                       org.bson.conversions.Bson bson,
                                                       com.mongodb.ReadPreference readPreference,
                                                       Class<T> aClass)
        Specified by:
        runCommand in interface com.mongodb.reactivestreams.client.MongoDatabase

      • drop

        public org.reactivestreams.Publisher<Void> drop()
        Specified by:
        drop in interface com.mongodb.reactivestreams.client.MongoDatabase

      • drop

        public org.reactivestreams.Publisher<Void> drop​(com.mongodb.reactivestreams.client.ClientSession clientSession)
        Specified by:
        drop in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollectionNames

        public org.reactivestreams.Publisher<String> listCollectionNames()
        Specified by:
        listCollectionNames in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollectionNames

        public org.reactivestreams.Publisher<String> listCollectionNames​(com.mongodb.reactivestreams.client.ClientSession clientSession)
        Specified by:
        listCollectionNames in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollections

        public com.mongodb.reactivestreams.client.ListCollectionsPublisher<org.bson.Document> listCollections()
        Specified by:
        listCollections in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollections

        public <T> com.mongodb.reactivestreams.client.ListCollectionsPublisher<T> listCollections​(Class<T> aClass)
        Specified by:
        listCollections in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollections

        public com.mongodb.reactivestreams.client.ListCollectionsPublisher<org.bson.Document> listCollections​(com.mongodb.reactivestreams.client.ClientSession clientSession)
        Specified by:
        listCollections in interface com.mongodb.reactivestreams.client.MongoDatabase

      • listCollections

        public <T> com.mongodb.reactivestreams.client.ListCollectionsPublisher<T> listCollections​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                                          Class<T> aClass)
        Specified by:
        listCollections in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createCollection

        public org.reactivestreams.Publisher<Void> createCollection​(String s)
        Specified by:
        createCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createCollection

        public org.reactivestreams.Publisher<Void> createCollection​(String s,
                                                            com.mongodb.client.model.CreateCollectionOptions createCollectionOptions)
        Specified by:
        createCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createCollection

        public org.reactivestreams.Publisher<Void> createCollection​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                            String s)
        Specified by:
        createCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createCollection

        public org.reactivestreams.Publisher<Void> createCollection​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                            String s,
                                                            com.mongodb.client.model.CreateCollectionOptions createCollectionOptions)
        Specified by:
        createCollection in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createView

        public org.reactivestreams.Publisher<Void> createView​(String s,
                                                      String s1,
                                                      List<? extends org.bson.conversions.Bson> list)
        Specified by:
        createView in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createView

        public org.reactivestreams.Publisher<Void> createView​(String s,
                                                      String s1,
                                                      List<? extends org.bson.conversions.Bson> list,
                                                      com.mongodb.client.model.CreateViewOptions createViewOptions)
        Specified by:
        createView in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createView

        public org.reactivestreams.Publisher<Void> createView​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                      String s,
                                                      String s1,
                                                      List<? extends org.bson.conversions.Bson> list)
        Specified by:
        createView in interface com.mongodb.reactivestreams.client.MongoDatabase

      • createView

        public org.reactivestreams.Publisher<Void> createView​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                      String s,
                                                      String s1,
                                                      List<? extends org.bson.conversions.Bson> list,
                                                      com.mongodb.client.model.CreateViewOptions createViewOptions)
        Specified by:
        createView in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch()
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(Class<T> aClass)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(List<? extends org.bson.conversions.Bson> list)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(List<? extends org.bson.conversions.Bson> list,
                                                                             Class<T> aClass)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                             Class<T> aClass)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public com.mongodb.reactivestreams.client.ChangeStreamPublisher<org.bson.Document> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                                         List<? extends org.bson.conversions.Bson> list)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • watch

        public <T> com.mongodb.reactivestreams.client.ChangeStreamPublisher<T> watch​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                             List<? extends org.bson.conversions.Bson> list,
                                                                             Class<T> aClass)
        Specified by:
        watch in interface com.mongodb.reactivestreams.client.MongoDatabase

      • aggregate

        public com.mongodb.reactivestreams.client.AggregatePublisher<org.bson.Document> aggregate​(List<? extends org.bson.conversions.Bson> list)
        Specified by:
        aggregate in interface com.mongodb.reactivestreams.client.MongoDatabase

      • aggregate

        public <T> com.mongodb.reactivestreams.client.AggregatePublisher<T> aggregate​(List<? extends org.bson.conversions.Bson> list,
                                                                              Class<T> aClass)
        Specified by:
        aggregate in interface com.mongodb.reactivestreams.client.MongoDatabase

      • aggregate

        public com.mongodb.reactivestreams.client.AggregatePublisher<org.bson.Document> aggregate​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                                          List<? extends org.bson.conversions.Bson> list)
        Specified by:
        aggregate in interface com.mongodb.reactivestreams.client.MongoDatabase

      • aggregate

        public <T> com.mongodb.reactivestreams.client.AggregatePublisher<T> aggregate​(com.mongodb.reactivestreams.client.ClientSession clientSession,
                                                                              List<? extends org.bson.conversions.Bson> list,
                                                                              Class<T> aClass)
        Specified by:
        aggregate in interface com.mongodb.reactivestreams.client.MongoDatabase