如何通过查询 sqlite3 数据库从行中返回值？ [复制]

Question

我正在为一些基于 sqlite3 的 expressjs 应用程序编写一些数据库中间件。 这是我的目录结构：

     | app
       | database
          index.js
       | routes
          index.js

database/index.js 包含：

module.exports.getLinkById = function(id) {
    Database.get(`SELECT redir FROM root WHERE id = "${id}"`, [], function(err, rows) {
        try {
            var row = rows;
            console.log(row.redir); // successfully logs the redir attr with correct value
            return row;
        } catch (e) {
            throw e;
        }
    });
};

并且 routes/index.js 包含：

var database = require('../database');
console.log(database.getLinkById("afb8")); // undefined

在database/index.js文件中，根据id选择行并返回。为了调试，我console.log()ged 并记录了正确的值。 但是，即使我返回了 row 值，routes/index.js 仍将其视为未定义。 如何正确地return 值，以便我可以在routes/index.js 中访问它？

Answer 1

这是一个不返回任何内容的异步函数。

只需返回一个快递的响应：

app.get("/api/user/:id", (req, res, next) => {
    var sql = "select * from user where id = ?"
    var params = [req.params.id]
    db.get(sql, params, (err, row) => {
        if (err) {
          res.status(400).json({"error":err.message});
          return;
        }
        res.json({
            "message":"success",
            "data":row
        })
      });
});

如果您需要同时运行更多代码，请参阅： sqlite3 nodejs get value from table

中间件所需功能，添加到database.js：

// Hack to look like node-postgres
// (and handle async / await operation)
db.query = function (sql, params) {
  var that = this;
  return new Promise(function (resolve, reject) {
    that.all(sql, params, function (error, rows) {
      if (error)
        reject(error);
      else
        resolve({ rows: rows });
    });
  });
};