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 com.mongodb.DB	db
protected boolean	isExternal
protected MongoJCAConnectionSpec	spec
protected MongoTransaction	transaction

Constructor Summary

Constructors

Constructor	Description
MongoConnection(com.mongodb.DB 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.DB	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

db

protected com.mongodb.DB db

isExternal

protected boolean isExternal

Constructor Details

MongoConnection

public MongoConnection(com.mongodb.DB db,
 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.DB 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)