Fastify 是一个快速的 Web 框架，而 Sequelize 是一个 Node.js 中的 ORM 框架，它能够轻松地连接和操作多个数据库。在本文中，我们将详细介绍如何使用 Sequelize 在 Fastify 中操作 MySQL 数据库。
安装 Sequelize 和 MySQL
在开始之前，我们需要安装 Sequelize 和 MySQL。使用以下命令可以安装 Sequelize 和 MySQL：
npm install sequelize mysql2
创建 Sequelize 实例
在 Fastify 中使用 Sequelize 首先需要创建一个 Sequelize 实例。可以通过以下方式创建一个 Sequelize 实例：
const Sequelize = require('sequelize');
const sequelize = new Sequelize('database', 'username', 'password', {
host: 'localhost',
dialect: 'mysql'
});其中，database 是数据库名称，username 和 password 是连接数据库的用户名和密码，host 是数据库的主机名，dialect 是数据库的类型。
定义模型
在 Sequelize 中，模型是一个 JavaScript 类，它映射到数据库中的表。可以通过以下方式定义模型：
-- -------------------- ---- -------
----- - ------ --------- - - ---------------------
----- ---- ------- ----- --
-----------
--- -
----- ------------------
----------- -----
-------------- ----
--
----- -
----- -----------------
---------- -----
--
------ -
----- -----------------
---------- ------
------- ----
--
---------- -
----- ---------------
------------- -------------
--
---------- -
----- ---------------
------------- -------------
-
-- -
----------
---------- ------
---在上面的代码中，我们定义了一个 User 模型，它有 id、name、email、createdAt 和 updatedAt 字段。id 为整数类型，是主键，同时还是自增字段。name 和 email 为字符串类型，不允许为空，email 还是唯一的。createdAt 和 updatedAt 为日期类型，它们的默认值为当前时间。sequelize 参数是 Sequelize 实例，modelName 参数是模型名称。
连接数据库
在定义模型之后，我们需要连接到数据库中。可以使用以下方式连接到数据库：
sequelize.sync().then(() => {
console.log('Database and tables created!');
}).catch((error) => {
console.error('Error creating database and tables:', error);
});在上面的代码中，我们使用 sync() 方法创建表格，并在创建成功时打印一条消息。如果出现错误，将在控制台上输出错误信息。
增删改查
在定义模型并连接到数据库之后，我们可以使用 Sequelize 来执行增删改查操作。下面是一些常用的操作：
创建记录
User.create({
name: 'John Doe',
email: 'johndoe@example.com'
}).then((user) => {
console.log('User created:', user.toJSON());
}).catch((error) => {
console.error('Error creating user:', error);
});在上面的代码中，我们使用 create() 方法创建一个新的用户记录，并在创建成功时打印一条消息。如果出现错误，将在控制台上输出错误信息。
查询记录
User.findAll().then((users) => {
console.log('All users:', users.map((user) => user.toJSON()));
}).catch((error) => {
console.error('Error finding users:', error);
});在上面的代码中，我们使用 findAll() 方法查询所有用户记录，并在查询成功时打印一条消息。如果出现错误，将在控制台上输出错误信息。
更新记录
User.update({ name: 'Jane Doe' }, {
where: { name: 'John Doe' }
}).then((result) => {
console.log('Records updated:', result[0]);
}).catch((error) => {
console.error('Error updating records:', error);
});在上面的代码中，我们使用 update() 方法将名称为“John Doe”的用户记录更新为名称为“Jane Doe”的用户记录，并在更新成功时打印一条消息。如果出现错误，将在控制台上输出错误信息。
删除记录
User.destroy({
where: { name: 'Jane Doe' }
}).then((result) => {
console.log('Records deleted:', result);
}).catch((error) => {
console.error('Error deleting records:', error);
});在上面的代码中，我们使用 destroy() 方法删除名称为“Jane Doe”的用户记录，并在删除成功时打印一条消息。如果出现错误，将在控制台上输出错误信息。
总结
在本文中，我们介绍了如何在 Fastify 中使用 Sequelize 操作 MySQL 数据库。我们了解了如何创建 Sequelize 实例、定义模型、连接数据库以及执行增删改查操作。这些操作可以帮助开发人员轻松地操作数据库，并提高开发效率。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6639988fd3423812e47c3d6a