使用MongoDB的异步/等待

以下是一个使用Node.js和MongoDB官方驱动程序的Async/Await的示例。

※ 2019/3/23: 我添加了错误处理并重新审查了代码。

const transaction = async () => {
  let client;
  try {
    client = await mongodb.MongoClient.connect("mongodb://127.0.0.1:27017", {
      useNewUrlParser: true
    });

    const db = client.db("DATABSE_NAME");

    const res = await db
      .collection("COLLECTION_NAME")
      .save({ key: "value" });

    const docs = await db
      .collection("COLLECTION_NAME")
      .find({})
      .toArray();
    return docs;
  } catch (error) {
    console.log(error);
  } finally {
    client.close();
  }
};

transaction();

总结

• エラー処理をfinally句で行えるので楽

同期APIと非同期APIが混在しているので注意