net.ymate.platform.persistence.mongodb

Class MongoDB

java.lang.Object

net.ymate.platform.persistence.mongodb.MongoDB

All Implemented Interfaces:

AutoCloseable, IModule, IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>, IDestroyable, IInitialization<IApplication>, IMongo

public class MongoDB
extends Object
implements IModule, IMongo

Author:

刘镇 (suninformation@163.com) on 15/11/21 上午9:24

Nested Class Summary

Nested classes/interfaces inherited from interface net.ymate.platform.persistence.mongodb.IMongo

IMongo.GridFs, IMongo.Opt

Field Summary

Fields inherited from interface net.ymate.platform.persistence.mongodb.IMongo

MODULE_NAME

Constructor Summary

Constructors

Constructor and Description
MongoDB()
MongoDB(IMongoConfig config)

Method Summary

Modifier and Type	Method and Description
void	close()
static IMongo	get()
IMongoConfig	getConfig() 获取持久化配置对象
IMongoConnectionHolder	getConnectionHolder(String dataSourceName) 获取由dataSourceName指定的数据源连接持有者对象
IMongoDataSourceAdapter	getDataSourceAdapter(String dataSourceName) 获取指定源数据源适配器
IMongoConnectionHolder	getDefaultConnectionHolder() 获取默认数据源连接持有者对象
IMongoDataSourceAdapter	getDefaultDataSourceAdapter() 获取默认数据源适配器
String	getName() 获取模块名称
IApplication	getOwner() 获取所属应用容器
void	initialize(IApplication owner) 初始化
boolean	isInitialized() 是否已初始化
IGridFsSession	openGridFsSession() 开启数据库文件储存会话(注意一定记得关闭会话)
IGridFsSession	openGridFsSession(IDataSourceRouter dataSourceRouter) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(IDataSourceRouter dataSourceRouter, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IGridFsSession	openGridFsSession(IDataSourceRouter dataSourceRouter, String bucketName) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(IDataSourceRouter dataSourceRouter, String bucketName, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openGridFsSession(IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IGridFsSession	openGridFsSession(IMongoConnectionHolder connectionHolder) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(IMongoConnectionHolder connectionHolder, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IGridFsSession	openGridFsSession(IMongoConnectionHolder connectionHolder, String bucketName) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(IMongoConnectionHolder connectionHolder, String bucketName, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IGridFsSession	openGridFsSession(String bucketName) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(String bucketName, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IGridFsSession	openGridFsSession(String dataSourceName, String bucketName) 开启数据库文件储存会话(注意一定记得关闭会话)
<T> T	openGridFsSession(String dataSourceName, String bucketName, IGridFsSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IMongoSession	openSession() 开启数据库连接会话(注意一定记得关闭会话)
IMongoSession	openSession(IDataSourceRouter dataSourceRouter) 开启数据库连接会话(注意一定记得关闭会话)
<T> T	openSession(IDataSourceRouter dataSourceRouter, IMongoSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IMongoSession	openSession(IMongoConnectionHolder connectionHolder) 开启数据库连接会话(注意一定记得关闭会话)
<T> T	openSession(IMongoConnectionHolder connectionHolder, IMongoSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openSession(IMongoSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
IMongoSession	openSession(String dataSourceName) 开启数据库连接会话(注意一定记得关闭会话)
<T> T	openSession(String dataSourceName, IMongoSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openTransaction(AbstractTrade<T> trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(AbstractTrade<T> trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(IDataSourceRouter dataSourceRouter, AbstractTrade<T> trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(IDataSourceRouter dataSourceRouter, AbstractTrade<T> trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(IDataSourceRouter dataSourceRouter, ITrade trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(IDataSourceRouter dataSourceRouter, ITrade trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(IMongoConnectionHolder connectionHolder, AbstractTrade<T> trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(IMongoConnectionHolder connectionHolder, AbstractTrade<T> trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(IMongoConnectionHolder connectionHolder, ITrade trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(IMongoConnectionHolder connectionHolder, ITrade trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(ITrade trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(ITrade trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(String dataSourceName, AbstractTrade<T> trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
<T> T	openTransaction(String dataSourceName, AbstractTrade<T> trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(String dataSourceName, ITrade trade) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	openTransaction(String dataSourceName, ITrade trade, ClientSessionOptions clientSessionOptions) 开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)
void	releaseConnectionHolder(IMongoConnectionHolder connectionHolder) 安全关闭数据源的连接持有者(确保非事务状态下执行关闭)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDB

public MongoDB()

MongoDB

public MongoDB(IMongoConfig config)

Method Detail

get

public static IMongo get()

getName

public String getName()

Description copied from interface: IModule

获取模块名称

Specified by:

getName in interface IModule

Returns:

返回模块名称

initialize

public void initialize(IApplication owner)
                throws Exception

Description copied from interface: IInitialization

初始化

Specified by:

initialize in interface IInitialization<IApplication>

Parameters:

owner - 指定所属容器参数对象

Throws:

Exception - 初始过程中产生的任何异常

isInitialized

public boolean isInitialized()

Description copied from interface: IInitialization

是否已初始化

Specified by:

isInitialized in interface IInitialization<IApplication>

Returns:

返回true表示已初始化

getOwner

public IApplication getOwner()

Description copied from interface: IPersistence

获取所属应用容器

Specified by:

getOwner in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Returns:

返回所属应用容器实例

getConfig

public IMongoConfig getConfig()

Description copied from interface: IPersistence

获取持久化配置对象

Specified by:

getConfig in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Returns:

返回持久化配置对象

getDefaultConnectionHolder

public IMongoConnectionHolder getDefaultConnectionHolder()
                                                  throws Exception

Description copied from interface: IPersistence

获取默认数据源连接持有者对象

Specified by:

getDefaultConnectionHolder in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Returns:

返回默认数据源连接持有者对象

Throws:

Exception - 可能产生的异常

getConnectionHolder

public IMongoConnectionHolder getConnectionHolder(String dataSourceName)
                                           throws Exception

Description copied from interface: IPersistence

获取由dataSourceName指定的数据源连接持有者对象

Specified by:

getConnectionHolder in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Parameters:

dataSourceName - 数据源名称

Returns:

获取由指定的数据源连接持有者对象

Throws:

Exception - 可能产生的异常

releaseConnectionHolder

public void releaseConnectionHolder(IMongoConnectionHolder connectionHolder)
                             throws Exception

Description copied from interface: IPersistence

安全关闭数据源的连接持有者(确保非事务状态下执行关闭)

Specified by:

releaseConnectionHolder in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Parameters:

connectionHolder - 数据源的连接持有者对象

Throws:

Exception - 可能产生的异常

openSession

public IMongoSession openSession()
                          throws Exception

Description copied from interface: IPersistence

开启数据库连接会话(注意一定记得关闭会话)

Specified by:

openSession in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openSession

public IMongoSession openSession(String dataSourceName)
                          throws Exception

Description copied from interface: IPersistence

开启数据库连接会话(注意一定记得关闭会话)

Specified by:

openSession in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Parameters:

dataSourceName - 数据源名称

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openSession

public IMongoSession openSession(IMongoConnectionHolder connectionHolder)
                          throws Exception

Description copied from interface: IPersistence

开启数据库连接会话(注意一定记得关闭会话)

Specified by:

openSession in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Parameters:

connectionHolder - 数据源连接持有者对象

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openSession

public IMongoSession openSession(IDataSourceRouter dataSourceRouter)
                          throws Exception

Description copied from interface: IPersistence

开启数据库连接会话(注意一定记得关闭会话)

Specified by:

openSession in interface IPersistence<IMongoSession,IMongoConfig,IMongoConnectionHolder>

Parameters:

dataSourceRouter - 数据源路由对象

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

getDefaultDataSourceAdapter

public IMongoDataSourceAdapter getDefaultDataSourceAdapter()

Description copied from interface: IMongo

获取默认数据源适配器

Specified by:

getDefaultDataSourceAdapter in interface IMongo

Returns:

返回数据源适配器对象

getDataSourceAdapter

public IMongoDataSourceAdapter getDataSourceAdapter(String dataSourceName)

Description copied from interface: IMongo

获取指定源数据源适配器

Specified by:

getDataSourceAdapter in interface IMongo

Parameters:

dataSourceName - 数据源名称

Returns:

返回数据源适配器对象

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

openSession

public <T> T openSession(IMongoSessionExecutor<T> executor)
                  throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

public <T> T openSession(IMongoConnectionHolder connectionHolder,
                         IMongoSessionExecutor<T> executor)
                  throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 连接对象持有者

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

public <T> T openSession(String dataSourceName,
                         IMongoSessionExecutor<T> executor)
                  throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceName - 数据源名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

public <T> T openSession(IDataSourceRouter dataSourceRouter,
                         IMongoSessionExecutor<T> executor)
                  throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(String bucketName,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

bucketName - 桶名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(String dataSourceName,
                               String bucketName,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceName - 数据源名称

bucketName - 桶名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(IMongoConnectionHolder connectionHolder,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 连接对象持有者

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(IDataSourceRouter dataSourceRouter,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(IMongoConnectionHolder connectionHolder,
                               String bucketName,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 连接对象持有者

bucketName - 桶名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public <T> T openGridFsSession(IDataSourceRouter dataSourceRouter,
                               String bucketName,
                               IGridFsSessionExecutor<T> executor)
                        throws Exception

Description copied from interface: IMongo

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Specified by:

openGridFsSession in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

bucketName - 桶名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openGridFsSession

public IGridFsSession openGridFsSession()
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(String bucketName)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

bucketName - 桶名称

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(String dataSourceName,
                                        String bucketName)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

dataSourceName - 数据源名称

bucketName - 桶名称

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(IMongoConnectionHolder connectionHolder,
                                        String bucketName)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

connectionHolder - 连接对象持有者

bucketName - 桶名称

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(IMongoConnectionHolder connectionHolder)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

connectionHolder - 连接对象持有者

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(IDataSourceRouter dataSourceRouter,
                                        String bucketName)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

dataSourceRouter - 数据源路由对象

bucketName - 桶名称

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openGridFsSession

public IGridFsSession openGridFsSession(IDataSourceRouter dataSourceRouter)
                                 throws Exception

Description copied from interface: IMongo

开启数据库文件储存会话(注意一定记得关闭会话)

Specified by:

openGridFsSession in interface IMongo

Parameters:

dataSourceRouter - 数据源路由对象

Returns:

返回会话对象

Throws:

Exception - 可能产生的异常

openTransaction

public void openTransaction(ITrade trade)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

trade - 事务业务操作对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(ITrade trade,
                            ClientSessionOptions clientSessionOptions)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(IMongoConnectionHolder connectionHolder,
                            ITrade trade)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

connectionHolder - 连接对象持有者

trade - 事务业务操作对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(IMongoConnectionHolder connectionHolder,
                            ITrade trade,
                            ClientSessionOptions clientSessionOptions)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

connectionHolder - 连接对象持有者

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(IDataSourceRouter dataSourceRouter,
                            ITrade trade)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

dataSourceRouter - 数据源路由对象

trade - 事务业务操作对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(IDataSourceRouter dataSourceRouter,
                            ITrade trade,
                            ClientSessionOptions clientSessionOptions)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

dataSourceRouter - 数据源路由对象

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(String dataSourceName,
                            ITrade trade)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

dataSourceName - 数据源名称

trade - 事务业务操作对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public void openTransaction(String dataSourceName,
                            ITrade trade,
                            ClientSessionOptions clientSessionOptions)
                     throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Parameters:

dataSourceName - 数据源名称

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(AbstractTrade<T> trade)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

trade - 事务业务操作对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(AbstractTrade<T> trade,
                             ClientSessionOptions clientSessionOptions)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(IMongoConnectionHolder connectionHolder,
                             AbstractTrade<T> trade,
                             ClientSessionOptions clientSessionOptions)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 连接对象持有者

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(IMongoConnectionHolder connectionHolder,
                             AbstractTrade<T> trade)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 连接对象持有者

trade - 事务业务操作对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(IDataSourceRouter dataSourceRouter,
                             AbstractTrade<T> trade)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

trade - 事务业务操作对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(IDataSourceRouter dataSourceRouter,
                             AbstractTrade<T> trade,
                             ClientSessionOptions clientSessionOptions)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(String dataSourceName,
                             AbstractTrade<T> trade)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceName - 数据源名称

trade - 事务业务操作对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openTransaction

public <T> T openTransaction(String dataSourceName,
                             AbstractTrade<T> trade,
                             ClientSessionOptions clientSessionOptions)
                      throws Exception

Description copied from interface: IMongo

开启事务(执行完毕事务将自动关闭, 任何异常将导致事务回滚)

Specified by:

openTransaction in interface IMongo

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceName - 数据源名称

trade - 事务业务操作对象

clientSessionOptions - 事务配置对象

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常