org.apache.shardingsphere.transaction

类 ConnectionTransaction

java.lang.Object

org.apache.shardingsphere.transaction.ConnectionTransaction

public final class ConnectionTransaction
extends Object

Connection transaction.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	ConnectionTransaction.DistributedTransactionOperationType

构造器概要

构造器

构造器和说明
ConnectionTransaction(String schemaName, TransactionContexts transactionContexts)
ConnectionTransaction(String schemaName, TransactionRule rule, TransactionContexts transactionContexts)

方法概要

限定符和类型	方法和说明
void	begin() Begin transaction.
void	commit() Commit transaction.
Optional<Connection>	getConnection(String dataSourceName) Get connection in transaction.
ConnectionTransaction.DistributedTransactionOperationType	getDistributedTransactionOperationType(boolean autoCommit) Get distributed transaction operation type.
boolean	isHoldTransaction(boolean autoCommit) Whether hold transaction.
boolean	isInTransaction() Whether in transaction.
boolean	isLocalTransaction() Judge is local transaction or not.
void	rollback() Rollback transaction.

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

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

构造器详细资料

ConnectionTransaction

public ConnectionTransaction(String schemaName,
                             TransactionContexts transactionContexts)

ConnectionTransaction

public ConnectionTransaction(String schemaName,
                             TransactionRule rule,
                             TransactionContexts transactionContexts)

方法详细资料

isInTransaction

public boolean isInTransaction()

Whether in transaction.

返回:

in transaction or not

isLocalTransaction

public boolean isLocalTransaction()

Judge is local transaction or not.

返回:

is local transaction or not

isHoldTransaction

public boolean isHoldTransaction(boolean autoCommit)

Whether hold transaction.

参数:

autoCommit - is auto commit

返回:

hold transaction or not

getConnection

public Optional<Connection> getConnection(String dataSourceName)
                                   throws SQLException

Get connection in transaction.

参数:

dataSourceName - data source name

返回:

connection in transaction

抛出:

SQLException - SQL exception

begin

public void begin()

Begin transaction.

commit

public void commit()

Commit transaction.

rollback

public void rollback()

Rollback transaction.

getDistributedTransactionOperationType

public ConnectionTransaction.DistributedTransactionOperationType getDistributedTransactionOperationType(boolean autoCommit)

Get distributed transaction operation type.

参数:

autoCommit - is auto commit

返回:

distributed transaction operation type