Express+Sequelize+MySQL如何在启动前异步动态创建数据库？

我使用Express+Sequelize+MySQL技术栈，多数文档都是提前创建好数据库再连接Sequelize启动服务器，但我希望在服务器启动时动态创建数据库。目前从网上找到的代码存在异步问题：首次启动服务器时会因找不到数据库失败，第二次启动才能正常运行。以下是我的代码，请问该如何修复？
我曾尝试将Sequelize配置移到connection.query的回调中，但效果不佳。

models/index.js #

const Sequelize = require("sequelize");
const mysql = require("mysql2/promise");

const env = process.env.NODE_ENV || "development";
const config = require("../config/config")[env];
const db = {};

mysql
  .createConnection({
    user: config.username,
    password: config.password,
  })
  .then((connection) => {
    connection.query("CREATE DATABASE IF NOT EXISTS template;").then(() => {
      // Safe to use sequelize now
    });
  });

const sequelize = new Sequelize(
  config.database,
  config.username,
  config.password,
  config
);

Object.keys(db).forEach((modelName) => {
  db[modelName].init(sequelize);
});

Object.keys(db).forEach((modelName) => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

db.sequelize = sequelize;
db.Sequelize = Sequelize;

module.exports = db;

app.js #

const db = require("./models");


...

const app = express();
// mysql
db.sequelize
  .sync()
  .then(() => {
    console.log("db connection ");
  })
  .catch(console.error);

app.set("port", process.env.PORT || 8888);
app.use(cors());
app.use(express.json());

...

核心问题是Sequelize实例初始化和数据库创建的异步顺序颠倒——你先创建了Sequelize连接，再去创建数据库，首次启动时数据库还没创建好，Sequelize连接自然失败。

步骤1：改写models/index.js为异步初始化 #

将数据库创建和Sequelize实例初始化改为异步流程，确保数据库创建完成后再初始化Sequelize：

const Sequelize = require("sequelize");
const mysql = require("mysql2/promise");

const env = process.env.NODE_ENV || "development";
const config = require("../config/config")[env];
const db = {};

// 封装异步初始化函数
async function initDB() {
  // 1. 先连接MySQL服务（不指定数据库）
  const connection = await mysql.createConnection({
    user: config.username,
    password: config.password,
    host: config.host || 'localhost',
    port: config.port || 3306
  });

  // 2. 创建目标数据库（如果不存在）
  await connection.query(`CREATE DATABASE IF NOT EXISTS ${config.database};`);
  await connection.end(); // 关闭临时连接

  // 3. 初始化Sequelize实例
  const sequelize = new Sequelize(
    config.database,
    config.username,
    config.password,
    config
  );

  // 加载并初始化模型（如果你的模型是单独文件，需在此处导入并添加到db对象）
  // 示例：const User = require('./user')(sequelize, Sequelize); db.User = User;

  Object.keys(db).forEach((modelName) => {
    db[modelName].init(sequelize);
  });

  Object.keys(db).forEach((modelName) => {
    if (db[modelName].associate) {
      db[modelName].associate(db);
    }
  });

  db.sequelize = sequelize;
  db.Sequelize = Sequelize;

  return db;
}

// 导出异步初始化函数的Promise
module.exports = initDB();

步骤2：修改app.js等待数据库初始化完成 #

现在models/index.js导出的是Promise，app.js需要等待这个Promise完成后再启动服务器和执行sync：

// 导入数据库初始化的Promise
const initDB = require("./models");

...

const app = express();
app.set("port", process.env.PORT || 8888);
app.use(cors());
app.use(express.json());

// 先完成数据库初始化，再启动服务器
initDB.then(db => {
  return db.sequelize.sync();
}).then(() => {
  console.log("数据库连接同步完成");
  // 启动服务器
  app.listen(app.get("port"), () => {
    console.log(`服务器运行在端口 ${app.get("port")}`);
  });
}).catch(err => {
  console.error("数据库初始化失败:", err);
  process.exit(1); // 初始化失败直接退出进程
});

关键说明 #

• 临时连接MySQL服务时要指定正确的host和port，避免连接失败
• 如果你的项目是自动读取models目录下的模型文件，需要把模型加载逻辑放到initDB函数里，确保在Sequelize实例创建后再执行
• 用async/await替代嵌套then，让异步流程更清晰，避免回调地狱

内容的提问来源于stack exchange，提问作者jerry