From 5edf825a36d26219316dc0ab0442539f46f2d595 Mon Sep 17 00:00:00 2001
From: terrymanu <zhangliang@apache.org>
Date: Sun, 2 Jun 2024 00:43:24 +0800
Subject: [PATCH] Refactor TrafficExecutorCallback

---
 .../apache/shardingsphere/traffic/executor/TrafficExecutor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/executor/TrafficExecutor.java b/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/executor/TrafficExecutor.java
index 7706ac2365005..56e42edf71393 100644
--- a/kernel/traffic/core/src/main/java/org/apache/shardingsphere/traffic/executor/TrafficExecutor.java
+++ b/kernel/traffic/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;
     }