Nest.js如何连接数据库？附详细步骤及代码实现

2023-10-27 09:04:48

使用Nest.js连接数据库

Nest.js是一个流行的Node.js框架，它提供了许多功能来帮助你快速开发Web应用程序。其中一个功能就是数据库连接。Nest.js支持连接多种数据库，包括MySQL、PostgreSQL、MongoDB等。

步骤1：安装依赖

首先，你需要安装Nest.js的数据库连接库。你可以使用以下命令安装它：

npm install @nestjs/typeorm

步骤2：配置数据库连接

接下来，你需要在你的Nest.js应用程序中配置数据库连接。你可以通过在src/app.module.ts文件中添加以下代码来做到这一点：

import { Module } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';

@Module({
  imports: [
    TypeOrmModule.forRoot({
      type: 'mysql',
      host: 'localhost',
      port: 3306,
      username: 'root',
      password: 'password',
      database: 'nest',
      entities: [User],
      synchronize: true,
    }),
  ],
})
export class AppModule {}

这段代码将使用TypeORM连接到MySQL数据库。你可以根据你的实际情况修改数据库类型、主机、端口、用户名、密码和数据库名称。

步骤3：创建实体类

接下来，你需要创建一个实体类来表示你的数据库表。你可以通过在src/entities/user.ts文件中添加以下代码来做到这一点：

import { Entity, PrimaryGeneratedColumn, Column } from 'typeorm';

@Entity()
export class User {
  @PrimaryGeneratedColumn()
  id: number;

  @Column()
  name: string;

  @Column()
  email: string;
}

这段代码将创建一个名为User的实体类，它包含三个属性：id、name和email。

步骤4：添加数据

现在，你可以使用TypeORM向数据库中添加数据。你可以通过在src/app.controller.ts文件中添加以下代码来做到这一点：

import { Controller, Post, Body } from '@nestjs/common';
import { CreateUserDto } from './dto/create-user.dto';
import { UserService } from './user.service';

@Controller('users')
export class UserController {
  constructor(private readonly userService: UserService) {}

  @Post()
  async create(@Body() createUserDto: CreateUserDto) {
    return await this.userService.create(createUserDto);
  }
}

这段代码将创建一个新的用户控制器，它包含一个create()方法，该方法将使用UserService创建一个新的用户。

步骤5：查询数据

最后，你可以使用TypeORM从数据库中查询数据。你可以通过在src/app.service.ts文件中添加以下代码来做到这一点：

import { Injectable } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { User } from './entities/user.ts';

@Injectable()
export class UserService {
  constructor(
    @InjectRepository(User)
    private readonly userRepository: Repository<User>,
  ) {}

  async create(createUserDto: CreateUserDto): Promise<User> {
    const user = new User();
    user.name = createUserDto.name;
    user.email = createUserDto.email;
    return await this.userRepository.save(user);
  }

  async findAll(): Promise<User[]> {
    return await this.userRepository.find();
  }
}