Package com.alpha.mongodb.sharding.core.client

Class CollectionShardedMongoClient

java.lang.Object

com.alpha.mongodb.sharding.core.client.CollectionShardedMongoClient

All Implemented Interfaces:

ShardedMongoClient, com.mongodb.client.MongoClient, Closeable, AutoCloseable

public class CollectionShardedMongoClient
extends Object
implements ShardedMongoClient

Collection Sharded Mongo Client that is used to access databases that are sharded by the collection.

Author:

Shashank Sharma

Constructor Summary

Constructors

Constructor	Description
CollectionShardedMongoClient(com.mongodb.client.MongoClient mongoClient, CollectionShardingOptions shardingOptions)

Method Summary

Modifier and Type	Method	Description
void	close()
com.mongodb.connection.ClusterDescription	getClusterDescription()
com.mongodb.client.MongoDatabase	getDatabase(String s)
com.mongodb.client.MongoIterable<String>	listDatabaseNames()
com.mongodb.client.MongoIterable<String>	listDatabaseNames(com.mongodb.client.ClientSession clientSession)
com.mongodb.client.ListDatabasesIterable<org.bson.Document>	listDatabases()
com.mongodb.client.ListDatabasesIterable<org.bson.Document>	listDatabases(com.mongodb.client.ClientSession clientSession)
<T> com.mongodb.client.ListDatabasesIterable<T>	listDatabases(com.mongodb.client.ClientSession clientSession, Class<T> aClass)
<T> com.mongodb.client.ListDatabasesIterable<T>	listDatabases(Class<T> aClass)
com.mongodb.client.ClientSession	startSession()
com.mongodb.client.ClientSession	startSession(com.mongodb.ClientSessionOptions clientSessionOptions)
com.mongodb.client.ChangeStreamIterable<org.bson.Document>	watch()
com.mongodb.client.ChangeStreamIterable<org.bson.Document>	watch(com.mongodb.client.ClientSession clientSession)
<T> com.mongodb.client.ChangeStreamIterable<T>	watch(com.mongodb.client.ClientSession clientSession, Class<T> aClass)
com.mongodb.client.ChangeStreamIterable<org.bson.Document>	watch(com.mongodb.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list)
<T> com.mongodb.client.ChangeStreamIterable<T>	watch(com.mongodb.client.ClientSession clientSession, List<? extends org.bson.conversions.Bson> list, Class<T> aClass)
<T> com.mongodb.client.ChangeStreamIterable<T>	watch(Class<T> aClass)
com.mongodb.client.ChangeStreamIterable<org.bson.Document>	watch(List<? extends org.bson.conversions.Bson> list)
<T> com.mongodb.client.ChangeStreamIterable<T>	watch(List<? extends org.bson.conversions.Bson> list, Class<T> aClass)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectionShardedMongoClient

public CollectionShardedMongoClient(com.mongodb.client.MongoClient mongoClient,
                                    CollectionShardingOptions shardingOptions)

Method Detail

getDatabase

public com.mongodb.client.MongoDatabase getDatabase(String s)

Specified by:

getDatabase in interface com.mongodb.client.MongoClient

startSession

public com.mongodb.client.ClientSession startSession()

Specified by:

startSession in interface com.mongodb.client.MongoClient

startSession

public com.mongodb.client.ClientSession startSession(com.mongodb.ClientSessionOptions clientSessionOptions)

Specified by:

startSession in interface com.mongodb.client.MongoClient

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface com.mongodb.client.MongoClient

listDatabaseNames

public com.mongodb.client.MongoIterable<String> listDatabaseNames()

Specified by:

listDatabaseNames in interface com.mongodb.client.MongoClient

listDatabaseNames

public com.mongodb.client.MongoIterable<String> listDatabaseNames(com.mongodb.client.ClientSession clientSession)

Specified by:

listDatabaseNames in interface com.mongodb.client.MongoClient

listDatabases

public com.mongodb.client.ListDatabasesIterable<org.bson.Document> listDatabases()

Specified by:

listDatabases in interface com.mongodb.client.MongoClient

listDatabases

public com.mongodb.client.ListDatabasesIterable<org.bson.Document> listDatabases(com.mongodb.client.ClientSession clientSession)

Specified by:

listDatabases in interface com.mongodb.client.MongoClient

listDatabases

public <T> com.mongodb.client.ListDatabasesIterable<T> listDatabases(Class<T> aClass)

Specified by:

listDatabases in interface com.mongodb.client.MongoClient

listDatabases

public <T> com.mongodb.client.ListDatabasesIterable<T> listDatabases(com.mongodb.client.ClientSession clientSession,
                                                                     Class<T> aClass)

Specified by:

listDatabases in interface com.mongodb.client.MongoClient

watch

public com.mongodb.client.ChangeStreamIterable<org.bson.Document> watch()

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public <T> com.mongodb.client.ChangeStreamIterable<T> watch(Class<T> aClass)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public com.mongodb.client.ChangeStreamIterable<org.bson.Document> watch(List<? extends org.bson.conversions.Bson> list)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public <T> com.mongodb.client.ChangeStreamIterable<T> watch(List<? extends org.bson.conversions.Bson> list,
                                                            Class<T> aClass)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public com.mongodb.client.ChangeStreamIterable<org.bson.Document> watch(com.mongodb.client.ClientSession clientSession)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public <T> com.mongodb.client.ChangeStreamIterable<T> watch(com.mongodb.client.ClientSession clientSession,
                                                            Class<T> aClass)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public com.mongodb.client.ChangeStreamIterable<org.bson.Document> watch(com.mongodb.client.ClientSession clientSession,
                                                                        List<? extends org.bson.conversions.Bson> list)

Specified by:

watch in interface com.mongodb.client.MongoClient

watch

public <T> com.mongodb.client.ChangeStreamIterable<T> watch(com.mongodb.client.ClientSession clientSession,
                                                            List<? extends org.bson.conversions.Bson> list,
                                                            Class<T> aClass)

Specified by:

watch in interface com.mongodb.client.MongoClient

getClusterDescription

public com.mongodb.connection.ClusterDescription getClusterDescription()

Specified by:

getClusterDescription in interface com.mongodb.client.MongoClient