NestJS：从入门到精通数据库操作

2023-08-23 22:41:36

NestJS 和 TypeORM：打造强大的数据库操作解决方案

在后端开发的世界中，数据库操作至关重要。对于 Node.js 开发人员而言，NestJS 和 TypeORM 是备受推崇的技术组合，可大幅增强数据库操作体验。

什么是 NestJS？

NestJS 是一款基于 TypeScript 的框架，以其简洁、高效和高度可扩展性而著称。它采用模块化设计，让开发者能够轻松构建复杂的应用程序，并轻松集成各种第三方库。

什么是 TypeORM？

TypeORM 是一款出色的对象关系映射工具（ORM），它为 Node.js 和 JavaScript 提供了全面的数据库操作功能。它支持各种关系型数据库，例如 MySQL、PostgreSQL 和 Oracle，并简化了复杂的查询和数据建模。

NestJS 和 TypeORM 集成

将 TypeORM 集成到 NestJS 应用程序中非常简单。首先，安装必要的依赖项，包括 NestJS CLI 和 TypeORM。然后，创建一个新的 NestJS 项目并选择 TypeORM 作为数据库驱动程序。

接下来，配置 ormconfig.json 文件以指定您的数据库设置，例如主机、端口、用户名、密码和数据库名称。

数据建模

使用 TypeORM，您可以轻松定义实体并建立它们之间的关系。实体表示数据库中的表，而实体中的属性对应于表的列。使用 TypeORM 注解，您可以定义属性的类型、是否为主键，以及其他约束。

数据操作

TypeORM 提供了一系列方法用于执行 CRUD（创建、读取、更新和删除）操作。您可以使用 Repository 类来查找、保存、更新和删除实体，也可以使用原生的 SQL 查询来执行更复杂的查询。

使用 NestJS 扩展 TypeORM

NestJS 提供了强大的中间件、守卫、管道、异常过滤器和拦截器机制，可用于增强 TypeORM 的功能。这些机制使您可以执行各种任务，例如：

中间件：在请求处理之前或之后执行操作，例如日志记录或身份验证。
守卫：控制对特定路由的访问权限，确保只有授权用户才能访问敏感数据。
管道：转换请求或响应的数据，例如将 JSON 数据转换为 JavaScript 对象。
异常过滤器：捕获和处理异常，并返回友好的响应。
拦截器：拦截和修改请求或响应，例如添加 CORS 头或记录请求处理时间。

代码示例

// users.controller.ts
import { Controller, Get, Post, Body, Delete, Param } from "@nestjs/common";
import { UsersService } from "./users.service";
import { User } from "./entities/user.entity";

@Controller("users")
export class UsersController {
  constructor(private readonly usersService: UsersService) {}

  @Get()
  findAll(): Promise<User[]> {
    return this.usersService.findAll();
  }

  @Post()
  create(@Body() user: User): Promise<User> {
    return this.usersService.create(user);
  }

  @Delete(":id")
  remove(@Param("id") id: string): Promise<void> {
    return this.usersService.remove(id);
  }
}

// users.service.ts
import { Injectable } from "@nestjs/common";
import { InjectRepository } from "@nestjs/typeorm";
import { Repository } from "typeorm";
import { User } from "./entities/user.entity";

@Injectable()
export class UsersService {
  constructor(
    @InjectRepository(User)
    private readonly userRepository: Repository<User>
  ) {}

  findAll(): Promise<User[]> {
    return this.userRepository.find();
  }

  create(user: User): Promise<User> {
    return this.userRepository.save(user);
  }

  remove(id: string): Promise<void> {
    return this.userRepository.delete(id);
  }
}