NodeJS + ExpressJS:如何等待forEach完成其中的SQL查询

const express = require('express');
const mysql = require('mysql');

const app = express();
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'database_name'
});

app.get('/data', async (req, res) => {
  try {
    const result = await getDataFromDatabase();
    res.json(result);
  } catch (error) {
    console.error(error);
    res.status(500).json({ error: 'Internal Server Error' });
  }
});

function getDataFromDatabase() {
  return new Promise((resolve, reject) => {
    const data = [];
    const query = 'SELECT * FROM table_name';
  
    connection.query(query, (error, rows) => {
      if (error) {
        reject(error);
      } else {
        rows.forEach(async (row) => {
          const detail = await getDetailFromDatabase(row.id);
          data.push(detail);
  
          if (data.length === rows.length) {
            resolve(data);
          }
        });
      }
    });
  });
}

function getDetailFromDatabase(id) {
  return new Promise((resolve, reject) => {
    const query = 'SELECT * FROM detail_table WHERE id = ?';
    connection.query(query, [id], (error, rows) => {
      if (error) {
        reject(error);
      } else {
        resolve(rows);
      }
    });
  });
}

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});