org.apache.shardingsphere.transaction

Class ShardingTransactionManagerEngine

java.lang.Object

org.apache.shardingsphere.transaction.ShardingTransactionManagerEngine

public final class ShardingTransactionManagerEngine
extends Object

Sharding transaction manager engine.

Constructor Summary

Constructors

Constructor and Description
ShardingTransactionManagerEngine()

Method Summary

Modifier and Type	Method and Description
void	close() Close sharding transaction managers.
ShardingTransactionManager	getTransactionManager(TransactionType transactionType) Get sharding transaction manager.
void	init(org.apache.shardingsphere.infra.database.type.DatabaseType databaseType, Map<String,DataSource> dataSourceMap, String xaTransactionMangerType) Initialize sharding transaction managers.

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardingTransactionManagerEngine

public ShardingTransactionManagerEngine()

Method Detail

init

public void init(org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
                 Map<String,DataSource> dataSourceMap,
                 String xaTransactionMangerType)

Initialize sharding transaction managers.

Parameters:

databaseType - database type

dataSourceMap - data source map

xaTransactionMangerType - XA transaction manger type

getTransactionManager

public ShardingTransactionManager getTransactionManager(TransactionType transactionType)

Get sharding transaction manager.

Parameters:

transactionType - transaction type

Returns:

sharding transaction manager

close

public void close()
           throws Exception

Close sharding transaction managers.

Throws:

Exception - exception