Package dev.morphia.transactions

Class MorphiaSessionImpl

java.lang.Object

dev.morphia.DatastoreImpl

dev.morphia.transactions.MorphiaSessionImpl

All Implemented Interfaces:

ClientSession, ClientSession, AdvancedDatastore, Datastore, MorphiaSession, Closeable, AutoCloseable

@MorphiaInternal
public class MorphiaSessionImpl
extends DatastoreImpl
implements MorphiaSession

Since:

2.0

Developer note.

This is an internal item. Its function and presence are subject to change without warning. Its use is highly discouraged.

Nested Class Summary

Nested classes/interfaces inherited from class dev.morphia.DatastoreImpl

DatastoreImpl.DatastoreOperations

Constructor Summary

Constructors

Constructor	Description
MorphiaSessionImpl(DatastoreImpl datastore, ClientSession session)	Creates a new session.

Method Summary

Modifier and Type	Method	Description
void	abortTransaction()
void	advanceClusterTime(BsonDocument clusterTime)
void	advanceOperationTime(BsonTimestamp operationTime)
void	clearTransactionContext()
void	close()
void	commitTransaction()
BsonDocument	getClusterTime()
BsonTimestamp	getOperationTime()
ClientSessionOptions	getOptions()
Object	getOriginator()
ServerAddress	getPinnedServerAddress()
BsonDocument	getRecoveryToken()
ServerSession	getServerSession()
ClientSession	getSession()
BsonTimestamp	getSnapshotTimestamp()
Object	getTransactionContext()
TransactionOptions	getTransactionOptions()
boolean	hasActiveTransaction()
boolean	isCausallyConsistent()
boolean	notifyMessageSent()
void	notifyOperationInitiated(Object operation)
void	setRecoveryToken(BsonDocument recoveryToken)
void	setSnapshotTimestamp(BsonTimestamp bsonTimestamp)
void	setTransactionContext(ServerAddress serverAddress, Object o)
void	startTransaction()
void	startTransaction(TransactionOptions transactionOptions)
<T> T	withTransaction(TransactionBody<T> transactionBody)
<T> T	withTransaction(TransactionBody<T> transactionBody, TransactionOptions options)

Methods inherited from class dev.morphia.DatastoreImpl

aggregate, aggregate, configureCollection, createAggregation, createAggregation, createQuery, createUpdateOperations, delete, delete, doTransaction, enableDocumentValidation, enableValidation, ensureCaps, ensureIndexes, ensureIndexes, find, find, find, find, getCodecRegistry, getCollection, getDatabase, getLoggedQuery, getMapper, getMongoClient, insert, insert, merge, merge, operations, operations, queryByExample, queryByExample, refresh, replace, replace, save, save, shardCollection, shardCollections, startSession, startSession, withTransaction, withTransaction

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.morphia.AdvancedDatastore

createAggregation, createQuery, createRef, createRef, createUpdateOperations, insert, insert, queryByExample

Methods inherited from interface dev.morphia.Datastore

aggregate, aggregate, createAggregation, createQuery, createUpdateOperations, delete, delete, delete, delete, enableDocumentValidation, ensureCaps, ensureIndexes, find, find, find, find, findAndDelete, findAndDelete, findAndModify, findAndModify, getCodecRegistry, getCollection, getDatabase, getLoggedQuery, getMapper, insert, insert, insert, insert, merge, merge, merge, queryByExample, refresh, replace, replace, replace, replace, save, save, save, save, save, save, save, shardCollections, startSession, startSession, update, update, withTransaction, withTransaction

Constructor Detail

MorphiaSessionImpl

public MorphiaSessionImpl(DatastoreImpl datastore,
                          ClientSession session)

Creates a new session.

Parameters:

datastore - the datastore

session - the client session

Method Detail

getPinnedServerAddress

@Nullable
public ServerAddress getPinnedServerAddress()

Specified by:

getPinnedServerAddress in interface ClientSession

Specified by:

getPinnedServerAddress in interface ClientSession

hasActiveTransaction

public boolean hasActiveTransaction()

Specified by:

hasActiveTransaction in interface ClientSession

notifyMessageSent

public boolean notifyMessageSent()

Specified by:

notifyMessageSent in interface ClientSession

notifyOperationInitiated

public void notifyOperationInitiated(Object operation)

Specified by:

notifyOperationInitiated in interface ClientSession

getTransactionOptions

public TransactionOptions getTransactionOptions()

Specified by:

getTransactionOptions in interface ClientSession

startTransaction

public void startTransaction()

Specified by:

startTransaction in interface ClientSession

startTransaction

public void startTransaction(TransactionOptions transactionOptions)

Specified by:

startTransaction in interface ClientSession

commitTransaction

public void commitTransaction()

Specified by:

commitTransaction in interface ClientSession

abortTransaction

public void abortTransaction()

Specified by:

abortTransaction in interface ClientSession

withTransaction

public <T> T withTransaction(TransactionBody<T> transactionBody)

Specified by:

withTransaction in interface ClientSession

getSnapshotTimestamp

public BsonTimestamp getSnapshotTimestamp()

Specified by:

getSnapshotTimestamp in interface ClientSession

withTransaction

public <T> T withTransaction(TransactionBody<T> transactionBody,
                             TransactionOptions options)

Specified by:

withTransaction in interface ClientSession

getSession

@NonNull
public ClientSession getSession()

Returns:

the session

getTransactionContext

public Object getTransactionContext()

Specified by:

getTransactionContext in interface ClientSession

setTransactionContext

public void setTransactionContext(ServerAddress serverAddress,
                                  Object o)

Specified by:

setTransactionContext in interface ClientSession

clearTransactionContext

public void clearTransactionContext()

Specified by:

clearTransactionContext in interface ClientSession

getRecoveryToken

@Nullable
public BsonDocument getRecoveryToken()

Specified by:

getRecoveryToken in interface ClientSession

setRecoveryToken

public void setRecoveryToken(BsonDocument recoveryToken)

Specified by:

setRecoveryToken in interface ClientSession

getOptions

public ClientSessionOptions getOptions()

Specified by:

getOptions in interface ClientSession

isCausallyConsistent

public boolean isCausallyConsistent()

Specified by:

isCausallyConsistent in interface ClientSession

getOriginator

public Object getOriginator()

Specified by:

getOriginator in interface ClientSession

getServerSession

public ServerSession getServerSession()

Specified by:

getServerSession in interface ClientSession

getOperationTime

public BsonTimestamp getOperationTime()

Specified by:

getOperationTime in interface ClientSession

advanceOperationTime

public void advanceOperationTime(BsonTimestamp operationTime)

Specified by:

advanceOperationTime in interface ClientSession

advanceClusterTime

public void advanceClusterTime(BsonDocument clusterTime)

Specified by:

advanceClusterTime in interface ClientSession

setSnapshotTimestamp

public void setSnapshotTimestamp(BsonTimestamp bsonTimestamp)

Specified by:

setSnapshotTimestamp in interface ClientSession

getClusterTime

public BsonDocument getClusterTime()

Specified by:

getClusterTime in interface ClientSession

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ClientSession

Specified by:

close in interface Closeable