diff --git a/rm-datasource/src/test/java/io/seata/rm/datasource/exec/MySQLInsertExecutorTest.java b/rm-datasource/src/test/java/io/seata/rm/datasource/exec/MySQLInsertExecutorTest.java
index 023fe03ab3d..9f28a7bca54 100644
--- a/rm-datasource/src/test/java/io/seata/rm/datasource/exec/MySQLInsertExecutorTest.java
+++ b/rm-datasource/src/test/java/io/seata/rm/datasource/exec/MySQLInsertExecutorTest.java
@@ -85,7 +85,8 @@ public class MySQLInsertExecutorTest {
     public void init() throws SQLException {
         ConnectionProxy connectionProxy = mock(ConnectionProxy.class);
         when(connectionProxy.getDbType()).thenReturn(JdbcConstants.MYSQL);
-        when(connectionProxy.getDataSourceProxy()).thenReturn(new DataSourceProxy(new MockDataSource()));
+        DataSourceProxy dataSourceProxy = new DataSourceProxy(new MockDataSource());
+        when(connectionProxy.getDataSourceProxy()).thenReturn(dataSourceProxy);
 
         statementProxy = mock(PreparedStatementProxy.class);
         when(statementProxy.getConnectionProxy()).thenReturn(connectionProxy);