Aún no tienes acceso a esta clase

Crea una cuenta y continúa viendo este curso

Conexión como inyectable y ejecutando un SELECT

7/33
Recursos
// src/database/database.module.ts

import { Client } from 'pg';

const client = new Client({  // 👈 client
  user: 'root',
  host: 'localhost',
  database: 'my_db',
  password: '123456',
  port: 5432,
});

client.connect();
..

@Global()
@Module({
  providers: [
    ...
    {
      provide: 'PG',
      useValue: client, // 👈 provider as value
    },
  ],
  exports: ['API_KEY', 'PG'], // 👈 add in exports
})
export class DatabaseModule {}
// src/app.service.ts

import { Client } from 'pg';


@Injectable()
export class AppService {
  constructor(
    @Inject('PG') private clientPg: Client, // 👈 inject PG
    ...
  ) {}

  getTasks() { // 👈 new method
    return new Promise((resolve, reject) => {
      this.clientPg.query('SELECT * FROM tasks', (err, res) => {
        if (err) {
          reject(err);
        }
        resolve(res.rows);
      });
    });
  }
}
// src/app.controller.ts

@Controller()
export class AppController {

  @Get('tasks') // 👈 new endpoint
  tasks() {
    return this.appService.getTasks();
  }
}

Aportes 4

Preguntas 6

Ordenar por:

¿Quieres ver más aportes, preguntas y respuestas de la comunidad? Crea una cuenta o inicia sesión.

Quienes trabajen con múltiples motores de bases de datos relacionales, les recomiendo sequelize. Lo utilizo desde hace tiempo y la verdad funciona muy bien.

Esto es una mala practica la verdad me parece… Lo mejor es colocarlo en useFactory y poder usarlo desde cada repository conectado a su identity correspondiente que es en sí una table de la db conectada.

¿Han probado Prisma ORM? ¿Que tal?

👏