从nodejs中的异步查询中获取结果

Question

我正在从数据库中提取一些数据，以便在我的 nodejs 应用程序中使用它。 我正在使用 node-postgres 连接到数据库 (https://node-postgres.com/)。

我多次阅读指南并尝试以不同方式查询它（回调、承诺、使用池和客户端），但总是出错。

const { Pool } = require('pg');

const pool = new Pool({
  user: 'user',
  host: 'host',
  database: 'db',
  password: 'pass',
  port: port,
});

pool.query('SELECT * from table').then(res=> {
var projects = res.rows; 
console.log(projects); 
return projects;
});

//... few other operations on projects data to follow before exports

exports.raw = projects;

我可以在控制台输出中看到数据，所以连接正常，但是当我尝试运行代码时，我得到了

ReferenceError: projects is not defined.

感谢您对此提供的任何帮助。

Answer 1

试试async/await 语法：

let projects;

(async () => {
    const res = await pool.query('SELECT * from table');
    projects = res.rows;
})();

exports.raw = projects;

Answer 2

你可以通过async/await代码格式简单实现

users.js

const users = {};

const { Pool } = require('pg');

const pool = new Pool({
  user: 'user',
  host: 'host',
  database: 'db',
  password: 'pass',
  port: process.env.port,
});

users.getUsers = async () => {
  try {
    const result = await pool.query('SELECT * FROM users');
    console.log(result);
    return result;
  } catch (err) {
    console.error(err);
    throw err;
  }
};

module.exports = users;

friends.js

const friends = {};

const users = require('./users');

friends.getSampleData = async () => {
  try {
    const result = await users.getUsers();
    console.log(result);
    return result;
  } catch (err) {
    console.error(err);
    throw err;
  }
};

module.exports = friends;

注意 async/await 仅适用于返回 Promise 的函数。

Answer 3

就像 Jeremy 回答的那样，创建一个 getter 方法来获取数据，不要在需要之前尝试存储它。

const fetchData = async() => {
  const res = await pool.query('SELECT * from table')
  return res.rows;
}

const myDesiredData = fetchData()