mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-19 06:11:06 -05:00
Code Issues Packages Projects Releases Wiki Activity

conn leak

Browse Source
This commit is contained in:
yanhuqing
2020-03-17 14:49:50 +08:00
parent cc070243d6
commit 46eaba02fb
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/BaseSelectHandler.java
+9 -5
View File
@@ -50,30 +50,34 @@ public class BaseSelectHandler extends BaseDMLHandler {
MySQLConnection exeConn = (MySQLConnection) session.getTarget(rrss);
if (session.tryExistsCon(exeConn, rrss)) {
exeConn.setRowDataFlowing(true);
return exeConn;
} else {
PhysicalDBNode dn = DbleServer.getInstance().getConfig().getDataNodes().get(rrss.getName());
//autocommit is session.getSource().isAutocommit() && !session.getSource().isTxStart()
final BackendConnection newConn = dn.getConnection(dn.getDatabase(), autocommit, rrss.getRunOnSlave(), rrss);
session.bindConnection(rrss, newConn);
newConn.setResponseHandler(this);
((MySQLConnection) newConn).setRowDataFlowing(true);
return (MySQLConnection) newConn;
}
}
public void execute(MySQLConnection conn) {
if (session.closed()) {
conn.setRowDataFlowing(false);
session.clearResources(true);
return;
}
conn.setResponseHandler(this);
conn.setSession(session);
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(conn.toString() + " send sql:" + rrss.getStatement());
}
if (session.closed()) {
if (conn.isClosed()) {
conn.setRowDataFlowing(false);
session.onQueryError("failed or cancelled by other thread".getBytes());
return;
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(conn.toString() + " send sql:" + rrss.getStatement());
}
conn.execute(rrss, session.getSource(), autocommit);
}