org.apache.shardingsphere.transaction.spi

Interface ShardingTransactionManager

All Superinterfaces:

AutoCloseable

public interface ShardingTransactionManager
extends AutoCloseable

Sharding transaction manager.

Author:

zhaojun

Method Summary

Modifier and Type	Method and Description
void	begin() Begin transaction.
void	commit() Commit transaction.
Connection	getConnection(String dataSourceName) Get transactional connection.
TransactionType	getTransactionType() Get transaction type.
void	init(org.apache.shardingsphere.spi.database.DatabaseType databaseType, Collection<ResourceDataSource> resourceDataSources) Initialize sharding transaction manager.
boolean	isInTransaction() Judge is in transaction or not.
void	rollback() Rollback transaction.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

init

void init(org.apache.shardingsphere.spi.database.DatabaseType databaseType,
          Collection<ResourceDataSource> resourceDataSources)

Initialize sharding transaction manager.

Parameters:

databaseType - database type

resourceDataSources - resource data sources

getTransactionType

TransactionType getTransactionType()

Get transaction type.

Returns:

transaction type

isInTransaction

boolean isInTransaction()

Judge is in transaction or not.

Returns:

in transaction or not

getConnection

Connection getConnection(String dataSourceName)
                  throws SQLException

Get transactional connection.

Parameters:

dataSourceName - data source name

Returns:

connection

Throws:

SQLException - SQL exception

begin

void begin()

Begin transaction.

commit

void commit()

Commit transaction.

rollback

void rollback()

Rollback transaction.