NestJS：TypeORM 连接mysql数据库，增删改查

一、安装数据库相关模块

pnpm add @nestjs/typeorm typeorm mysql

package.json 

二、navicat创建nestjs_base数据库，创建products数据表，添加记录

创建nestjs数据库，创建products数据表

navicat：连接MySQL，创建库、表_snow@li的博客-CSDN博客

products表添加记录

mysql：使用终端操作数据库_snow@li的博客-CSDN博客

三、src/entities/products.entity.ts 创建实体

import { Column, Entity, PrimaryGeneratedColumn, BaseEntity } from 'typeorm';// Column：列/字段
// Entity：实体
// PrimaryGeneratedColumn：创建一个主列，该值将使用自动增量值自动生成。 它将使用auto-increment /serial /sequence创建int列（取决于数据库）。 你不必在保存之前手动分配其值，该值将会自动生成。
// BaseEntity：继承基础实体类@Entity()
// Products需要与数据表同名
export class Products extends BaseEntity {@PrimaryGeneratedColumn()id: number;@Column({type:'varchar', name: 'name'})name: string;@Column({type:'varchar', name: 'type'})type: string;
}

四、src/app.module.ts 连接数据库 nestjs_base

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { ProductsModule } from './products/products.module';@Module({imports: [TypeOrmModule.forRoot({ // 连接数据库type: 'mysql', // 数据库类型host: 'localhost', // 数据库ip地址port: 3306, // 端口username: 'root', // 登录名password: 'snowball', // 密码database: 'nestjs_base', // 数据库名称entities: [__dirname + '//*.entity{.ts,.js}'], // 扫描本项目中.entity.ts或者.entity.js的文件synchronize: true, // 定义数据库表结构与实体类字段同步(这里一旦数据库少了字段就会自动加入,根据需要来使用)}),ProductsModule // 加载子模块],controllers: [],providers: [],
})
export class AppModule {}

五、src/products/products.service.ts

import { Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { Products } from '../entities/products.entity';@Injectable()
export class ProductsService {// 使用InjectRepository装饰器并引入Repository即可使用typeorm的操作constructor(@InjectRepository(Products)private readonly productsRepository: Repository<Products>,) { }// 查询数据库产品数据// 获取所有用户数据列表(productsRepository.query()方法属于typeoram)async getList(): Promise<Products[]> {return await this.productsRepository.query('select * from products');}
}

五、src/products/products.controller.ts

import { Controller, Get, Post, Request, Query, Body, Param } from '@nestjs/common';
import { ProductsService } from './products.service';
import { Products } from '../entities/products.entity';@Controller('products')
export class ProductsController {// this.productsService = new ProductsService() 等价于 constructor 方式constructor(private productsService: ProductsService){}// 通过数据库查询产品list@Get('list')getList(): Promise<Products[]> {return this.productsService.getList();}
}

六、src/products/products.module.ts

import { Module } from '@nestjs/common';
import { ProductsController } from './products.controller';
import { ProductsService } from './products.service';
import { TypeOrmModule } from '@nestjs/typeorm';
import { Products } from '../entities/products.entity';@Module({imports:[TypeOrmModule.forFeature([Products])], // 导入并注册实体controllers: [ProductsController],providers: [ProductsService]
})
export class ProductsModule {}

七、访问接口地址

7.1、RESTClient访问接口地址，访问成功

7.2、浏览器地址访问，访问成功。

八、nestjs数据库products数据表，增删改查数据

8.1、src/products/products.service.ts

import { Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { Products } from '../entities/products.entity';@Injectable()
export class ProductsService {// 使用InjectRepository装饰器并引入Repository即可使用typeorm的操作constructor(@InjectRepository(Products)private readonly productsRepository: Repository<Products>,) { }// 查询数据库产品数据// 获取所有用户数据列表(productsRepository.query()方法属于typeoram)async getList(): Promise<Products[]> {return await this.productsRepository.query('select * from products');}// 通过id查询产品async getProductById(id): Promise<Products> {return await this.productsRepository.findOne({where:{id: id}});}// 新增产品async addProduct(product): Promise<any> {return await this.productsRepository.insert(product);}// 更新产品async updateProduct(product): Promise<string> {let res = await this.productsRepository.update({ id: product.id }, product);if(res){return "更新成功"} else {return "更新失败"}}// 删除产品async delProduct(params): Promise<object> {let res = await this.productsRepository.delete({ id: params.id });if(res){return {code: 0,data: "",msg: "删除成功"}} else {return {code: 0,data: "",msg: "删除失败"}}}
}

8.2、src/products/products.controller.ts

import { Controller, Get, Post, Request, Query, Body, Param } from '@nestjs/common';
import { ProductsService } from './products.service';
import { Products } from '../entities/products.entity';@Controller('products')
export class ProductsController {// this.productsService = new ProductsService() 等价于 constructor 方式constructor(private productsService: ProductsService){}// 通过数据库查询产品list@Get('list')getList(): Promise<Products[]> {return this.productsService.getList();}// 通过id查询产品@Get('getProductById')getProductById(@Query() query): Promise<Products> {let id:number = parseInt(query.id)return this.productsService.getProductById(id);}// 增加产品@Post('addProduct')addProduct(@Body() body): Promise<Products> {return this.productsService.addProduct(body);}// 更新产品@Post('updateProduct')updateProduct(@Body() body): Promise<string> {return this.productsService.updateProduct(body);}// 删除产品@Post('delProduct')delProduct(@Body() body): Promise<object> {return this.productsService.delProduct(body);}
}

8.3、测试：

通过id查询产品

新增产品

更新产品

删除产品

九、欢迎交流指正，关注我，一起学习。

参考链接

实体 | TypeORM 中文文档 | TypeORM 中文网

NestJS：orm工具简介

nestjs[连接mysql数据库]_nestjs mysql_墨水白云的博客-CSDN博客

nestjs[typeorm学习之基本的增删查改操作]_typeorm delete_墨水白云的博客-CSDN博客