72 lines
2.2 KiB
TypeScript
72 lines
2.2 KiB
TypeScript
import { IIngredient } from "../schemas";
|
|
import pool from "../db";
|
|
import now from "../util/now";
|
|
|
|
export class Ingredient {
|
|
async getAll() {
|
|
try {
|
|
const statement = `SELECT * FROM recipin.ingredient`;
|
|
const result = await pool.query(statement);
|
|
if (result.rows.length) return result.rows;
|
|
return null;
|
|
} catch (e: any) {
|
|
throw new Error(e);
|
|
}
|
|
}
|
|
|
|
async getOne(id: string) {
|
|
try {
|
|
const statement = `SELECT * FROM recipin.ingredient WHERE id = $1`;
|
|
const result = await pool.query(statement, [id]);
|
|
if (result.rows.length) return result.rows[0];
|
|
return null;
|
|
} catch (e: any) {
|
|
throw new Error(e);
|
|
}
|
|
}
|
|
|
|
async getAllForRecipe(recipeid: string) {
|
|
try {
|
|
const statement = `SELECT * FROM recipin.cmp_recipeingredient WHERE recipeid = $1`;
|
|
const result = await pool.query(statement, [recipeid]);
|
|
if (result.rows.length) return result.rows[0];
|
|
return null;
|
|
} catch (e: any) {
|
|
throw new Error(e);
|
|
}
|
|
}
|
|
|
|
async post(data: IIngredient) {
|
|
try {
|
|
const statement = `
|
|
INSERT INTO recipin.ingredient
|
|
(name, description, datecreated)
|
|
VALUES ($1, $2, $3) RETURNING *`;
|
|
const values = [data.name, data.description, data.datecreated || now];
|
|
const result = await pool.query(statement, values);
|
|
if (result.rows.length) return result.rows[0];
|
|
return null;
|
|
} catch (e: any) {
|
|
throw new Error(e);
|
|
}
|
|
}
|
|
|
|
async put(id: string, data: IIngredient) {
|
|
try {
|
|
const statement = `
|
|
UPDATE recipin.ingredient
|
|
SET name = $1,
|
|
description = $2
|
|
WHERE id = $3
|
|
RETURNING *
|
|
`
|
|
|
|
const values = [data.name, data.description, id];
|
|
const result = await pool.query(statement, values);
|
|
if (result.rows.length) return result.rows[0];
|
|
return null;
|
|
} catch (e: any) {
|
|
throw new Error(e);
|
|
}
|
|
}
|
|
} |