diff --git a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java index 584620a156306..a593f2594c4d9 100644 --- a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java +++ b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java @@ -168,9 +168,9 @@ private TrafficExecutorCallback getTrafficExecuteQueryCallback(final private ExecuteQueryCallback getExecuteQueryCallback(final ShardingSphereDatabase database, final QueryContext queryContext, final String jdbcDriverType) { return JDBCDriverType.STATEMENT.equals(jdbcDriverType) ? new StatementExecuteQueryCallback(database.getProtocolType(), database.getResourceMetaData(), - queryContext.getSqlStatementContext().getSqlStatement(), SQLExecutorExceptionHandler.isExceptionThrown()) + queryContext.getSqlStatementContext().getSqlStatement(), SQLExecutorExceptionHandler.isExceptionThrown()) : new PreparedStatementExecuteQueryCallback(database.getProtocolType(), database.getResourceMetaData(), - queryContext.getSqlStatementContext().getSqlStatement(), SQLExecutorExceptionHandler.isExceptionThrown()); + queryContext.getSqlStatementContext().getSqlStatement(), SQLExecutorExceptionHandler.isExceptionThrown()); } @SuppressWarnings({"rawtypes", "unchecked"}) @@ -286,7 +286,7 @@ private int executeUpdate(final ShardingSphereDatabase database, final ExecuteUp final StatementReplayCallback statementReplayCallback) throws SQLException { return isNeedImplicitCommitTransaction ? executeWithImplicitCommitTransaction(() -> useDriverToExecuteUpdate( - database, updateCallback, sqlStatementContext, executionContext, prepareEngine, statementReplayCallback), connection, database.getProtocolType()) + database, updateCallback, sqlStatementContext, executionContext, prepareEngine, statementReplayCallback), connection, database.getProtocolType()) : useDriverToExecuteUpdate(database, updateCallback, sqlStatementContext, executionContext, prepareEngine, statementReplayCallback); } @@ -398,7 +398,7 @@ private boolean executeWithExecutionContext(final ShardingSphereDatabase databas final boolean isNeedImplicitCommitTransaction, final StatementReplayCallback statementReplayCallback) throws SQLException { return isNeedImplicitCommitTransaction ? executeWithImplicitCommitTransaction(() -> useDriverToExecute(database, executeCallback, executionContext, prepareEngine, statementReplayCallback), connection, - database.getProtocolType()) + database.getProtocolType()) : useDriverToExecute(database, executeCallback, executionContext, prepareEngine, statementReplayCallback); }