logologo
文档仓库
文档仓库
logologo
开始

概述

第一步
控制器
提供者
模块
中间件
异常过滤器
管道
守卫
拦截器
自定义装饰器

基础

自定义提供程序
异步提供者
动态模块
注入作用域
循环依赖
模块引用
懒加载模块
执行上下文
生命周期事件
发现服务
平台无关
单元测试

技术

配置
SQL
Mongo
验证
缓存
序列化
版本控制
任务调度
队列
日志
Cookies
事件
压缩
文件上传
文件流
HTTP 模块
Session
MVC
性能(Fastify)
SSE

安全

认证
授权
加密与哈希
Helmet
CORS
CSRF
速率限制

GraphQL

快速开始
解析器
变更
订阅
标量
指令
接口
联合与枚举
字段中间件
类型映射
插件
复杂度
扩展
CLI 插件
生成SDL
共享模型
其他功能
联邦

WebSocket

网关
异常过滤器
管道
守卫
拦截器
适配器

微服务

基础
Redis
MQTT
NATS
RabbitMQ
Kafka
gRPC
自定义传输
异常过滤器
管道
守卫
拦截器
部署
独立应用程序

CLI

概述
工作区
库
用法
脚本

OpenAPI

介绍
装饰器
类型映射
操作
其他特性
安全
类型与参数
CLI 插件

实用示例

REPL
CRUD生成器
SWC
Passport(认证)
热重载
MikroORM
TypeORM
Mongoose
Sequelize
路由模块
Swagger
健康检查
CQRS
Compodoc
Prisma
Sentry
静态资源
Commander
异步本地存储
Necord
套件(原Automock)

常见问题

Serverless
HTTP 适配器
长连接
全局前缀
原始请求体
混合应用
HTTPS & 多服务器
请求生命周期
错误

开发工具

概述
CI/CD
迁移指南
API参考(官方)

生态与案例

谁在用
精彩资源

支持

支持

社区

贡献者

最后更新于: 2025/11/18 02:11:37

上一页Mongoose
下一页路由模块

#SQL (Sequelize)

#本章仅适用于 TypeScript
警告

本文中,您将学习如何基于 Sequelize 包使用自定义组件从零开始创建 DatabaseModule。因此,该技术包含许多额外工作,您可以通过使用开箱即用的专用 @nestjs/sequelize 包来避免。了解更多信息,请参阅此处 。

Sequelize 是一个用原生 JavaScript 编写的流行对象关系映射器(ORM),但有一个 sequelize-typescript TypeScript 包装器,为基础 sequelize 提供了一系列装饰器和其他附加功能。

#快速开始

要开始使用这个库的冒险之旅,我们需要先安装以下依赖项:

$ npm install --save sequelize sequelize-typescript mysql2
$ npm install --save-dev @types/sequelize

第一步是创建一个带有选项对象的 Sequelize 实例,并将其传入构造函数。此外,我们需要添加所有模型(另一种方法是使用 modelPaths 属性)并 sync() 我们的数据库表。

database.providers.ts
import { Sequelize } from 'sequelize-typescript';
import { Cat } from '../cats/cat.entity';

export const databaseProviders = [
 {
   provide: 'SEQUELIZE',
   useFactory: async () => {
     const sequelize = new Sequelize({
       dialect: 'mysql',
       host: 'localhost',
       port: 3306,
       username: 'root',
       password: 'password',
       database: 'nest',
     });
     sequelize.addModels([Cat]);
     await sequelize.sync();
     return sequelize;
   },
 },
];
提示

遵循最佳实践,我们在单独的文件中声明了自定义提供者,该文件具有 *.providers.ts 后缀。

然后,我们需要导出这些提供者,使它们对应用程序的其余部分可访问 。

import { Module } from '@nestjs/common';
import { databaseProviders } from './database.providers';

@Module({
  providers: [...databaseProviders],
  exports: [...databaseProviders],
})
export class DatabaseModule {}

现在我们可以使用 @Inject() 装饰器注入 Sequelize 对象。每个依赖 Sequelize 异步提供者的类都将等待 Promise 解析完成。

#模型注入

在 Sequelize 中,Model 定义了数据库中的一张表。该类的实例代表数据库中的一行记录。首先,我们至少需要一个实体:

cat.entity.ts
import { Table, Column, Model } from 'sequelize-typescript';

@Table
export class Cat extends Model {
 @Column
 name: string;

 @Column
 age: number;

 @Column
 breed: string;
}

Cat 实体属于 cats 目录,该目录代表 CatsModule 模块。现在该创建一个 Repository 提供者了:

cats.providers.ts
import { Cat } from './cat.entity';

export const catsProviders = [
 {
   provide: 'CATS_REPOSITORY',
   useValue: Cat,
 },
];
注意

在实际应用中应避免使用 魔法字符串 。建议将 CATS_REPOSITORY 和 SEQUELIZE 都存放在独立的 constants.ts 文件中。

在 Sequelize 中,我们使用静态方法来操作数据,因此这里创建了一个别名 。

现在我们可以通过 @Inject() 装饰器将 CATS_REPOSITORY 注入到 CatsService 中:

cats.service.ts
import { Injectable, Inject } from '@nestjs/common';
import { CreateCatDto } from './dto/create-cat.dto';
import { Cat } from './cat.entity';

@Injectable()
export class CatsService {
 constructor(
   @Inject('CATS_REPOSITORY')
   private catsRepository: typeof Cat
 ) {}

 async findAll(): Promise<Cat[]> {
   return this.catsRepository.findAll<Cat>();
 }
}

数据库连接是异步的 ,但 Nest 使这个过程对终端用户完全透明。CATS_REPOSITORY 提供者会等待数据库连接完成,而 CatsService 会延迟到存储库准备就绪。整个应用会在所有类实例化完成后启动。

以下是最终的 CatsModule:

cats.module.ts
import { Module } from '@nestjs/common';
import { CatsController } from './cats.controller';
import { CatsService } from './cats.service';
import { catsProviders } from './cats.providers';
import { DatabaseModule } from '../database/database.module';

@Module({
 imports: [DatabaseModule],
 controllers: [CatsController],
 providers: [
   CatsService,
   ...catsProviders,
 ],
})
export class CatsModule {}
提示

不要忘记将 CatsModule 导入根模块 AppModule。