net.ymate.platform.persistence.mongodb.transaction.impl

Class DefaultTransaction

java.lang.Object

net.ymate.platform.persistence.mongodb.transaction.impl.DefaultTransaction

All Implemented Interfaces:

ITransaction

public class DefaultTransaction
extends Object
implements ITransaction

Since:

2.1.0

Author:

刘镇 (suninformation@163.com) on 2021/10/17 12:07 上午

Constructor Summary

Constructors

Constructor and Description
DefaultTransaction(IMongoConnectionHolder connectionHolder, ClientSessionOptions clientSessionOptions)

Method Summary

Modifier and Type	Method and Description
void	close() 关闭事务（连接）
void	commit() 提交事务
ClientSession	getClientSession(String dsName) 获取客户端会话对象
IMongoConnectionHolder	getConnectionHolder(String dsName) 获取数据库连接持有者对象
String	getId() 获取事务唯一标识
void	rollback() 回滚事务

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTransaction

public DefaultTransaction(IMongoConnectionHolder connectionHolder,
                          ClientSessionOptions clientSessionOptions)
                   throws Exception

Throws:

Exception

Method Detail

getId

public String getId()

Description copied from interface: ITransaction

获取事务唯一标识

Specified by:

getId in interface ITransaction

Returns:

返回事务唯一标识

commit

public void commit()

Description copied from interface: ITransaction

提交事务

Specified by:

commit in interface ITransaction

rollback

public void rollback()

Description copied from interface: ITransaction

回滚事务

Specified by:

rollback in interface ITransaction

close

public void close()

Description copied from interface: ITransaction

关闭事务（连接）

Specified by:

close in interface ITransaction

getClientSession

public ClientSession getClientSession(String dsName)

Description copied from interface: ITransaction

获取客户端会话对象

Specified by:

getClientSession in interface ITransaction

Parameters:

dsName - 数据源名称

Returns:

返回客户端会话对象

getConnectionHolder

public IMongoConnectionHolder getConnectionHolder(String dsName)

Description copied from interface: ITransaction

获取数据库连接持有者对象

Specified by:

getConnectionHolder in interface ITransaction

Parameters:

dsName - 数据源名称

Returns:

返回数据库连接持有者对象