diff --git a/backend/framework/src/main/java/org/jumpserver/chen/framework/console/QueryConsole.java b/backend/framework/src/main/java/org/jumpserver/chen/framework/console/QueryConsole.java index ee11d62..26c90d2 100644 --- a/backend/framework/src/main/java/org/jumpserver/chen/framework/console/QueryConsole.java +++ b/backend/framework/src/main/java/org/jumpserver/chen/framework/console/QueryConsole.java @@ -505,6 +505,14 @@ private void sendDataView(DataView dataView, boolean clearOthers) { @Override public void close() { + if (this.currentPlan != null) { + // flush + var session = SessionManager.getCurrentSession(); + var lastCmd = this.currentPlan.getTargetSQL(); + var cmdRecord = new CommandRecord(lastCmd); + cmdRecord.setError("Abnormal exit"); + session.recordCommand(cmdRecord); + } log.info("console closed"); } }