javascript - 函数不返回记录集

Question

编辑: 答案在这个问题的末尾，因为我无法回答这个问题，因为它被标记为重复。

我是 Node 和 Express 新手，在尝试从数据库检索记录集时遇到问题。

我的代码中有一个函数应该从数据库获取记录集:

// Connection
const db_connection = nconf.get("db");
const connectionPool = new mssql.ConnectionPool(db_connection).connect(err => {
  if (err)
    failureCallback(err);
});

// The function I'm talking about
function getAllUser() {
  connectionPool.query("SELECT * FROM User", (err, result) => {
    if (err)
      failureCallback(err);
    else
      return result.recordset;
  });
}

我在路由中调用此函数:

app.get("/users", (req, res) => {
  res.send(getAllUser());
});

结果是……什么也没有。空白页 - 没有错误。

如果我使用这样的函数:

function getAllUser2(callback) {
  connectionPool.connect().then(function () {
    const request = new mssql.Request(connectionPool);
    request.query("SELECT * FROM User").then(function (result) {
      connectionPool.close();
      callback(result.recordset);
    }, failureCallback);
  }, failureCallback);
}

在路由中:

app.get("/users2", (req, res) => {
  conn.getAllUser(function (err, result) {
    if (err) 
      res.send(err);
    else 
      res.send(result);
  });
});

它有效。据我了解，我没有做太多改变，我只是想让它更具可读性/易于理解。

我非常感谢任何帮助和/或指导!

编辑: 尽管该问题被标记为重复，并且在阅读与其链接的问题/答案后，我仍然遇到问题，并且不知道为什么它不起作用。因此，如果有人可以帮助我，我将非常感激......

使用这样的函数:

test5 = function () {
  return connectionPool.query("SELECT * FROM Objekt", (err, result) => {
    if (err)
      failureCallback(err);
    else {
      console.log("Test 5 success!");
      console.log(result);
      //console.log(recordset);
      console.log(result.recordset);
      //result.recordset;
      result;
    }
  })
};

我在页面上看到这个:

TypeError: Converting circular structure to JSON
    at JSON.stringify (<anonymous>)
    at stringify (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\response.js:1123:12)
    at ServerResponse.json (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\response.js:260:14)
    at ServerResponse.send (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\response.js:158:21)
    at app.get (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\app.js:110:7)
    at Layer.handle [as handle_request] (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\router\layer.js:95:5)
    at next (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\router\route.js:137:13)
    at Route.dispatch (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\router\route.js:112:3)
    at Layer.handle [as handle_request] (M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\router\layer.js:95:5)
    at M:\MyFiles\Workspaces\Node_workspace\SPPA\API\node_modules\express\lib\router\index.js:281:22

但是控制台中的正确结果(console.log(result)):

{ recordsets: [ [ [Object], [Object], [Object], [Object] ] ],
  recordset:
  [ { id: '3FCB9E85-CEB1-41F1-84B4-4A9912345678',
  anmeldename: 'lustig_pe',
  email: 'peter.lustig@company.com',
  istAdmin: false },
{ id: '04B142F1-1A5C-4B97-A173-650C12345678',
  anmeldename: 'durden_ty',
  email: 'tylor.durden@company.com',
  istAdmin: true },
{ id: 'A5019258-2CC7-4794-A924-65F812345678',
  anmeldename: 'sarpei_ha',
  email: 'hans.sarpei@company.com',
  istAdmin: true },
{ id: 'BAFF838E-B606-4DC8-AEF6-DED612345678',
  anmeldename: 'mustermann_ma',
  email: 'max.mustermann@company.com',
  istAdmin: false } ],
  output: {},
  rowsAffected: [ 4 ] }
[ { id: '3FCB9E85-CEB1-41F1-84B4-4A9912345678',
    anmeldename: 'lustig_pe',
    email: 'peter.lustig@company.com',
    istAdmin: false },
  { id: '04B142F1-1A5C-4B97-A173-650C12345678',
    anmeldename: 'durden_ty',
    email: 'tylor.durden@company.com',
    istAdmin: true },
  { id: 'A5019258-2CC7-4794-A924-65F812345678',
    anmeldename: 'sarpei_ha',
    email: 'hans.sarpei@company.com',
    istAdmin: true },
  { id: 'BAFF838E-B606-4DC8-AEF6-DED612345678',
    anmeldename: 'mustermann_ma',
    email: 'max.mustermann@company.com',
    istAdmin: false } ]
}

有什么想法吗？

编辑: 我找到了解决方案，但无法回答我的问题(我猜是因为它被标记为重复)，所以我将在问题中显示它:

// This is the function you want to call in the routing:
function getFoo() {
  try {
    return connectionPool.query("SELECT * FROM Foo");
  }
  catch (err) {
    return err.message;
  }
}

// In routing you have to add **async** to the callback function 
// and add **await** next to the function you are calling. 
// This works now!
app.get('/v2/anhang', async (req, res) => {
  res.send(await getFoo());
});

我还想指出，这个看似“重复”问题的链接问题(及其答案)根本没有帮助我。我在我试图在路由中调用的函数中尝试了很多东西，以至于我忘记了路由中的回调函数......所以我希望这能帮助初学者解决类似的问题，这样他们就不必阅读大部分不相关的内容并浪费时间。

Answer 1

您没有从函数返回任何内容，也没有在 getAllUser() 中调用回调函数。

试试这个:

function getAllUser() {
   return new Promise(resolve=>{
       connectionPool.query("SELECT * FROM User", (err, result) => {
    if (err)
      failureCallback(err);
    else
      resolve(result.recordset)
  });
   })
}