Module org.eclipse.persistence.nosql

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

Class MongoDatabaseInteraction

java.lang.Object

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

All Implemented Interfaces:

Interaction

public class MongoDatabaseInteraction
extends Object
implements Interaction

Interaction to Mongo JCA adapter. Executes the interaction spec to enqueue or dequeue a message.

Since:

EclipseLink 2.4

Field Summary

Fields

Modifier and Type	Field	Description
protected MongoDatabaseConnection	connection	Store the connection the interaction was created from.

Constructor Summary

Constructors

Constructor	Description
MongoDatabaseInteraction(MongoDatabaseConnection connection)	Default constructor.

Method Summary

Modifier and Type	Method	Description
com.mongodb.BasicDBObject	buildDBObject(MongoRecord record)	Build the Mongo DBObject from the Map record.
org.bson.Document	buildDocument(MongoRecord record)	Build the Mongo Document from the Map record.
MongoRecord	buildRecordFromDBObject(org.bson.Document object)	Build the Map record from the Mongo Document.
void	clearWarnings()
void	close()
Record	execute(InteractionSpec spec, Record record)	Execute the interaction and return output record.
boolean	execute(InteractionSpec spec, Record input, Record output)	Output records are not supported/required.
Connection	getConnection()
ResourceWarning	getWarnings()

Methods inherited from class java.lang.Object

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

Field Details

connection

protected MongoDatabaseConnection connection

Store the connection the interaction was created from.

Constructor Details

MongoDatabaseInteraction

public MongoDatabaseInteraction(MongoDatabaseConnection connection)

Default constructor.

Method Details

clearWarnings

public void clearWarnings()

Specified by:

clearWarnings in interface Interaction

close

public void close()

Specified by:

close in interface Interaction

execute

public boolean execute(InteractionSpec spec,
 Record input,
 Record output)
                throws ResourceException

Output records are not supported/required.

Specified by:

execute in interface Interaction

Throws:

ResourceException

execute

public Record execute(InteractionSpec spec,
 Record record)
               throws ResourceException

Execute the interaction and return output record. The spec is either GET, PUT or DELETE interaction.

Specified by:

execute in interface Interaction

Throws:

ResourceException

buildDBObject

public com.mongodb.BasicDBObject buildDBObject(MongoRecord record)

Build the Mongo DBObject from the Map record.

buildDocument

public org.bson.Document buildDocument(MongoRecord record)

Build the Mongo Document from the Map record.

buildRecordFromDBObject

public MongoRecord buildRecordFromDBObject(org.bson.Document object)

Build the Map record from the Mongo Document.

getConnection

public Connection getConnection()

Specified by:

getConnection in interface Interaction

getWarnings

public ResourceWarning getWarnings()

Specified by:

getWarnings in interface Interaction