如何在Node.js(Express)中配置数据库脚本仅执行一次

你遇到的问题是每次用nodemon重启应用时，执行updateTables里的添加列语句会报错——因为address列已经存在。下面给你几种可行的解决办法：

一、快速修复：修改SQL语句（最简单） #

PostgreSQL支持ADD COLUMN IF NOT EXISTS语法，直接修改你的表变更语句，重复执行也不会触发报错：

const addAdressColumnInUsersTable=`
    ALTER TABLE IF EXISTS users ADD COLUMN IF NOT EXISTS address VARCHAR;
`;

另外注意你代码里的小错误：createTables函数里调用了createTableQueries，但你定义的变量是createUsersTable，得改成executeQueryArray([createUsersTable])，不然会触发变量未定义的错误。

二、手动实现迁移记录（适合小型项目） #

如果以后会有更多数据库变更，建议建一个专门的表来记录已执行的脚本，彻底避免重复执行：

1. 先创建迁移记录表：

const createMigrationsTable = `
CREATE TABLE IF NOT EXISTS schema_migrations (
  id SERIAL PRIMARY KEY,
  script_name VARCHAR(255) NOT NULL UNIQUE,
  executed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
`;

2. 写一个检查脚本是否已执行的工具函数：

async function hasScriptExecuted(scriptName) {
  const result = await pool.query(
    'SELECT 1 FROM schema_migrations WHERE script_name = $1',
    [scriptName]
  );
  return result.rows.length > 0;
}

3. 修改updateTables函数，只执行未记录的脚本：

export const updateTables = async () => {
  // 先确保迁移记录表存在
  await pool.query(createMigrationsTable);
  
  const scriptName = 'add_address_column_to_users';
  if (!(await hasScriptExecuted(scriptName))) {
    await pool.query(addAdressColumnInUsersTable);
    // 记录已执行的脚本
    await pool.query(
      'INSERT INTO schema_migrations (script_name) VALUES ($1)',
      [scriptName]
    );
  }
};

这样不管重启多少次，只有第一次会执行添加列的操作。

三、用成熟的迁移库（推荐给中大型项目） #

如果项目后期会有大量数据库变更，直接用现成的迁移工具更省心，比如Knex.js：

1. 安装依赖：

npm install knex pg

2. 初始化Knex配置文件：

npx knex init

3. 在生成的knexfile.js里配置PostgreSQL连接信息，和你现有pool的配置保持一致。
4. 创建迁移文件：

npx knex migrate:make add_address_column_to_users

5. 在生成的迁移文件中编写变更逻辑：

exports.up = function(knex) {
  return knex.schema.alterTable('users', function(table) {
    table.string('address');
  });
};

exports.down = function(knex) {
  return knex.schema.alterTable('users', function(table) {
    table.dropColumn('address');
  });
};

6. 在app.js启动时自动执行迁移：

const knex = require('knex')(require('./knexfile')[process.env.NODE_ENV || 'development']);

async function startApp() {
  await knex.migrate.latest();
  // 这里写你启动应用服务的代码
}

startApp();

Knex会自动维护一个迁移记录表，确保每个迁移脚本只执行一次，还支持回滚操作，适合长期维护的项目。

额外提示：修复你的批量执行函数 #

你当前的executeQueryArray有逻辑问题：forEach里用async/await不会按顺序执行，而且可能还没等所有SQL执行完就触发resolve了，建议改成顺序执行的版本：

export const executeQueryArray = async (arr) => {
  for (const q of arr) {
    await pool.query(q);
  }
};

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