大前端nestjs入门教程系列(四):如何nestjs整合mysql数据库

经过前面的几篇文章，想必大家已经对nestjs有了基础的了解，那么这篇文章就带大家玩玩数据库，学会了这篇，就离大前端又进了一步

Nest与数据库无关，使你可以轻松地与任何 SQL 或 NoSQL 数据库集成。 根据你的喜好，你有多种选择。 在最一般的层面上，将 Nest 连接到数据库只是为数据库加载适当的 Node.js 驱动程序的问题，下面我们就学习下如何整合mysql数据库

为了与 SQL 和 NoSQL 数据库集成，Nest 提供了 @nestjs/typeorm 包。 TypeORM 是可用于 TypeScript 的最成熟的对象关系映射器 (ORM)。 由于它是用 TypeScript 编写的，因此可以很好地与 Nest 框架集成。

依赖的安装

npm install --save @nestjs/typeorm typeorm mysql2

安装完成后，我们在app.module.ts中引入mysql的配置

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';

@Module({
  imports: [
    TypeOrmModule.forRoot({
      type: 'mysql',
      host: 'localhost',
      port: 3306,
      username: 'root',  //改成自己账户
      password: 'root',  //改成自己密码
      database: 'test',  //改成自己的数据库
      entities: [],
      synchronize: true,
    }),
  ],
})
export class AppModule {}

创建实体类

这里的实体类就是java中的bean对象，了解java的不陌生，那么我们如何在这里定义呢？
user.entity.ts

import { Column, Entity, PrimaryGeneratedColumn } from "typeorm";

@Entity()
export class newUser{

  @PrimaryGeneratedColumn()
  id:number


  @Column("varchar",{length:8})
  firstName

  @Column()
  lastName:string

  @Column()
  age:number

}

创建user模块

users.module.ts

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { newUser } from './user.entity';
import { UsersController } from './users.controllers';
import { UsersService } from './users.service';

@Module({
  imports:[TypeOrmModule.forFeature([newUser])],  //引入了user实体
  providers:[UsersService],
  controllers:[UsersController]
})
export class UsersModule {}

创建provider服务

import { Injectable } from "@nestjs/common";
import { InjectRepository } from "@nestjs/typeorm";
import { newUser } from "./user.entity";
import { DeleteResult, Repository } from "typeorm";

@Injectable()
export class UsersService{
  constructor(
    @InjectRepository(newUser) private usersRepository:Repository<newUser>
  ){}
   //待完善的一系列操作数据库的方法
}

创建controller服务

import { Body, Controller, Delete, Get, Param, Post } from "@nestjs/common";
import { UsersService } from "./users.service";
import { User } from "./interface/users.interface";

@Controller("users")
export class UsersController{

  constructor(private usersService:UsersService){
     
  }
  @Get()
  getAllUsers(){
     return this.usersService.findAll()
  }

  @Get('/:id')
  getUserById(@Param('id') id:number){
    return this.usersService.getUserById(id)
  }

  @Delete("/:id")
  deleteById(@Param('id') id:number){
     return this.usersService.remove(id)
  }

  @Post('')
  addUserData(@Body() user:User){
      console.log(user,'add')
      return this.usersService.addUser(user)
  }
}

至此创建文件就结束了，此时我们可以到数据库看到多了一张表new_user

接下来我们就来进行数据的crud

增删改查

业务代码我们要写在service文件中

查：

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

如果里面没有任何数据，那么返回的就是空，这里我已经增加了相关数据，所以会有返回结果

增：

async addUser(user:newUser):Promise<string>{
  
    /**
     * 数据库里面找不到这个数据才新增
     */
    const isNotExist = (await this.usersRepository.find()).every(item => item.firstName != user.firstName && item.lastName != user.lastName)
    
    if(isNotExist){
      await this.usersRepository.save(user)
      console.log("🚀 ~ file: users.service.ts:28 ~ UsersService ~ addUser ~ data:",'ok')
      return "ok"
    }else{
      return "不允许重复添加数据"
    }
  }

这里是post请求，我们需要借助postman等来进行操作

非常好，我们成功新增了一条数据…

那如果我们增加一条已经存在的数据，那结果会怎样呢？我们可以试试，因为我这里是不允许重名的，所以无法新增成功，重名会报错，大家可以根据自己的实际业务需求进行操作

再次添加白眉鹰王，返回提示重复，数据库也没变化

删：

async remove(id:number):Promise<number>{
    const data = await this.usersRepository.delete(id)
    console.log(data,'delete-data')
    return data.affected;
}

根据id删了id为6的白眉，再次查询，数据库就少了这条数据,删除成功!!!

完整的代码如下

import { Injectable } from "@nestjs/common";
import { InjectRepository } from "@nestjs/typeorm";
import { newUser } from "./user.entity";
import { DeleteResult, Repository } from "typeorm";

@Injectable()
export class UsersService{
  constructor(
    @InjectRepository(newUser) private usersRepository:Repository<newUser>
  ){}

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

  getUserById(id:number):Promise<newUser | null>{
      return this.usersRepository.findOneBy({id})
  }

  async remove(id:number):Promise<number>{
    const data = await this.usersRepository.delete(id)
    console.log(data,'delete-data')
    return data.affected;
  }

  async addUser(user:newUser):Promise<string>{
  
    /**
     * 数据库里面找不到这个数据才新增
     */
    const isNotExist = (await this.usersRepository.find()).every(item => item.firstName != user.firstName && item.lastName != user.lastName)
    
    if(isNotExist){
      await this.usersRepository.save(user)
      console.log("🚀 ~ file: users.service.ts:28 ~ UsersService ~ addUser ~ data:",'ok')
      return "ok"
    }else{
      return "不允许重复添加数据"
    }
  }
}

这样我们就实现了，nestjs整合mysql数据库，实现数据crud了，以后再也不用让求着让后端帮忙改接口了…

更多后续精彩内容，请关注本系列的动态