Commit 37cff615 authored by terrymanu's avatar terrymanu
Browse files

remove transactionEventClazz of TransactionContext

parent 56b97f62

sharding-jdbc/src/main/java/io/shardingsphere/core/jdbc/adapter/AbstractConnectionAdapter.java

+1 −1
Original line number Diff line number Diff line
@@ -93,7 +93,7 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera 
    @Override

    public final void setAutoCommit(final boolean autoCommit) {

        this.autoCommit = autoCommit;

        TransactionContextHolder.set(new TransactionContext(new LocalTransactionManager(), TransactionType.LOCAL, LocalTransactionEvent.class));

        TransactionContextHolder.set(new TransactionContext(new LocalTransactionManager(), TransactionType.LOCAL));

        recordMethodInvocation(Connection.class, "setAutoCommit", new Class[] {boolean.class}, new Object[] {autoCommit});

        EventBusInstance.getInstance().post(buildTransactionEvent(TCLType.BEGIN));

    }

sharding-transaction/src/main/java/io/shardingsphere/transaction/common/TransactionContext.java

+1 −6
Original line number Diff line number Diff line
@@ -19,8 +19,6 @@ package io.shardingsphere.transaction.common; 


import io.shardingsphere.core.constant.TransactionType;

import io.shardingsphere.transaction.api.TransactionManager;

import io.shardingsphere.transaction.common.event.TransactionEvent;

import io.shardingsphere.transaction.common.event.LocalTransactionEvent;

import lombok.Getter;

import lombok.NoArgsConstructor;
@@ -37,11 +35,8 @@ public final class TransactionContext { 
    

    private TransactionType transactionType = TransactionType.LOCAL;

    

    private Class<? extends TransactionEvent> transactionEventClazz = LocalTransactionEvent.class;



    public TransactionContext(final TransactionManager transactionManager, final TransactionType transactionType, final Class<? extends TransactionEvent> clazz) {

    public TransactionContext(final TransactionManager transactionManager, final TransactionType transactionType) {

        this.transactionManager = transactionManager;

        this.transactionType = transactionType;

        this.transactionEventClazz = clazz;

    }

}

sharding-transaction/src/main/java/io/shardingsphere/transaction/common/TransactionContextFactory.java

+2 −4
Original line number Diff line number Diff line
@@ -19,8 +19,6 @@ package io.shardingsphere.transaction.common; 


import io.shardingsphere.core.constant.TransactionType;

import io.shardingsphere.transaction.api.TransactionManager;

import io.shardingsphere.transaction.common.event.LocalTransactionEvent;

import io.shardingsphere.transaction.common.event.XaTransactionEvent;

import io.shardingsphere.transaction.api.local.LocalTransactionManager;

import lombok.AccessLevel;

import lombok.NoArgsConstructor;
@@ -40,7 +38,7 @@ public class TransactionContextFactory { 
     * @return XA transaction context

     */

    public static TransactionContext newXAContext(final TransactionManager transactionManager) {

        return new TransactionContext(transactionManager, TransactionType.XA, XaTransactionEvent.class);

        return new TransactionContext(transactionManager, TransactionType.XA);

    }

    

    /**
@@ -49,6 +47,6 @@ public class TransactionContextFactory { 
     * @return local transaction context

     */

    public static TransactionContext newLocalTransactionContext() {

        return new TransactionContext(new LocalTransactionManager(), TransactionType.LOCAL, LocalTransactionEvent.class);

        return new TransactionContext(new LocalTransactionManager(), TransactionType.LOCAL);

    }

}