database.service.ts import { Injectable } from `@nestjs/common`; import { Pool } from `pg`; @Injectable() export class DatabaseService { private client: Pool; constructor() { this.client = new Pool({ host: `localhost`, port: 5432, user: `felixolszewski`, database: `postgres`, }); } async query(text: string, params?: any[]) { return this.client.query(text, params); } async getAllDepartment() { const queryResult = await this.query(`SELECT * FROM department`); return queryResult.rows } async getDepartment(name: string) { const queryResult = await this.query(`SELECT * FROM department WHERE name = $1`, [name]); return queryResult.rows } async getAllEmployeesByDepartment(id: string) { console.log(id); const queryResult = await this.query(`SELECT * FROM employee WHERE departmentid = $1`, [id]); return queryResult.rows } } database.service.ts import { Injectable } from `@nestjs/common`; import { Pool } from `pg`; @Injectable() export class DatabaseService { private client: Pool; constructor() { this.client = new Pool({ host: `localhost`, port: 5432, user: `felixolszewski`, database: `postgres`, }); } async query(text: string, params?: any[]) { return this.client.query(text, params); } async getAllDepartment() { const queryResult = await this.query(`SELECT * FROM department`); return queryResult.rows } async getDepartment(name: string) { const queryResult = await this.query(`SELECT * FROM department WHERE name = $1`, [name]); return queryResult.rows } async getAllEmployeesByDepartment(id: string) { console.log(id); const queryResult = await this.query(`SELECT * FROM employee WHERE departmentid = $1`, [id]); return queryResult.rows } } database.service.ts import { Injectable } from `@nestjs/common`; import { Pool } from `pg`; @Injectable() export class DatabaseService { private client: Pool; constructor() { this.client = new Pool({ host: `localhost`, port: 5432, user: `felixolszewski`, database: `postgres`, }); } async query(text: string, params?: any[]) { return this.client.query(text, params); } async getAllDepartment() { const queryResult = await this.query(`SELECT * FROM department`); return queryResult.rows } async getDepartment(name: string) { const queryResult = await this.query(`SELECT * FROM department WHERE name = $1`, [name]); return queryResult.rows } async getAllEmployeesByDepartment(id: string) { console.log(id); const queryResult = await this.query(`SELECT * FROM employee WHERE departmentid = $1`, [id]); return queryResult.rows } }
©