Module org.eclipse.persistence.nosql

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

Class MongoDatabaseConnection

java.lang.Object

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

All Implemented Interfaces:

Connection

public class MongoDatabaseConnection
extends Object
implements Connection

Connection to Mongo This connection wraps a Mongo DB.

Since:

EclipseLink 2.7

Field Summary

Fields

Modifier and Type	Field	Description
protected com.mongodb.client.MongoDatabase	db
protected boolean	isExternal
protected MongoJCAConnectionSpec	spec
protected MongoTransaction	transaction

Constructor Summary

Constructors

Constructor	Description
MongoDatabaseConnection(com.mongodb.MongoClient mongo, com.mongodb.client.MongoDatabase db, boolean isExternal, MongoJCAConnectionSpec spec)	Create the connection on a native AQ session.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the AQ native session and the database connection.
Interaction	createInteraction()
MongoJCAConnectionSpec	getConnectionSpec()
com.mongodb.client.MongoDatabase	getDB()
LocalTransaction	getLocalTransaction()
ConnectionMetaData	getMetaData()
com.mongodb.MongoClient	getMongo()
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

db

protected com.mongodb.client.MongoDatabase db

isExternal

protected boolean isExternal

Constructor Details

MongoDatabaseConnection

public MongoDatabaseConnection(com.mongodb.MongoClient mongo,
 com.mongodb.client.MongoDatabase db,
 boolean isExternal,
 MongoJCAConnectionSpec spec)

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

Method Details

getMongo

public com.mongodb.MongoClient getMongo()

getDB

public com.mongodb.client.MongoDatabase getDB()

close

public void close()
           throws ResourceException

Close the AQ native session and the database connection.

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)