mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix npe when the frontend connection is closed, the statement is still send (#3470)

Browse Source
This commit is contained in:
ylinzhu
2022-11-15 10:03:31 +08:00
committed by lin
parent 7c9d29a5d1
commit 3e22f8bda4
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/BaseSelectHandler.java
View File

@@ -24,6 +24,7 @@ import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
@@ -48,7 +49,8 @@ public class BaseSelectHandler extends BaseDMLHandler {
public BackendConnection initConnection() throws Exception {
if (serverSession.closed()) {
return null;
LOGGER.warn(" FrontendConnection is closed without sending a statement, conn is " + serverSession.getShardingService().getConnection());
throw new IOException("FrontendConnection is closed");
}
BackendConnection exeConn = serverSession.getTarget(rrss);