Как подождать, пока будет подключена База данных?

Question

[Карлиндоу Мэрлифи]

У меня есть файл с подключением к бд:

spoiler

import pg from 'pg'
export const pool = new pg.Pool({
    host: '',
    port: ,
    database: '',
    user: '',
    password: ''
})

pool.connect((err, client, release) => {
    if (err) {
        return console.error('Ошибка в запросе к БД (1)', err.stack)
    }
    client.query('SELECT NOW()', (err, result) => {
        release()
        if (err) {
            return console.error('Ошибка в запросе к БД (2)', err.stack)
        }
        console.log('\x1b[34m%s\x1b[0m',`PostgreSQL is running (${result.rows[0].now})`);
    })
})

А есть главный файл, где делаю так:

import { pool } from './postgresDB.js';
import express from 'express';

const app = express();
const ip = 'localhost';
const port = 3000;


app.get('/', (req, res) => {
    pool.query('SELECT * FROM users', (err, result) => {
        if (err) {
            res.status(500).send('Ошибка при получении данных из базы данных');
        } else {
            res.json(result.rows);
        }
    });
});

app.listen(port, ip, () => {
    console.log(`Сервер запущен на адресе ${ip} и порту ${port}`);
});

Хочу сделать, чтоб сервер подключался только после коннекта БД, перепробовал разные способы, но не смог

Comments

[Ivan Ustûžanin]

сервер подключался куда?

[Карлиндоу Мэрлифи]

IvanU7n, postgresql бд на убунте, вдска. сервер, работает, всё норм, просто мне надо сделать, чтоб код выполнялся только после его коннекта

[d'Ivan]

Карлиндоу Мэрлифи, в Docker или нет?

[Карлиндоу Мэрлифи]

Иерокопус Таманский, нет

Answer 1

[Kentavr16]

можно использовать что-то вроде

import express from "express";

const app = express();
const ip = "localhost";
const port = 4000;

app.get("/", (req, res) => {
  res.send("some response");
});

function startServer() {
  app.listen(port, ip, () => {
    console.log(`Сервер запущен на адресе ${ip} и порту ${port}`);
  });
}

async function connectToDatabase() {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve("ok"), 2000);
  });
}

connectToDatabase()
  .then(() => {
    startServer();
    console.log("Успешное подключение к базе данных.");
  })
  .catch((err) => {
    console.error("Не удалось подключиться к базе данных:", err);
  });

где для коннекта к бд использовать промис

export function connectToDatabase() {
    return new Promise((resolve, reject) => {
        pool.connect((err, client, release) => {
            if (err) {
                console.error('Ошибка в запросе к БД (1)', err.stack);
                release();
                reject(err);
                return;
            }

            client.query('SELECT NOW()', (err, result) => {
                release();
                if (err) {
                    console.error('Ошибка в запросе к БД (2)', err.stack);
                    reject(err);
                    return;
                }

                console.log('\x1b[34m%s\x1b[0m', `PostgreSQL is running (${result.rows[0].now})`);
                resolve(pool);
            });
        });
    });
}

Ну и пул объявить не забыть. Хз, с обычным промисом который в первом примере, работает окей, почему с подключением к бд будет иначе? Для эксперимента ставить pg неохота. Вполне возможно что я что-то проглядел, поправьте, с серверами на ноде давно не имел дела.

Answer 2

