如何使异步函数在解析之前等待数据库查询完成？ [复制]

Question

所以我有：

async function functionName() {
  return await new Promise( async (resolve, reject) => {
    try { 
      //variables and such
      for (let i = 0; i < results.length; i++) {
        await geo.geocode('mapbox.places', address, async function (err, geoData) {
          await db.query(`INSERT INTO table (col1, col2, col3) VALUES($1, $2, $3) ON CONFLICT DO NOTHING`, ["default", val2, val3], (err, res) => {
            if (err) {
              console.error(err);
              return;
            }
          }
        }
      }
      resolve("resolved")
    } catch(e) {
      reject(err)
    }
  }
}

由于某种原因，当我调用此函数时，似乎该函数正在解析，但在解析完成后对数据库进行了查询。如何确保该函数仅在查询完成/数据库更新后才解析？

Answer 1

您不能将普通的回调与 Promise 混合使用，并希望控制流程。当您向它们传递回调时，geo.geocode() 和 db.query() 等函数不会返回承诺，因此 await 没有任何用处。相反，您需要使用这些函数的承诺版本，或者创建一个承诺版本（如果尚不存在）。

如果您使用支持 Promise 的 geocode 库的 beta 版本，并且您使用支持 Promise 的 sql 库版本，那么您可以这样编写代码：

async function functionName() {
      //variables and such
      for (let i = 0; i < results.length; i++) {
        let geoData = await geo.geocode('mapbox.places', address);
        await db.query(`INSERT INTO table (col1, col2, col3) VALUES($1, $2, $3) ON CONFLICT DO NOTHING`, ["default", val2, val3]);
      }
}

但是，由于这个 sql 语句无论你在做什么循环迭代都是一样的，所以这里肯定缺少一些使用 geoData 的代码。

---

如果您无法访问支持 Promise 的 geo.geocode 和 db.query 版本，那么您可以像这样自己手动对各个方法进行 Promisify：

const util = require('util');
const geo.geocodeP = util.promisify(geo.geocode);
const db.queryP = util.promisify(db.query);

async function functionName() {
    //variables and such
    for (let i = 0; i < results.length; i++) {
        let geoData = await geo.geocodeP('mapbox.places', address);
        await db.queryP(`INSERT INTO table (col1, col2, col3) VALUES($1, $2, $3) ON CONFLICT DO NOTHING`, ["default",
            val2, val3
        ])
    }
}

请记住，这些都不会使函数在返回之前“等待”。该函数在遇到第一个await 时仍会立即返回一个promise，调用者必须使用该promise 和await 或.then() 才能从函数中获得最终结果。不过，这允许您做的是，在 for 循环中对异步操作进行排序，以便它们按顺序发生，其中一个异步操作在下一次运行之前等待前一个完成。