1 安装依赖
typeorm 对 mysql 数据库版本有要求，需要5.6以上
npm install --save @nestjs/typeorm typeorm mysql
复制
2 导入TypeOrmModule
安装完成后我们在app.module导入TypeOrmModule，
import { Module } from '@nestjs/common'; import { AppController } from './app.controller'; import { AppService } from './app.service'; // 引入数据库的及配置文件 import { TypeOrmModule } from '@nestjs/typeorm'; import { Connection } from 'typeorm'; @Module({ imports: [ TypeOrmModule.forRoot({ type: 'mysql', host: '127.0.0.1', port: 3306, username: 'root', password: 'root', database: 'test', entities: [__dirname + '/**/*.entity{.ts,.js}'], synchronize: true, }) ], controllers: [AppController], providers: [AppService], }) export class AppModule { constructor(private readonly connection: Connection) {} }
复制
forRoot()方法接受与来自TypeORM包的createConnection()相同的配置对象。另外，我们可以创建ormconfig.json，这种方式创建的json文件，在测试过程中，运行报错，具体原因没有找到。
synchronize字段代表是否自动将实体类同步到数据库
3 编写功能模块
我们编写一个模块来测试。新建message文件夹，文件夹下有下面几个文件
message.entity.ts
import { Column, Entity, PrimaryGeneratedColumn, BaseEntity } from 'typeorm'; // 这里可以修改表名 @Entity() export class Message extends BaseEntity { @PrimaryGeneratedColumn() id: number; @Column('int', { name: 'user_id' }) userId: number; @Column('text', { name: 'content' }) content: string; @Column('int', { name: 'to_user_id' }) toUserId: number; @Column('datetime', { name: 'created_time' }) createdTime: Date; @Column('int') creator: number; @Column('datetime', { name: 'updated_time' }) updatedTime: Date; @Column('int') updator: number; }
复制
messages.service.ts
import { Injectable } from '@nestjs/common'; // import { Message } from './interfaces/message.interface'; // ORM import { InjectRepository } from '@nestjs/typeorm'; import { Repository } from 'typeorm'; import { Message } from './message.entity'; @Injectable() export class MessagesService { constructor( @InjectRepository(Message) private readonly messagesRepository: Repository<Message>, ) {} private readonly messages: Message[] = []; async findAll(): Promise<Message[]> { return await this.messagesRepository.find(); } }
复制
messages.module.ts
import { Module } from '@nestjs/common'; import { MessagesService } from './messages.service'; import { MessagesController } from './messages.controller'; import { TypeOrmModule } from '@nestjs/typeorm'; import { Message } from './message.entity'; @Module({ imports: [TypeOrmModule.forFeature([Message])], providers: [MessagesService], controllers: [MessagesController], }) export class MessagesModule {}
复制
messages.controller.ts
import { Controller, Post } from '@nestjs/common'; import { MessagesService } from './messages.service'; import { Message } from './message.entity'; @Controller('messages') export class MessagesController { constructor(private readonly messagesService: MessagesService) {} @Post() findAll(): Promise<Message[]> { return this.messagesService.findAll(); } }
复制
4 导入及运行
app.module.ts文件导入
// messages import { MessagesModule } from './messages/messages.module'; @Module({ imports: [ TypeOrmModule.forRoot({ type: 'mysql', host: '94.191.51.170', port: 3306, username: 'wangcong#2020', password: 'wangcong#2020', database: 'blog', entities: [__dirname + '/**/*.entity{.ts,.js}'], synchronize: true, }), MessagesModule, ], controllers: [AppController], providers: [AppService], }) export class AppModule { constructor(private readonly connection: Connection) {} }
复制
运行项目，用数据库管理工具连接我们的数据库，可以发现，已经自动创建表，我们随便加一条测试数据
网络异常，图片无法展示
|
我们用postman测试，可以返回我们加的测试数据。
