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() 我们的数据库表。

@@filename(database.providers)
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 定义了数据库中的一张表。该类的实例代表数据库中的一行记录。首先,我们至少需要一个实体:

@@filename(cat.entity)
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 提供者了:

@@filename(cats.providers)
import { Cat } from './cat.entity';

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

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

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

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

@@filename(cats.service)
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

@@filename(cats.module)
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