等待在节点js中执行下一条语句之前完成回调

Question

NodeJ的新手。我在同步方法执行时遇到问题。这是我的意思，我有一个控制器负责：一种。调用方法（在单独的JS文件中）以打开数据库连接并检索数据。b。然后，它将数据发送到前端。从我的调试工作看来，我是在打开连接并获取数据的方法完成之前发送数据的。我知道这是因为，当salesController.js的最后一行执行时，它给出错误“无法读取未定义的属性'recordsets'”。在以下代码段中，dbAccess.js具有打开数据库并获取数据的方法。然后，salesController.js发送该数据。在salesController.js中突出显示的部分需要帮助。请注意是否有帮助，我将sql server作为后端使用。

dbAccess.js

const dbConfig = require('../../nodeApp/dbConfig')

module.exports = {
    makeDBAccess: function(sqlString, req, res) {
        var sql = require("mssql/msnodesqlv8");
        // connect to your database
        sql.connect(dbConfig, function (err) {


            if (err) console.log(err);

            // create Request object
            var request = new sql.Request();

            // query to the database and get the records
            request.query(sqlString, function (err, recordset) {

                if (err) console.log(err)

                console.log(recordset.recordsets[0]);
                console.log(recordset.recordsets[0].length)

                return recordset;
            });
        });
    }
}

salesController.js

const express = require('express');
var router = express.Router();
var dbAccess = require('../utility/dbAccess.js')
var utility = require('../utility/readfile.js')


router.get('/totalSales2011', function (req, res) {
    var sqlString = utility.readFileFunc("queries/sales2011.sql");
    var recordSet = dbAccess.makeDBAccess(sqlString,req,res); **//Get data from database**
    res.send(recordSet.recordsets[0]); **//Wait for line above to complete before doing this.**
});

module.exports = router;

Answer 1

由于您未添加undefined语句，因此javascript函数中的返回return，makeDBAccess函数不包含返回值，因此它返回undefined。

关于此操作，您需要使用callback或promises，因为连接到数据库并进行数据库查询都是non-blocking异步操作。

dbAccess.js

const dbConfig = require('../../nodeApp/dbConfig')

module.exports = {
    makeDBAccess: function(sqlString, callback) {
        var sql = require("mssql/msnodesqlv8");
        // connect to your database
        sql.connect(dbConfig, function (err) {


            if (err) return callback(err);

            // create Request object
            var request = new sql.Request();

            // query to the database and get the records
            request.query(sqlString, function (err, recordset) {

                if (err) return callback(err)


                return callback(null, recordset);
            });
        });
    }
}

salesController.js

const express = require('express');
var router = express.Router();
var dbAccess = require('../utility/dbAccess.js')
var utility = require('../utility/readfile.js')


router.get('/totalSales2011', function (req, res) {
    var sqlString = utility.readFileFunc("queries/sales2011.sql");
    var recordSet = dbAccess.makeDBAccess(sqlString, (err, recordSet) => {
          if (err) console.error(err);
          else res.send(recordSet.recordsets[0]);
    });

});

module.exports = router;