大前端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 "不允许重复添加数据"}}
}