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

怼烎@ 2024-03-23 13:04 88阅读 0赞

**一、安装数据库相关模块**

> pnpm add @nestjs/typeorm typeorm mysql

package.json

![36c30b1b7ce1452793575b098da307bb.png][]

**二、navicat创建nestjs\_base数据库，创建products数据表，添加记录**

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

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

products表添加记录

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

![dff7e0ba504b40d0858b27d8812168cc.png][]

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

![6c80cf4ce9584eb6a206b3abe9269e4f.png][]

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**

**六、src/products/products.controller.ts**

**七、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访问接口地址，访问成功**

![53e8ffedb53543799221fb60c8885416.png][]

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

![218b04c0e12f4ae88b3dc086b2275375.png][]

**九、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);
        }
    }

**9.3、测试：**

通过id查询产品

![8895f185591743509631ecc8c190e27c.png][]

新增产品

![5fadded206514562a714609901041800.png][]

更新产品

![a9a769e7efc14dc7be1e4d1d6e542140.png][]

删除产品

![bb05effbfe674f12928b2d38bb280e45.png][]

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

**参考链接**

[实体 | TypeORM 中文文档 | TypeORM 中文网][_ TypeORM _ _ TypeORM]

[NestJS：orm工具简介][NestJS_orm]

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

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

[36c30b1b7ce1452793575b098da307bb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/87d5e809b9924275a445549de329cba9.png
[navicat_MySQL_snow_li_-CSDN]: https://blog.csdn.net/snowball_li/article/details/121676476
[mysql_snow_li_-CSDN]: https://blog.csdn.net/snowball_li/article/details/121666670
[dff7e0ba504b40d0858b27d8812168cc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/c4395aef145e4be6b562726b878baba0.png
[6c80cf4ce9584eb6a206b3abe9269e4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/e679f55d21644ff3927e4d411fd869b5.png
[53e8ffedb53543799221fb60c8885416.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/032f4f08768445f6813bd96a32e343b1.png
[218b04c0e12f4ae88b3dc086b2275375.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/e747d46fe1d140558a4f188888f5f20d.png
[8895f185591743509631ecc8c190e27c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/ce9366971f9b468a9d9dd2baf16a8c00.png
[5fadded206514562a714609901041800.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/2f46383166394b52b503be9d3109bf3f.png
[a9a769e7efc14dc7be1e4d1d6e542140.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/e2d3fa97a4cb4e13bdf6857fcaaeeb9a.png
[bb05effbfe674f12928b2d38bb280e45.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/7e74941835e54e6c8aaf5dc1a9374573.png
[_ TypeORM _ _ TypeORM]: https://typeorm.devjs.cn/entities
[NestJS_orm]: https://mp.csdn.net/mp_blog/creation/editor/130153316
[nestjs_mysql_nestjs mysql_-CSDN]: https://blog.csdn.net/lxy869718069/article/details/103408695?spm=1001.2101.3001.6650.7&utm_medium=distribute.pc_relevant.none-task-blog-2~default~BlogCommendFromBaidu~Rate-7-103408695-blog-125324022.235%5Ev29%5Epc_relevant_default_base3&depth_1-utm_source=distribute.pc_relevant.none-task-blog-2~default~BlogCommendFromBaidu~Rate-7-103408695-blog-125324022.235%5Ev29%5Epc_relevant_default_base3&utm_relevant_index=12
[nestjs_typeorm_typeorm delete_-CSDN]: https://blog.csdn.net/lxy869718069/article/details/110128030