[d'Ivan]

Перед стартом приложения можно ожидать готовности СУБД, посредством проверки порта и, как только будет открыт - запускать приложение.

Добавлено
Или в цикле проверять соединение с СУБД при инициализации приложения. Однако, при этом подходе, добавляется лишний код для решения проблемы с инфраструктурой/окружением.

Answer 3

[ky0]

В docker-compose (к которому вы рано или поздно придёте) для этого существует depends_on. Проверять готовность постгреса лучше не тупо долбясь в порт, а с помощью pg_isready.

Comments

[d'Ivan]

Если не ошибаюсь, когда СУБД стартует, оно не сразу открывает порт. Так что полагаться лишь на зависимость от сервиса не достаточно.

[Карлиндоу Мэрлифи]

Иерокопус Таманский, оно всегда по-разному открывает порт, иногда очень быстро, а когда чуть дольше, хз почему

[d'Ivan]

Карлиндоу Мэрлифи, именно поэтому я дал свой ответ выше

[ky0]

Иерокопус Таманский, именно поэтому состояние сервиса лучше, как я и сказал, определять не долбясь в порт, а сделав локальный healthcheck с pg_isready:

service-db:
    healthcheck:
      test: ["CMD-SHELL", "pg_isready", "--quiet"]
      interval: 1s
      timeout: 5s
      retries: 10

  service:
    depends_on:
      service-db:
        condition: service_healthy

[Карлиндоу Мэрлифи]

ky0, благодарю за это, может и я начну докер использовать в скором

[d'Ivan]

ky0,

определять не долбясь в порт

ну, раз в секунду - это разве часто? Должно быть достаточно просто.
И Докер для этого не нужен. Есть даже такие инструменты в любом мейнстрим Линуксе.

[Kentavr16]

Иерокопус Таманский, а почему не подходят обычные средства типа завернуть в промис?

[d'Ivan]

Kentavr16, какую проблему должно решить использование промиса и каким образом? Можешь написать свой ответ на вопрос автора.

[Kentavr16]

Иерокопус Таманский, Спокойно. Я просто предположил что можно использовать что-то вроде

import express from "express";

const app = express();
const ip = "localhost";
const port = 4000;

app.get("/", (req, res) => {
  res.send("some response");
});

function startServer() {
  app.listen(port, ip, () => {
    console.log(`Сервер запущен на адресе ${ip} и порту ${port}`);
  });
}

async function connectToDatabase() {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve("ok"), 2000);
  });
}

connectToDatabase()
  .then(() => {
    startServer();
    console.log("Успешное подключение к базе данных.");
  })
  .catch((err) => {
    console.error("Не удалось подключиться к базе данных:", err);
  });

где для коннекта к бд использовать промис

export function connectToDatabase() {
    return new Promise((resolve, reject) => {
        pool.connect((err, client, release) => {
            if (err) {
                console.error('Ошибка в запросе к БД (1)', err.stack);
                release();
                reject(err);
                return;
            }

            client.query('SELECT NOW()', (err, result) => {
                release();
                if (err) {
                    console.error('Ошибка в запросе к БД (2)', err.stack);
                    reject(err);
                    return;
                }

                console.log('\x1b[34m%s\x1b[0m', `PostgreSQL is running (${result.rows[0].now})`);
                resolve(pool);
            });
        });
    });
}

Ну и пул объявить не забыть. Хз, с обычным промисом который в первом примере, работает окей, почему с подключением к бд будет иначе? Для эксперимента ставить pg неохота. Вполне возможно что я что-то проглядел, поправьте, с серверами на ноде давно не имел дела.

[Карлиндоу Мэрлифи]

Kentavr16, это похоже на то, что я хотел изначально,
я затестил и всё вроде как работает, но интересно почему
в консоль эта строчка не выводится

console.log('\x1b[34m%s\x1b[0m', `PostgreSQL is running (${result.rows[0].now})`);

[Карлиндоу Мэрлифи]

Карлиндоу Мэрлифи, понял,
нужно было удалить это из твоего кода

async function connectToDatabase() {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve("ok"), 2000);
  });
}

Спасибо!

[Kentavr16]

Карлиндоу Мэрлифи, да, первый кусок кода - это то что я писал в редакторе,просто пример с асинхронностью. Нужно тестировать, но думаю будет нормально работать.

[Карлиндоу Мэрлифи]

Kentavr16, напиши в ответах, я помечу, чтоб другие могли сразу найти, думаю многим понадобится

[Kentavr16]

Карлиндоу Мэрлифи, вопрос что это дает если можно ждать ответа бд и при работающем экспрессе? Какую именно проблему ты хотел решить/решил этим кодом? Очень частая ошибка новичка - x-y проблема, о формулировке которой я услышал тут же на форуме. Когда пытаешься решить задачу, которую по незнанию изначально сформировал неверно. Я постоянно наступаю на эти грабли.

[Карлиндоу Мэрлифи]

Kentavr16, потому что так правильно. Если сервер должен работать с базой данных, то недопустимо принимать запросы серверу, если база данных не подключена.