master-salve connection only use local transaction

sharding-jdbc/sharding-jdbc-core/src/main/java/org/apache/shardingsphere/shardingjdbc/jdbc/adapter/AbstractConnectionAdapter.java

@@ -27,6 +27,7 @@ import org.apache.shardingsphere.core.routing.router.masterslave.MasterVisitedMa
 import org.apache.shardingsphere.core.spi.hook.SPIRootInvokeHook;
 import org.apache.shardingsphere.shardingjdbc.jdbc.adapter.executor.ForceExecuteCallback;
 import org.apache.shardingsphere.shardingjdbc.jdbc.adapter.executor.ForceExecuteTemplate;
+import org.apache.shardingsphere.shardingjdbc.jdbc.core.connection.MasterSlaveConnection;
 import org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationConnection;
 import org.apache.shardingsphere.spi.hook.RootInvokeHook;
 import org.apache.shardingsphere.transaction.ShardingTransactionManagerEngine;
@@ -190,7 +191,7 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera
     @Override
     public final void setAutoCommit(final boolean autoCommit) throws SQLException {
         this.autoCommit = autoCommit;
-        if (TransactionType.LOCAL == transactionType) {
+        if (TransactionType.LOCAL == transactionType || this instanceof MasterSlaveConnection) {
             setAutoCommitForLocalTransaction(autoCommit);
         } else if (!autoCommit) {
             shardingTransactionManager.begin();
@@ -210,7 +211,7 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera
     
     @Override
     public final void commit() throws SQLException {
-        if (TransactionType.LOCAL == transactionType) {
+        if (TransactionType.LOCAL == transactionType || this instanceof MasterSlaveConnection) {
             commitForLocalTransaction();
         } else {
             shardingTransactionManager.commit();
@@ -229,7 +230,7 @@ public abstract class AbstractConnectionAdapter extends AbstractUnsupportedOpera
     
     @Override
     public final void rollback() throws SQLException {
-        if (TransactionType.LOCAL == transactionType) {
+        if (TransactionType.LOCAL == transactionType || this instanceof MasterSlaveConnection) {
             rollbackForLocalTransaction();
         } else {
             shardingTransactionManager.rollback();