Interface ClientSession

All Superinterfaces:
AutoCloseable, Closeable

@NotThreadSafe public interface ClientSession extends Closeable
A client session.
Since:
3.6
See Also:
Since server release
3.6
  • Method Details

    • getPinnedServerAddress

      @Nullable ServerAddress getPinnedServerAddress()
      Get the server address of the pinned mongos on this session. For internal use only.
      Returns:
      the server address of the pinned mongos
      Since:
      3.11
      Since server release
      4.2
    • getTransactionContext

      @Nullable Object getTransactionContext()
      Gets the transaction context.

      For internal use only

      Returns:
      the transaction context
    • setTransactionContext

      void setTransactionContext(ServerAddress address, Object transactionContext)
      Sets the transaction context.

      For internal use only

      Implementations may place additional restrictions on the type of the transaction context

      Parameters:
      address - the server address
      transactionContext - the transaction context
    • clearTransactionContext

      void clearTransactionContext()
      Clears the transaction context.

      For internal use only

    • getRecoveryToken

      @Nullable BsonDocument getRecoveryToken()
      Get the recovery token from the latest outcome in a sharded transaction. For internal use only.
      Returns:
      the recovery token
      Since:
      3.11
      Since server release
      4.2
    • setRecoveryToken

      void setRecoveryToken(BsonDocument recoveryToken)
      Set the recovery token. For internal use only.
      Parameters:
      recoveryToken - the recovery token
      Since:
      3.11
      Since server release
      4.2
    • getOptions

      ClientSessionOptions getOptions()
      Get the options for this session.
      Returns:
      the options, which may not be null
    • isCausallyConsistent

      boolean isCausallyConsistent()
      Returns true if operations in this session must be causally consistent
      Returns:
      whether operations in this session must be causally consistent.
    • getOriginator

      Object getOriginator()
      Gets the originator for the session.

      Important because sessions must only be used by their own originator.

      Returns:
      the sessions originator
    • getServerSession

      ServerSession getServerSession()
      Returns:
      the server session
    • getOperationTime

      BsonTimestamp getOperationTime()
      Gets the operation time of the last operation executed in this session.
      Returns:
      the operation time
    • advanceOperationTime

      void advanceOperationTime(@Nullable BsonTimestamp operationTime)
      Set the operation time of the last operation executed in this session.
      Parameters:
      operationTime - the operation time
    • advanceClusterTime

      void advanceClusterTime(@Nullable BsonDocument clusterTime)
      Parameters:
      clusterTime - the cluster time to advance to
    • setSnapshotTimestamp

      void setSnapshotTimestamp(@Nullable BsonTimestamp snapshotTimestamp)
      For internal use only.
      Parameters:
      snapshotTimestamp - the snapshot timestamp
    • getSnapshotTimestamp

      @Nullable BsonTimestamp getSnapshotTimestamp()
      For internal use only.
      Returns:
      the snapshot timestamp
    • getClusterTime

      BsonDocument getClusterTime()
      Returns:
      the latest cluster time seen by this session
    • close

      void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable