Module org.eclipse.persistence.nosql

Package org.eclipse.persistence.internal.nosql.adapters.mongo

Class MongoConnection

java.lang.Object

org.eclipse.persistence.internal.nosql.adapters.mongo.MongoConnection

All Implemented Interfaces:

Connection

public class MongoConnection
extends Object
implements Connection

Connection to Mongo This connection wraps a Mongo DB.

Since:

EclipseLink 2.4

Field Summary

Fields

Modifier and Type	Field	Description
protected String	databaseName
protected boolean	isExternal
protected com.mongodb.client.MongoClient	mongo
protected MongoJCAConnectionSpec	spec
protected MongoTransaction	transaction

Constructor Summary

Constructors

Constructor	Description
MongoConnection(com.mongodb.client.MongoClient mongo, String databaseName, boolean isExternal, MongoJCAConnectionSpec spec)	Create the connection on a native AQ session.

Method Summary

Modifier and Type	Method	Description
void	close()	Close MongoDB client with all underlying cached resources.
Interaction	createInteraction()
com.mongodb.client.MongoClient	getClient()
MongoJCAConnectionSpec	getConnectionSpec()
String	getDatabaseName()
com.mongodb.client.MongoDatabase	getDB()
LocalTransaction	getLocalTransaction()
ConnectionMetaData	getMetaData()
MongoTransaction	getMongoTransaction()
ResultSetInfo	getResultSetInfo()	Result sets are not supported.
boolean	isExternal()
void	setExternal(boolean isExternal)

Methods inherited from class java.lang.Object

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

Field Details

spec

protected MongoJCAConnectionSpec spec

transaction

protected MongoTransaction transaction

mongo

protected com.mongodb.client.MongoClient mongo

databaseName

protected String databaseName

isExternal

protected boolean isExternal

Constructor Details

MongoConnection

public MongoConnection(com.mongodb.client.MongoClient mongo,
 String databaseName,
 boolean isExternal,
 MongoJCAConnectionSpec spec)

Create the connection on a native AQ session. The session must be connected to a JDBC connection.

Method Details

getDB

public com.mongodb.client.MongoDatabase getDB()

getClient

public com.mongodb.client.MongoClient getClient()

getDatabaseName

public String getDatabaseName()

close

public void close()
           throws ResourceException

Close MongoDB client with all underlying cached resources.

Specified by:

close in interface Connection

Throws:

ResourceException

createInteraction

public Interaction createInteraction()

Specified by:

createInteraction in interface Connection

getConnectionSpec

public MongoJCAConnectionSpec getConnectionSpec()

getLocalTransaction

public LocalTransaction getLocalTransaction()

Specified by:

getLocalTransaction in interface Connection

getMongoTransaction

public MongoTransaction getMongoTransaction()

getMetaData

public ConnectionMetaData getMetaData()

Specified by:

getMetaData in interface Connection

getResultSetInfo

public ResultSetInfo getResultSetInfo()

Result sets are not supported.

Specified by:

getResultSetInfo in interface Connection

isExternal

public boolean isExternal()

setExternal

public void setExternal(boolean isExternal)