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

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;
}

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 {}

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');
    }
}

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();
    }
}

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 {}

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

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