(shardingsphere) branch master updated: Add more test cases on MySQLFrontendEngineTest (#37911)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new edbb78a8fdf Add more test cases on MySQLFrontendEngineTest (#37911)
edbb78a8fdf is described below

commit edbb78a8fdf71baeb7ac680a6da7ca4b0828e862
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Jan 30 21:06:15 2026 +0800

    Add more test cases on MySQLFrontendEngineTest (#37911)
---
 .../frontend/mysql/MySQLFrontendEngineTest.java    | 23 ++++++++++++----------
 1 file changed, 13 insertions(+), 10 deletions(-)

diff --git 
a/proxy/frontend/dialect/mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/MySQLFrontendEngineTest.java
 
b/proxy/frontend/dialect/mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/MySQLFrontendEngineTest.java
index 5605efefa98..a2d6b9759aa 100644
--- 
a/proxy/frontend/dialect/mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/MySQLFrontendEngineTest.java
+++ 
b/proxy/frontend/dialect/mysql/src/test/java/org/apache/shardingsphere/proxy/frontend/mysql/MySQLFrontendEngineTest.java
@@ -18,24 +18,26 @@
 package org.apache.shardingsphere.proxy.frontend.mysql;
 
 import io.netty.channel.Channel;
+import 
org.apache.shardingsphere.database.connector.core.spi.DatabaseTypedSPILoader;
+import org.apache.shardingsphere.database.connector.core.type.DatabaseType;
 import 
org.apache.shardingsphere.database.protocol.mysql.constant.MySQLConstants;
 import 
org.apache.shardingsphere.database.protocol.mysql.netty.MySQLSequenceIdInboundHandler;
+import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
 import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
 import 
org.apache.shardingsphere.proxy.frontend.mysql.command.query.binary.MySQLStatementIdGenerator;
 import 
org.apache.shardingsphere.proxy.frontend.netty.FrontendChannelInboundHandler;
+import 
org.apache.shardingsphere.proxy.frontend.spi.DatabaseProtocolFrontendEngine;
 import 
org.apache.shardingsphere.test.infra.framework.extension.mock.AutoMockExtension;
 import 
org.apache.shardingsphere.test.infra.framework.extension.mock.StaticMockSettings;
-import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Answers;
 import org.mockito.Mock;
-import org.mockito.junit.jupiter.MockitoSettings;
-import org.mockito.quality.Strictness;
 
 import java.util.concurrent.atomic.AtomicInteger;
 
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.ArgumentMatchers.isA;
@@ -45,19 +47,15 @@ import static org.mockito.Mockito.when;
 
 @ExtendWith(AutoMockExtension.class)
 @StaticMockSettings({ProxyContext.class, MySQLStatementIdGenerator.class})
-@MockitoSettings(strictness = Strictness.LENIENT)
 class MySQLFrontendEngineTest {
     
-    private MySQLFrontendEngine engine;
+    private final DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "MySQL");
+    
+    private final DatabaseProtocolFrontendEngine engine = 
DatabaseTypedSPILoader.getService(DatabaseProtocolFrontendEngine.class, 
databaseType);
     
     @Mock(answer = Answers.RETURNS_DEEP_STUBS)
     private Channel channel;
     
-    @BeforeEach
-    void setUp() {
-        engine = new MySQLFrontendEngine();
-    }
-    
     @Test
     void assertInitChannel() {
         engine.initChannel(channel);
@@ -74,4 +72,9 @@ class MySQLFrontendEngineTest {
         engine.release(connectionSession);
         
verify(MySQLStatementIdGenerator.getInstance()).unregisterConnection(connectionId);
     }
+    
+    @Test
+    void assertHandleException() {
+        assertDoesNotThrow(() -> engine.handleException(mock(), mock()));
+    }
 }