节点 - MySQL 查询，需要几分钟时间，在几分钟后重复自己，然后完成原始查询

node - mysql query that takes a few minutes repeating itself after a few minutes before finishing the original query

本文关键字：分钟 几分钟 查询 自己 然后 原始 MySQL 节点 时间      更新时间：2023-09-26

我正在构建一个带有 angular 和 node js 的应用程序。我有一个非常大的查询（插入查询），它插入了大约 30，000 行的内容，由于某种原因需要几分钟（我想没关系）。

这是我的查询：

this.createCourts = function (req, res, next){
  console.log("entered creation courts");
      connection.query('CALL filldates("' + 
        req.body['startDate'] + '","' +
        req.body['endDate'] + '","' +
        req.body['numOfCourts'] + '","' +
        req.body['duration'] + '","' +
        req.body['sundayOpen'] + '","' +
        req.body['mondayOpen'] + '","' +
        req.body['tuesdayOpen'] + '","' +
        req.body['wednesdayOpen'] + '","' +
        req.body['thursdayOpen'] + '","' +
        req.body['fridayOpen'] + '","' +
        req.body['saturdayOpen'] + '","' +
        req.body['sundayClose'] + '","' +
        req.body['mondayClose'] + '","' +
        req.body['tuesdayClose'] + '","' +
        req.body['wednesdayClose'] + '","' +
        req.body['thursdayClose'] + '","' +
        req.body['fridayClose'] + '","' +
        req.body['saturdayClose'] +
        '");', function(err, result, fields){
        if (err){
          console.log("error is" + err);
          return res.send(500, "fail");              
        }
        else{
          console.log("finsihed");
          return res.send(200);
        }
      });
  });
};

我的 UI 将单击一个按钮，该按钮将触发如下服务：

  CourtsService.createCourts.save({}, 
    {"startDate": dateService.Date_toYMD($scope.startDate), 
    "endDate": dateService.Date_toYMD($scope.endDate), 
    "numOfCourts": $scope.numOfCourts, 
    "duration": $scope.duration, 
    "sundayOpen": $scope.sundayOpen.hour, 
    "mondayOpen": $scope.mondayOpen.hour, 
    "tuesdayOpen": $scope.tuesdayOpen.hour, 
    "wednesdayOpen": $scope.wednesdayOpen.hour, 
    "thursdayOpen": $scope.thursdayOpen.hour, 
    "fridayOpen": $scope.fridayOpen.hour, 
    "saturdayOpen": $scope.saturdayOpen.hour, 
    "sundayClose": $scope.sundayClose.hour,
    "mondayClose": $scope.mondayClose.hour,
    "tuesdayClose": $scope.tuesdayClose.hour,
    "wednesdayClose": $scope.wednesdayClose.hour,
    "thursdayClose": $scope.thursdayClose.hour,
    "fridayClose": $scope.fridayClose.hour,
    "saturdayClose": $scope.saturdayClose.hour},
     function(data){
      $scope.showSearching = false;
      $dialog.messageBox("success", btns).open();
  }, function(err){
      $scope.showSearching = false;
      $dialog.messageBox("fail", err.data, btns).open();
  });

我在实际执行查询的函数的第一行添加了这一行（它在此处的代码中） 控制台.log（"进入创造法院"）;

我的

问题是，由于查询运行了几分钟（可能是 10 分钟），似乎我的函数一次又一次地被调用，因为我可以在控制台中看到该行大约每1分钟"进入创造法庭"，这当然不是我希望发生的事情。

我不知道是什么一次又一次地触发了createCourt函数。

也许是因为 UI 超时，因此如果在 1 分钟后未收到答案（或接近该答案），则会再次触发服务。 如果这就是我如何告诉服务等待答案的原因？

考虑异步 api：在服务器上处理程序立即使用 HTTP 200 和一些 id 进行响应，并且还有另一个端点来检查 id 是否完成插入命令。

请注意，您的代码容易受到 SQL 注入攻击。更好的方法：

var params = req.body; // you may want to filter names explicitly here
connection.query('CALL filldates(?,?,?,?,...)', params, function(err, result, fields){
    if (err){
      console.log("error is" + err);
      return res.send(500, "fail");              
    }
    else{
      console.log("finsihed");
      return res.send(200);
    }
});

这将在发送查询之前转义客户端上所有危险的字符，或者使用带有 mysql2 的预准备语句来发送依赖于参数的查询：

var params = req.body; // you may want to filter names explicitly here
connection.execute('CALL filldates(?,?,?,?,...)', params, function(err, result, fields){
    if (err){
      console.log("error is" + err);
      return res.send(500, "fail");              
    }
    else{
      console.log("finsihed");
      return res.send(200);
    }
});

"几分钟"恕我直言太多了，在我的基准测试中，我的插入速率约为 10k 行/秒。尝试将惰性调用替换为生成大型插入查询文本，并使用控制台客户端进行测试。如果仍然需要几分钟，那么问题不在节点土地上，您需要优化数据库。

相关文章：