com.hazelcast.jet.mongodb.dataconnection

Class MongoDataConnection

java.lang.Object

com.hazelcast.dataconnection.DataConnectionBase

com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection

All Implemented Interfaces:

DataConnection

@Beta
public class MongoDataConnection
extends DataConnectionBase

Creates a MongoDB DataConnection.

According to MongoClient documentation, the client object is responsible for maintaining connection pool, so this data connection just returns one, cached client.

Since:

5.3

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTION_STRING_PROPERTY Name of a property which holds connection string to the mongodb instance.
static String	DATABASE_PROPERTY Name of a property with a database name hint.

Constructor Summary

Constructors

Constructor and Description
MongoDataConnection(DataConnectionConfig config) Creates a new data connection based on given config.

Method Summary

Modifier and Type	Method and Description
void	destroy() Closes underlying client.
com.mongodb.client.MongoClient	getClient() Returns an instance of MongoClient.
String	getDatabaseName() Returns the database name hint.
List<DataConnectionResource>	listResources() Lists all MongoDB collections in all databases.
static DataConnectionConfig	mongoDataConnectionConf(String name, String connectionString) Helper method to create new MongoDataConnection with given name and connection string.

Methods inherited from class com.hazelcast.dataconnection.DataConnectionBase

getConfig, getName, release, retain

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.dataconnection.DataConnection

options

Field Detail

CONNECTION_STRING_PROPERTY

public static final String CONNECTION_STRING_PROPERTY

Name of a property which holds connection string to the mongodb instance.

See Also:

Constant Field Values

DATABASE_PROPERTY

public static final String DATABASE_PROPERTY

Name of a property with a database name hint. This is used as a hint only; listResources() will return only collection from db with this name, but client is not restricted to this database. It can be used to specify database to which SQL Mappings will point.

See Also:

Constant Field Values

Constructor Detail

MongoDataConnection

public MongoDataConnection(DataConnectionConfig config)

Creates a new data connection based on given config.

Method Detail

getClient

@Nonnull
public com.mongodb.client.MongoClient getClient()

Returns an instance of MongoClient. If client is DataConnectionConfig.isShared() and there will be still some usages of given client, the MongoClient.close() method won't take an effect.

getDatabaseName

public String getDatabaseName()

Returns the database name hint.

listResources

@Nonnull
public List<DataConnectionResource> listResources()

Lists all MongoDB collections in all databases.

destroy

public void destroy()

Closes underlying client.

mongoDataConnectionConf

@Nonnull
public static DataConnectionConfig mongoDataConnectionConf(String name,
                                                                    String connectionString)

Helper method to create new MongoDataConnection with given name and connection string.