Node.js+Sequelize项目共享数据库连接报错，如何解决？

错误原因分析 #

你遇到的错误主要由以下几个问题导致：

• 循环依赖：项目中存在index.js → 路由 → 模型 → 迁移文件 → index.js的循环导入，导致index.js中的Sequelize实例还未完全初始化就被迁移文件引用，此时db对象不具备define方法。
• 模型与迁移职责混淆：迁移文件是用来管理数据库结构变更的工具，不应该被业务模型导入使用，两者职责要明确分开。
• 服务启动时机不当：数据库连接还未成功建立就启动了服务并加载路由，导致依赖数据库的代码提前执行。
• 错误使用原生MySQL连接：模型中使用了未定义的conn对象执行原生SQL，应该改用Sequelize模型提供的ORM方法。

分步解决方案 #

1. 重构目录结构，明确职责划分 #

调整项目结构，区分模型、迁移、路由的位置：

your-project/
├── index.js
├── models/
│   └── Product.js       # 定义Sequelize模型
├── migrations/          # 存放Sequelize迁移文件（由CLI生成）
├── routes/
│   └── homeRoute.js
└── public/

2. 修复数据库连接与服务启动顺序 #

修改index.js，确保数据库连接成功后再加载路由并启动服务：

const express = require('express')
const Sequelize = require('sequelize')
const app = express()

app.set("view engine", "ejs")
app.use(express.static('public'))

// 初始化Sequelize实例
const db = new Sequelize('maxDev', 'root', '', {
    host: '127.0.0.1',
    dialect: 'mysql'
})

// 先完成数据库连接与模型同步，再启动服务
db.authenticate()
  .then(() => {
    console.log("DB connected!")
    // 开发环境可使用sync自动创建表，生产环境建议用迁移
    return db.sync({ alter: true })
  })
  .then(() => {
    // 连接成功后再导入路由，避免循环依赖
    const homeRoute = require('./routes/homeRoute.js')
    app.use(homeRoute)

    // 启动服务
    app.listen(3000, () => {
      console.log("Server is running on 3000")
    })
  })
  .catch(error => {
    console.error('Database connection failed:', error)
    process.exit(1)
  })

module.exports = db

3. 编写正确的Sequelize模型 #

在models/Product.js中定义模型：

const { DataTypes } = require('sequelize')
const db = require('../index.js')

const Product = db.define('Product', {
    id: {
        type: DataTypes.INTEGER,
        allowNull: false,
        primaryKey: true,
        autoIncrement: true // 推荐添加自增属性，除非手动维护ID
    },
    name: {
        type: DataTypes.STRING,
        allowNull: false
    },
    price: {
        type: DataTypes.STRING,
        allowNull: false
    },
    specs: {
        type: DataTypes.STRING,
        allowNull: false
    },
    imgUrl: {
        type: DataTypes.TEXT,
    }
}, {
    tableName: 'products' // 指定表名，避免Sequelize自动复数化
})

module.exports = Product

4. 修复业务逻辑模型（数据操作层） #

修改你的业务模型文件（比如命名为services/productService.js），使用Sequelize模型方法替代原生SQL：

const Product = require('../models/Product.js')

async function getMainProducts () {
    try {
        // 使用Sequelize的ORM方法查询数据
        const products = await Product.findAll()
        console.log(products)
        return products
    } catch (err) {
        console.error('Failed to fetch products:', err)
        throw err
    }
}

module.exports = {
    getMainProducts,
}

5. 迁移文件的正确用法（可选，生产环境推荐） #

迁移文件用来管理数据库结构变更，通过Sequelize CLI生成和执行：

1. 安装Sequelize CLI：npm install --save-dev sequelize-cli
2. 初始化CLI配置：npx sequelize-cli init
3. 生成创建产品表的迁移文件：npx sequelize-cli migration:generate --name create-products-table
4. 在生成的迁移文件中编写表结构：

'use strict';

/** @type {import('sequelize-cli').Migration} */
module.exports = {
  async up(queryInterface, Sequelize) {
    await queryInterface.createTable('products', {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER
      },
      name: {
        type: Sequelize.STRING,
        allowNull: false
      },
      price: {
        type: Sequelize.STRING,
        allowNull: false
      },
      specs: {
        type: Sequelize.STRING,
        allowNull: false
      },
      imgUrl: {
        type: Sequelize.TEXT
      },
      createdAt: {
        allowNull: false,
        type: Sequelize.DATE
      },
      updatedAt: {
        allowNull: false,
        type: Sequelize.DATE
      }
    });
  },

  async down(queryInterface, Sequelize) {
    await queryInterface.dropTable('products');
  }
};

5. 执行迁移创建表：npx sequelize-cli db:migrate

额外注意事项 #

• 移除不必要的mysql包：你已经使用Sequelize作为ORM，不需要直接依赖mysql模块。
• 避免在模型中直接使用db.sync()：生产环境建议使用迁移文件管理表结构，db.sync()适合开发快速测试。

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