Как писать запросы PostgreSQL для Node.js

Введение

Если вы пишете RESTful api в Node.js, вам придется выбирать между реляционной базой данных или нереляционной базой данных. Если вы выбрали первое, вам нужно знать, как писать базовые запросы CRUD, чтобы ваш api мог осмысленно взаимодействовать с вашей базой данных. В этом блоге я собираюсь рассмотреть четыре основных запроса, которые вы можете использовать для создания RESTful api с использованием Node.js и PostgreSQL. Примечание. В этом блоге предполагается, что у вас уже установлены Node.js, PostgreSQL и pg.

Запрос на создание

Здесь мы создаем маршрут для обработки почтового запроса, в котором мы вставляем новые данные в таблицу с названием «todo». Мы создаем новую задачу, в которой наше описание совпадает с описанием, которое наш пользователь поместил в свой запрос. «$ 1» действует как заполнитель для переменной и позволяет нам вставлять любую переменную, которую мы хотим, в наш запрос. Обязательно напишите «ВОЗВРАЩЕНИЕ *», так как это единственный способ получить обратно информацию из запроса. Затем мы отправляем json-ответ с данными, которые мы только что обновили.

Код для создания

app.post("/todos", async (req, res) => {
try{
const {description} = req.body;
//This takes our description that we sent in and inserts into the todo table
const newTodo = await pool.query("INSERT INTO todo (description) VALUES ($1) RETURNING *", [description]);
res.json(newTodo.rows[0]);
} catch(error){
console.log(error.message)
}
});

Этот запрос намного проще. Мы берем идентификатор из params и выбираем все данные, которые имеют этот идентификатор. Затем мы отправляем ответ с этими данными.

Код для чтения

app.get("/todos/:id", async (req, res) => {
const { id } = req.params;
try {
const todo = await pool.query("SELECT * FROM todo WHERE todo_id = $1", [id]);
res.json(todo.rows[0]);
} catch (error){
console.log(error.message);
}
});

Здесь нам нужен идентификатор задачи, которую мы хотим обновить, и обновленное описание. Затем нам нужно обновить задачу с этим идентификатором и установить описание, равное нашему обновленному описанию. Снова не забудьте поставить RETURNING *, чтобы вернуть обновленные данные.

Код для обновления

app.delete("/todos/:id", async (req, res) => {
try {
const { id } = req.params;
const deleteTodo = await pool.query("DELETE FROM todo WHERE todo_id = $1", [id]);
res.status(500).json("Todo was deleted!")
} catch (error){
console.error(error.message);
}
});

Здесь нам просто нужен идентификатор задачи, которую мы хотим удалить, и удалить ее из таблицы. Здесь я просто отправляю сообщение в интерфейс, в котором говорится, что указанное задание было удалено.

Код для удаления

app.delete("/todos/:id", async (req, res) => {
try {
const { id } = req.params;
const deletedTodo = await pool.query("DELETE FROM todo WHERE todo_id = $1", [id]);
res.status(500).json("Todo was deleted!")
} catch (error){
console.error(error.message);
}
});

https://www.youtube.com/watch?v=_Mun4eOOf2Q