在 NodeJS 中使用 Sequelize 创建 MySQL 表

Sequelize是一个针对Node.js应用程序的ORM或框架，它允许您在Node.js上轻松地管理SQL数据库。 Sequelize 支持多个数据库管理系统，例如 PostgreSQL, MySQL, SQLite 和 Microsoft SQL Server。在这篇文章中，我们将探讨如何使用Sequelize框架在Node.js上创建MySQL表。

阅读更多：MySQL 教程

步骤1：安装和设置Sequelize

在开始使用Sequelize之前，您需要使用npm在Node.js环境中安装Sequelize。您可以在命令行中使用以下命令：

npm install sequelize mysql2

安装完成后，我们需要在Node.js中配置数据库连接。以下示例代码向您展示如何在Node.js中设置MySQL连接：

const Sequelize = require('sequelize');
const sequelize = new Sequelize('database_name', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

请注意，上述代码中的 “database_name” “username” 和 “password” 将被您的自定义数据库名称、MySQL用户名和MySQL密码所替换。使用上面的示例代码作为依据，在配置文件中”config.json”中添加您的配置，如下代码所示：

{
    "development": {
        "username": "database_username",
        "password": "database_password",
        "database": "database_name",
        "host": "localhost",
        "dialect": "mysql"
    }
}

步骤2：定义模型

在定义模型之前，我们需要使用Sequelize定义要插入到您的MySQL表中的列。以下示例定义了一个名称为“users”的表格和其对应的模型：

const User = sequelize.define('user', {
  id: {
    type: Sequelize.INTEGER,
    primaryKey: true,
    autoIncrement: true
  },
  first_name: {
    type: Sequelize.STRING
  },
  last_name: {
    type: Sequelize.STRING
  },
  email: {
    type: Sequelize.STRING
  }
}, {
  timestamps: false
});

在上述示例中，我们使用了Sequelize的 define() 方法定义了一个名为 “user”的模型。id是一个整数类型的主键，first_name, last_name 和 email是字符类型的属性。

timestamps选项是可选的。可以使用它来创建系统默认的update_at和created_at两个字段。为表格省略时间戳字段，将 timestamps 设置为 false。

步骤3：同步到数据库

定义完模型后，我们需要同步模型以创建表。您可以使用我们在第一步中定义的sequelize对象来同步模型。

sequelize.sync().then(() => {
  console.log('Users Table Created Successfully.');
}).catch(err => {
  console.error('Error while creating Users Table.', err);
});

上述示例使用sequelize对象的 sync() 方法将模型同步到数据库中。在成功创建用户表之后，您将在控制台上看到“Users Table Created Successfully”消息。

您还可以使用sync()方法的force选项来强制重新同步模型。

步骤4：运行应用程序

通过以上步骤，现在我们已经成功地创建了一个名为 “users” 的MySQL表，并将其定义为一个名为 “user”的模型。现在让我们运行我们的应用程序来确保创建表的过程是如预期的一样。

sequelize.authenticate()
  .then(() => {
    console.log('MySQL Connection has been established successfully.');
  })
  .catch(err => {
    console.error('MySQL Connection Error: ', err);
  });

以上示例使用authenticate()方法来验证数据库连接是否正常。

完整代码

const Sequelize = require('sequelize');
const sequelize = new Sequelize('database_name', 'username', 'password', {
  host: 'localhost',
  dialect: 'mysql'
});

const User = sequelize.define('user', {
  id: {
    type: Sequelize.INTEGER,
    primaryKey: true,
    autoIncrement: true
  },
  first_name: {
    type: Sequelize.STRING
  },
  last_name: {
    type: Sequelize.STRING
  },
  email: {
    type: Sequelize.STRING
  }
}, {
  timestamps: false
});

sequelize.sync().then(() => {
  console.log('Users Table Created Successfully.');
}).catch(err => {
  console.error('Error while creating Users Table.', err);
});

sequelize.authenticate()
  .then(() => {
    console.log('MySQL Connection has been established successfully.');
  })
  .catch(err => {
    console.error('MySQL Connection Error: ', err);
  });