io.seata.rm.datasource

类 DataSourceManager

java.lang.Object

io.seata.rm.AbstractResourceManager

io.seata.rm.datasource.DataSourceManager

所有已实现的接口:

io.seata.common.executor.Initialize, ResourceManager, ResourceManagerInbound, ResourceManagerOutbound

public class DataSourceManager
extends AbstractResourceManager
implements io.seata.common.executor.Initialize

The type Data source manager.

作者:

sharajava

构造器概要

构造器

构造器和说明
DataSourceManager() Instantiates a new Data source manager.

方法概要

限定符和类型	方法和说明
BranchStatus	branchCommit(BranchType branchType, String xid, long branchId, String resourceId, String applicationData)
BranchStatus	branchRollback(BranchType branchType, String xid, long branchId, String resourceId, String applicationData)
DataSourceProxy	get(String resourceId) Get data source proxy.
BranchType	getBranchType()
Map<String,Resource>	getManagedResources()
void	init()
void	initAsyncWorker(ResourceManagerInbound asyncWorker) Init.
boolean	lockQuery(BranchType branchType, String resourceId, String xid, String lockKeys)
void	registerResource(Resource resource)
void	setAsyncWorker(ResourceManagerInbound asyncWorker) Sets async worker.
void	unregisterResource(Resource resource)

从类继承的方法 io.seata.rm.AbstractResourceManager

branchRegister, branchReport

从类继承的方法 java.lang.Object

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

构造器详细资料

DataSourceManager

public DataSourceManager()

Instantiates a new Data source manager.

方法详细资料

setAsyncWorker

public void setAsyncWorker(ResourceManagerInbound asyncWorker)

Sets async worker.

参数:

asyncWorker - the async worker

lockQuery

public boolean lockQuery(BranchType branchType,
                         String resourceId,
                         String xid,
                         String lockKeys)
                  throws TransactionException

指定者:

lockQuery 在接口中 ResourceManagerOutbound

覆盖:

lockQuery 在类中 AbstractResourceManager

抛出:

TransactionException

initAsyncWorker

public void initAsyncWorker(ResourceManagerInbound asyncWorker)

Init.

参数:

asyncWorker - the async worker

init

public void init()

指定者:

init 在接口中 io.seata.common.executor.Initialize

registerResource

public void registerResource(Resource resource)

指定者:

registerResource 在接口中 ResourceManager

覆盖:

registerResource 在类中 AbstractResourceManager

unregisterResource

public void unregisterResource(Resource resource)

指定者:

unregisterResource 在接口中 ResourceManager

覆盖:

unregisterResource 在类中 AbstractResourceManager

get

public DataSourceProxy get(String resourceId)

Get data source proxy.

参数:

resourceId - the resource id

返回:

the data source proxy

branchCommit

public BranchStatus branchCommit(BranchType branchType,
                                 String xid,
                                 long branchId,
                                 String resourceId,
                                 String applicationData)
                          throws TransactionException

指定者:

branchCommit 在接口中 ResourceManagerInbound

抛出:

TransactionException

branchRollback

public BranchStatus branchRollback(BranchType branchType,
                                   String xid,
                                   long branchId,
                                   String resourceId,
                                   String applicationData)
                            throws TransactionException

指定者:

branchRollback 在接口中 ResourceManagerInbound

抛出:

TransactionException

getManagedResources

public Map<String,Resource> getManagedResources()

指定者:

getManagedResources 在接口中 ResourceManager

getBranchType

public BranchType getBranchType()

指定者:

getBranchType 在接口中 ResourceManager