nodejs如何异步返回数据？

Question

星号那一排会打印出undefined，
search函数中该被return的数据是有我需要的数据的，
页面也收不到数据，哪里除了问题啊？

页面请求的数据格式是

await axios
    .get("/api/", {
        params: {
            type: "search",
            searchtext: this.searchtext
        }
    })
    .then(function(response) {
        if (response.data.result == "success") {
            // Do something
        } else if (response.data.result == "safetytest") {
            // Do something
        }
    })
    .catch(function(error) {
            // Do something
    });

服务器：

// 监听路径
app.get("/api/", function (req, res) {
    var resdata = {};
    // 查看是否为查询
    switch (req.query["type"]) {
        case "search":
            search(req.query["searchtext"])
            // ***************************************
            .then(resdata => { console.log(resdata); res.json(resdata) })
            .catch(e => { console.log });
            break;
        case "***":
            // other
            break;
        default:
            // other
    }
});

async function search(searchtext) {
    var resdata = {};
    // 安全检查
    if (safetytest(searchtext)) {
        pool.getConnection(function (err, connection) {
            if (err) throw err;
            connection.query(
                "SELECT * FROM `***` where ***=?",
                searchtext,
                function (err, result) {
                    if (err) throw err;
                    resdata = {
                        uid: result[0].uid,
                        aname: result[0].aname,
                        lng: result[0].lng,
                        lat: result[0].lat,
                        address: result[0].address,
                        telephone: result[0].telephone
                    };
                    return resdata;
                }
            );
        });
    }
}

Answer 1

pool.getConnection跟connection.query如果没有promise/async写法的话，你就手动实现各promise吧。

function search(searchtext) {
    return new Promise((resolve, reject) => {
        var resdata = {};
        if (safetytest(searchtext)) {
            pool.getConnection(function (err, connection) {
                if (err) reject(err); // reject
                connection.query(
                    function (err, result) {
                        if (err) reject(err); // reject
                        resdata = {
                        };
                        resolve(resdata); // resolve
                    }
                );
            });
        }
    })
}

有的话可能就是这样了。

async function search(searchtext) {
    var resdata = {};
    // 安全检查
    if (safetytest(searchtext)) {
        try {
            const connection = await pool.getConnection()
            const resdata = await connection.query()
            return resdata
        } catch (err) {
            throw err
        }
    }
}