服务

  1. import { Injectable } from '@nestjs/common';
  2. import { InjectRepository } from "@nestjs/typeorm";
  3. import { Repository } from "typeorm";
  4. import { Mysql } from '../entity/mysql.entity';
  6. @Injectable()
  7. export class MysqldemoService {
  8.     constructor(
  9.         //  把实例 赋值给变量
  10.         @InjectRepository(Mysql)
  11.         private readonly mysqlRepository: Repository<Mysql>
  12.     ) { }
  13.     //  查找
  14.     findAll() {
  15.         return this.mysqlRepository.find()
  16.     }
  17.     //  增加
  18.     async add() {
  19.         const mysql = new Mysql()
  20.         mysql.name = 'daming';
  21.         mysql.age = 87;
  22.         return await this.mysqlRepository.save(mysql);
  23.     }
  24.     //  更新
  25.     async update() {
  26.         return this.mysqlRepository.update(
  27.             {name:"红"},
  28.             {age:99999}
  29.         )
  30.     }
  31.     //  删除
  32.     async delete(){
  33.         //  期待优雅的写法
  34.         const del = await this.mysqlRepository.findOne({name:"红"})
  35.        console.log(del);
  37.         return await this.mysqlRepository.remove(del)
  38.     }
  39. }

接口

  1. import { Controller, Get } from '@nestjs/common';
  2. import { MysqldemoService } from "./mysqldemo.service";
  3. @Controller('mysqldemo')
  4. export class MysqldemoController {
  5.     constructor(
  6.         private readonly mysqldemoService:MysqldemoService
  7.     ){}
  8.     @Get('find')
  9.     index(){
  10.         return this.mysqldemoService.findAll()
  11.     }
  13.     @Get('add')
  14.     async add(){
  15.         return await this.mysqldemoService.add()
  16.     }
  18.     @Get('update')
  19.     async update(){
  20.         return await this.mysqldemoService.update();
  21.     }
  23.     @Get('delete')
  24.     async delete(){
  25.         return await this.mysqldemoService.delete()
  26.     }
  27. }

操作差不多，可以使用.query直接操作mysql 语法