Description

Installation

    $ npm i --save nest-postgres pg

    $ yarn add nest-postgres pg

    $ pnpm add nest-postgres pg

Table of Contents

Usage

PostgresModule

@Module({imports:[PostgresModule.forRoot({connectionString:'postgresql://[user]:[password]@[host]/[nameDb]',// or// host: 'localhost',// database: [:databaseName],// password: [:passwordDb],// user: [:userDb],// port: 5432,}),],})

@Module({imports:[PostgresModule.forRootAsync({useFactory:()=>({connectionString:'postgresql://[user]:[password]@[host]/[nameDb]',// or// host: 'localhost',// database: [:databaseName],// password: [:passwordDb],// user: [:userDb],// port: 5432,}),}),],})

Example of use

import{Client}from'pg';import{InjectClient}from'nest-postgres';@Injectable()exportclassUsersService{constructor(@InjectClient()privatereadonlypg:Client){}publicasyncfindAll():Promise<User[]>{constusers=awaitthis.pg.query('SELECT * FROM users');returnusers.rows;}}

import{Controller,Get}from'@nestjs/common';import{UsersService}from'./users.service';@Controller()exportclassUsersController{constructor(privatereadonlyusersService:UsersService){}  @Get()asyncgetAllUsers():Promise<User[]>{returnawaitthis.usersService.findAll();}}

Multi Connections Database

@Module({imports:[PostgresModule.forRoot({connectionString:'postgresql://postgres:pass123@localhost:5432/nest1',// or// host: 'localhost',// database: [:databaseName],// password: [:passwordDb],// user: [:userDb],// port: 5432,},'db1Connection',),PostgresModule.forRoot({connectionString:'postgresql://postgres:pass123@localhost:5434/nest2',},'db2Connection',),],controllers:[],providers:[],})exportclassAppModule{}

import{Client}from'pg';import{InjectConnection}from'nest-postgres';import{CreatePostDto}from'./dto/create-post.dto';import{Post}from'./interfaces/post.interface';@Injectable()exportclassPostService{constructor(    @InjectConnection('db2Connection')privatedbConnection:Client,){}publicasyncfindAll():Promise<Post[]>{constusers=awaitthis.dbConnection.query('SELECT * FROM posts');returnusers.rows;}publicasynccreate(createPostDto:CreatePostDto):Promise<Post[]>{try{constuser=awaitthis.dbConnection.query('INSERT INTO posts (title, description)  VALUES ($1, $2) RETURNING *',[createPostDto.title,createPostDto.description],);returnuser.rows;}catch(err){thrownewHttpException(err,HttpStatus.BAD_REQUEST);}}}

import{Client}from'pg';import{InjectConnection}from'nest-postgres';import{CreateUserDto}from'./dto/create-user.dto';import{User}from'./interfaces/user.interface';@Injectable()exportclassUsersService{constructor(    @InjectConnection('db1Connection')privatedbConnection:Client,){}publicasyncfindAll():Promise<User[]>{constusers=awaitthis.dbConnection.query('SELECT * FROM users');returnusers.rows;}publicasynccreate(createUserDto:CreateUserDto):Promise<User[]>{try{constuser=awaitthis.dbConnection.query('INSERT INTO users (firstName, lastName)  VALUES ($1, $2) RETURNING *',[createUserDto.firstName,createUserDto.lastName],);returnuser.rows;}catch(err){thrownewHttpException(err,HttpStatus.BAD_REQUEST);}}}

Contribute

Stay in touch

License