Commit d7f2b185 authored by terrymanu's avatar terrymanu
Browse files

simplify XATransactionEvent

parent 3b9456e7
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -109,7 +109,7 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera
            case LOCAL:
                return new LocalTransactionEvent(operationType, cachedConnections.values(), autoCommit);
            case XA:
                return new XATransactionEvent(operationType, "");
                return new XATransactionEvent(operationType);
            case BASE:
            default:
                throw new UnsupportedOperationException(TransactionTypeHolder.get().name());
+0 −4
Original line number Diff line number Diff line
@@ -19,9 +19,7 @@ package io.shardingsphere.proxy.backend.jdbc.transaction;

import com.google.common.base.Optional;
import io.shardingsphere.core.constant.transaction.TransactionOperationType;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.Setter;

import java.sql.SQLException;

@@ -31,8 +29,6 @@ import java.sql.SQLException;
 * @author zhaojun
 */
@RequiredArgsConstructor
@Getter
@Setter
public abstract class TransactionEngine {
    
    private final String sql;
+1 −1
Original line number Diff line number Diff line
@@ -44,7 +44,7 @@ public final class XATransactionEngine extends TransactionEngine {
        Optional<TransactionOperationType> operationType = parseSQL();
        if (operationType.isPresent() && isInTransaction(operationType.get())) {
            TransactionTypeHolder.set(TransactionType.XA);
            EventBusInstance.getInstance().post(new XATransactionEvent(operationType.get(), getSql()));
            EventBusInstance.getInstance().post(new XATransactionEvent(operationType.get()));
            return true;
        }
        return false;
+0 −2
Original line number Diff line number Diff line
@@ -32,6 +32,4 @@ import lombok.RequiredArgsConstructor;
public final class XATransactionEvent implements ShardingTransactionEvent {
    
    private final TransactionOperationType operationType;
    
    private final String sql;
}