fix rwsplit user sqlExecuteTimeout do not take effects inner 1696 (#3194)

* fix rwsplit user sqlExecuteTimeout do not take effects  inner 1696

* fix function

src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java

@@ -179,8 +179,8 @@ public class MySQLResponseService extends BackendService {
         if (synSQL != null && ignoreSql(service)) {
             sendQueryCmd(synSQL.toString(), service.getCharset());
         }
+        execCmd(originPacket);
 
-        write(originPacket, WriteFlags.QUERY_END);
     }
 
     //-------------------------------------- for sharding ----------------------------------------------------
@@ -318,6 +318,13 @@ public class MySQLResponseService extends BackendService {
         this.sendQueryCmd(cmd, charsetName);
     }
 
+    public void execCmd(byte[] originPacket) {
+        isExecuting = true;
+        connection.setLastTime(TimeUtil.currentTimeMillis());
+        write(originPacket, WriteFlags.QUERY_END);
+
+    }
+
     private StringBuilder getSynSql(String xaTxID, RouteResultsetNode rrn, boolean expectAutocommit, VariablesService front) {
 
         StringBuilder sb = getSynSql(expectAutocommit, front);
@@ -519,6 +526,7 @@ public class MySQLResponseService extends BackendService {
 
     /**
      * Temporary way，it will be revised in the future
+     *
      * @param service
      * @return
      */

src/main/java/com/actiontech/dble/services/rwsplit/RWSplitHandler.java

@@ -233,7 +233,10 @@ public class RWSplitHandler implements ResponseHandler, LoadDataResponseHandler,
             if (!write2Client) {
                 loadDataClean();
                 rwSplitService.getSession2().bind(null);
-                writeErrorMsg(rwSplitService.nextPacketId(), "connection close");
+                reason = "Connection {dbInstance[" + rwSplitService.getConnection().getHost() + ":" + rwSplitService.getConnection().getPort() + "],DbGroup[" +
+                        rwSplitService.getUserConfig().getDbGroup() + "],threadID[" +
+                        ((MySQLResponseService) service).getConnection().getThreadId() + "]} was closed ,reason is [" + reason + "]";
+                writeErrorMsg(rwSplitService.nextPacketId(), reason);
                 write2Client = true;
                 if (buffer != null) {
                     frontedConnection.recycle(buffer);