NestJS：TypeORM 连接mysql数据库，增删改查-阿里云开发者社区

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

2023-07-10 243

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

RDS MySQL Serverless 高可用系列，价值2615元额度，1个月

简介： 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 {}

八、访问接口地址

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

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

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

9.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: "删除失败"
            }
        }
    }
}

9.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);
    }
}