Loading sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/JDBCBackendHandler.java +0 −3 Original line number Diff line number Diff line Loading @@ -48,7 +48,6 @@ import io.shardingsphere.proxy.util.ExecutorContext; import io.shardingsphere.transaction.xa.AtomikosUserTransaction; import lombok.Getter; import lombok.Setter; import lombok.extern.slf4j.Slf4j; import javax.sql.DataSource; import javax.transaction.Status; Loading @@ -71,7 +70,6 @@ import java.util.concurrent.Future; * @author zhaojun */ @Getter @Slf4j public abstract class JDBCBackendHandler implements BackendHandler { private final String sql; Loading Loading @@ -107,7 +105,6 @@ public abstract class JDBCBackendHandler implements BackendHandler { try { return execute(ruleRegistry.isMasterSlaveOnly() ? doMasterSlaveRoute() : doShardingRoute()); } catch (final Exception ex) { log.error("ExecuteBackendHandler", ex); return new CommandResponsePackets(new ErrPacket(1, new SQLException(ex))); } } Loading sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/JDBCExecuteWorker.java +1 −4 Original line number Diff line number Diff line Loading @@ -31,7 +31,6 @@ import io.shardingsphere.proxy.transport.mysql.packet.generic.ErrPacket; import io.shardingsphere.proxy.transport.mysql.packet.generic.OKPacket; import lombok.AllArgsConstructor; import lombok.Getter; import lombok.extern.slf4j.Slf4j; import java.sql.ResultSet; import java.sql.ResultSetMetaData; Loading @@ -48,7 +47,6 @@ import java.util.concurrent.Callable; */ @AllArgsConstructor @Getter @Slf4j public abstract class JDBCExecuteWorker implements Callable<CommandResponsePackets> { private final JDBCBackendHandler executeBackendHandler; Loading @@ -59,8 +57,7 @@ public abstract class JDBCExecuteWorker implements Callable<CommandResponsePacke public CommandResponsePackets call() { try { return execute(); } catch (SQLException ex) { log.error("ExecuteWorker", ex); } catch (final SQLException ex) { return new CommandResponsePackets(new ErrPacket(1, ex)); } finally { MasterVisitedManager.clear(); Loading sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/text/query/ComQueryPacket.java +0 −1 Original line number Diff line number Diff line Loading @@ -87,7 +87,6 @@ public final class ComQueryPacket extends CommandPacket implements CommandPacket return new CommandResponsePackets(new OKPacket(1)); } } catch (final Exception ex) { log.error("doTransactionIntercept Exception", ex); return new CommandResponsePackets(new ErrPacket(1, new SQLException(ex))); } return backendHandler.execute(); Loading Loading
sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/JDBCBackendHandler.java +0 −3 Original line number Diff line number Diff line Loading @@ -48,7 +48,6 @@ import io.shardingsphere.proxy.util.ExecutorContext; import io.shardingsphere.transaction.xa.AtomikosUserTransaction; import lombok.Getter; import lombok.Setter; import lombok.extern.slf4j.Slf4j; import javax.sql.DataSource; import javax.transaction.Status; Loading @@ -71,7 +70,6 @@ import java.util.concurrent.Future; * @author zhaojun */ @Getter @Slf4j public abstract class JDBCBackendHandler implements BackendHandler { private final String sql; Loading Loading @@ -107,7 +105,6 @@ public abstract class JDBCBackendHandler implements BackendHandler { try { return execute(ruleRegistry.isMasterSlaveOnly() ? doMasterSlaveRoute() : doShardingRoute()); } catch (final Exception ex) { log.error("ExecuteBackendHandler", ex); return new CommandResponsePackets(new ErrPacket(1, new SQLException(ex))); } } Loading
sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/common/jdbc/JDBCExecuteWorker.java +1 −4 Original line number Diff line number Diff line Loading @@ -31,7 +31,6 @@ import io.shardingsphere.proxy.transport.mysql.packet.generic.ErrPacket; import io.shardingsphere.proxy.transport.mysql.packet.generic.OKPacket; import lombok.AllArgsConstructor; import lombok.Getter; import lombok.extern.slf4j.Slf4j; import java.sql.ResultSet; import java.sql.ResultSetMetaData; Loading @@ -48,7 +47,6 @@ import java.util.concurrent.Callable; */ @AllArgsConstructor @Getter @Slf4j public abstract class JDBCExecuteWorker implements Callable<CommandResponsePackets> { private final JDBCBackendHandler executeBackendHandler; Loading @@ -59,8 +57,7 @@ public abstract class JDBCExecuteWorker implements Callable<CommandResponsePacke public CommandResponsePackets call() { try { return execute(); } catch (SQLException ex) { log.error("ExecuteWorker", ex); } catch (final SQLException ex) { return new CommandResponsePackets(new ErrPacket(1, ex)); } finally { MasterVisitedManager.clear(); Loading
sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/text/query/ComQueryPacket.java +0 −1 Original line number Diff line number Diff line Loading @@ -87,7 +87,6 @@ public final class ComQueryPacket extends CommandPacket implements CommandPacket return new CommandResponsePackets(new OKPacket(1)); } } catch (final Exception ex) { log.error("doTransactionIntercept Exception", ex); return new CommandResponsePackets(new ErrPacket(1, new SQLException(ex))); } return backendHandler.execute(); Loading