Refactor TrafficExecutorCallback

apache · Jun 1, 2024 · 5edf825 · 5edf825
1 parent eb58f47
commit 5edf825
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...raffic/core/src/main/java/org/apache/shardingsphere/traffic/executor/TrafficExecutor.java b/...raffic/core/src/main/java/org/apache/shardingsphere/traffic/executor/TrafficExecutor.java
@@ -65,7 +65,7 @@ public <T> T execute(final String processId, final String databaseName, final St
         JDBCExecutionUnit executionUnit = createTrafficExecutionUnit(processId, databaseName, trafficInstanceId, queryContext, prepareEngine);
         SQLUnit sqlUnit = executionUnit.getExecutionUnit().getSqlUnit();
         cacheStatement(sqlUnit.getParameters(), executionUnit.getStorageResource());
-        T result = callback.execute(statement, sqlUnit.getSql());
+        T result = callback.execute(sqlUnit.getSql(), statement);
         resultSet = statement.getResultSet();
         return result;
     }