Керування з’єднаннями з базою даних

npm install pg

const { Pool } = require('pg');

const pool = new Pool({
  host: 'localhost',
  port: 5432,
  database: 'app_db',
  user: 'app_user',
  password: 'secret',
  max: 10
});

const { Pool } = require('pg');

const pool = new Pool({
  connectionString: process.env.DATABASE_URL,
  max: 10
});

postgresql://app_user:secret@localhost:5432/app_db

const { Pool } = require('pg');

const pool = new Pool({
  connectionString: process.env.DATABASE_URL
});

async function checkDatabaseConnection() {
  try {
    const result = await pool.query('SELECT 1 AS connected');

    console.log('База даних доступна:', result.rows[0]);
  } catch (error) {
    console.error('Не вдалося підключитися до бази даних:', error.message);
  }
}

checkDatabaseConnection();

База даних доступна: { connected: 1 }

const result = await pool.query(
  'SELECT id, name FROM users WHERE email = $1',
  [email]
);

// Небезпечно: значення вставляється безпосередньо в SQL
const query = `SELECT * FROM users WHERE email = '${email}'`;

// Безпечно: значення передається окремо від SQL-запиту
const result = await pool.query(
  'SELECT * FROM users WHERE email = $1',
  [email]
);

const client = await pool.connect();

try {
  const result = await client.query('SELECT NOW() AS current_time');

  console.log(result.rows[0]);
} catch (error) {
  console.error('Помилка запиту:', error.message);
} finally {
  client.release();
}

const client = await pool.connect();

const result = await client.query('SELECT NOW()');
console.log(result.rows[0]);

// З'єднання не повернуто до пулу

const client = await pool.connect();

try {
  const result = await client.query('SELECT NOW()');

  console.log(result.rows[0]);
} finally {
  client.release();
}

let client;

try {
  client = await pool.connect();

  await client.query('SELECT NOW()');
} catch (error) {
  console.error('Помилка роботи з базою:', error.message);
} finally {
  if (client) {
    client.release();
  }
}

await pool.end();

process.on('SIGINT', shutdown);
process.on('SIGTERM', shutdown);

const { Pool } = require('pg');

const pool = new Pool({
  connectionString: process.env.DATABASE_URL || 'postgresql://app_user:secret@localhost:5432/app_db',
  max: 10
});

async function checkDatabase() {
  const result = await pool.query('SELECT 1 AS connected');

  console.log('З’єднання з базою перевірено:', result.rows[0]);
}

async function getUsers() {
  const result = await pool.query(
    'SELECT id, name FROM users ORDER BY id'
  );

  return result.rows;
}

async function shutdown(signal) {
  console.log(`Отримано сигнал ${signal}. Завершення роботи...`);

  try {
    await pool.end();

    console.log('Пул з’єднань закрито.');
    process.exit(0);
  } catch (error) {
    console.error('Помилка під час закриття пулу:', error.message);
    process.exit(1);
  }
}

async function main() {
  try {
    await checkDatabase();

    const users = await getUsers();
    console.log('Користувачі:', users);
  } catch (error) {
    console.error('Помилка роботи із базою даних:', error.message);

    // Закриваємо пул, якщо застосунок не може продовжити роботу
    await pool.end();
    process.exit(1);
  }
}

process.on('SIGINT', shutdown);
process.on('SIGTERM', shutdown);

main();

const client = await pool.connect();

try {
  await client.query('SELECT 1');
} finally {
  client.release();
}

async function getUsers() {
  const pool = new Pool({
    connectionString: process.env.DATABASE_URL
  });

  return pool.query('SELECT * FROM users');
}

const pool = new Pool({
  connectionString: process.env.DATABASE_URL
});

async function getUsers() {
  return pool.query('SELECT * FROM users');
}

try {
  await pool.query('SELECT 1');
} catch (error) {
  console.error('Запит не виконано:', error.message);
}