org.apache.shardingsphere.transaction.spi

接口 ShardingSphereTransactionManager

所有超级接口:

AutoCloseable

public interface ShardingSphereTransactionManager
extends AutoCloseable

ShardingSphere transaction manager.

方法概要

限定符和类型	方法和说明
void	begin() Begin transaction.
void	begin(int timeout) Begin transaction with given timeout.
void	commit(boolean rollbackOnly) Commit transaction.
Connection	getConnection(String databaseName, String dataSourceName) Get transactional connection.
TransactionType	getTransactionType() Get transaction type.
void	init(org.apache.shardingsphere.infra.database.type.DatabaseType databaseType, Collection<ResourceDataSource> resourceDataSources, String providerType) Initialize transaction manager.
boolean	isInTransaction() Judge is in transaction or not.
void	rollback() Rollback transaction.

从接口继承的方法 java.lang.AutoCloseable

close

方法详细资料

init

void init(org.apache.shardingsphere.infra.database.type.DatabaseType databaseType,
          Collection<ResourceDataSource> resourceDataSources,
          String providerType)

Initialize transaction manager.

参数:

databaseType - database type

resourceDataSources - resource data sources

providerType - transaction manager provider type

getTransactionType

TransactionType getTransactionType()

Get transaction type.

返回:

transaction type

isInTransaction

boolean isInTransaction()

Judge is in transaction or not.

返回:

in transaction or not

getConnection

Connection getConnection(String databaseName,
                         String dataSourceName)
                  throws SQLException

Get transactional connection.

参数:

databaseName - database name

dataSourceName - data source name

返回:

connection

抛出:

SQLException - SQL exception

begin

void begin()

Begin transaction.

begin

void begin(int timeout)

Begin transaction with given timeout.

参数:

timeout - Transaction timeout in SECONDS

commit

void commit(boolean rollbackOnly)

Commit transaction.

参数:

rollbackOnly - rollback only

rollback

void rollback()

Rollback transaction.