Транзакції

BEGIN
Списати 100 грн з рахунку A — успішно
Зарахувати 100 грн на рахунок B — помилка
ROLLBACK

BEGIN;    -- почати транзакцію
COMMIT;   -- підтвердити зміни
ROLLBACK; -- скасувати зміни

npm install pg

CREATE TABLE accounts (
  id SERIAL PRIMARY KEY,
  owner_name TEXT NOT NULL,
  balance NUMERIC(12, 2) NOT NULL CHECK (balance >= 0)
);

CREATE TABLE transfers (
  id SERIAL PRIMARY KEY,
  from_account_id INTEGER NOT NULL REFERENCES accounts(id),
  to_account_id INTEGER NOT NULL REFERENCES accounts(id),
  amount NUMERIC(12, 2) NOT NULL CHECK (amount > 0),
  created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

INSERT INTO accounts (owner_name, balance)
VALUES
  ('Олена', 1000.00),
  ('Андрій', 500.00);

import pg from 'pg';

const { Pool } = pg;

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

async function transferMoney(fromAccountId, toAccountId, amount) {
  if (!Number.isInteger(fromAccountId) || !Number.isInteger(toAccountId)) {
    throw new TypeError('Ідентифікатори рахунків мають бути цілими числами');
  }

  if (fromAccountId === toAccountId) {
    throw new Error('Рахунки відправника й отримувача мають відрізнятися');
  }

  if (!Number.isFinite(amount) || amount <= 0) {
    throw new Error('Сума переказу має бути додатним числом');
  }

  const client = await pool.connect();

  try {
    await client.query('BEGIN');

    const debitResult = await client.query(
      `
        UPDATE accounts
        SET balance = balance - $1
        WHERE id = $2
          AND balance >= $1
        RETURNING id, balance
      `,
      [amount, fromAccountId],
    );

    if (debitResult.rowCount === 0) {
      throw new Error('Рахунок не знайдено або недостатньо коштів');
    }

    const creditResult = await client.query(
      `
        UPDATE accounts
        SET balance = balance + $1
        WHERE id = $2
        RETURNING id, balance
      `,
      [amount, toAccountId],
    );

    if (creditResult.rowCount === 0) {
      throw new Error('Рахунок отримувача не знайдено');
    }

    await client.query(
      `
        INSERT INTO transfers (
          from_account_id,
          to_account_id,
          amount
        )
        VALUES ($1, $2, $3)
      `,
      [fromAccountId, toAccountId, amount],
    );

    await client.query('COMMIT');

    return {
      fromAccount: debitResult.rows[0],
      toAccount: creditResult.rows[0],
      amount,
    };
  } catch (error) {
    try {
      await client.query('ROLLBACK');
    } catch (rollbackError) {
      console.error('Не вдалося виконати відкат транзакції:', rollbackError);
    }

    throw error;
  } finally {
    client.release();
  }
}

try {
  const result = await transferMoney(1, 2, 100);
  console.log('Переказ виконано:', result);
} catch (error) {
  console.error('Переказ не виконано:', error.message);
} finally {
  await pool.end();
}

UPDATE accounts
SET balance = balance - 100
WHERE id = 1
  AND balance >= 100;

if (debitResult.rowCount === 0) {
  throw new Error('Рахунок не знайдено або недостатньо коштів');
}

await client.query('ROLLBACK');

try {
  await client.query('BEGIN');

  await client.query('UPDATE ...');
  await client.query('INSERT ...');

  await client.query('COMMIT');
} catch (error) {
  await client.query('ROLLBACK');
  throw error;
}

await pool.query('BEGIN');
await pool.query('UPDATE accounts SET balance = balance - $1 WHERE id = $2', [
  100,
  1,
]);
await pool.query('COMMIT');

const client = await pool.connect();

try {
  await client.query('BEGIN');
  await client.query('UPDATE ...');
  await client.query('INSERT ...');
  await client.query('COMMIT');
} catch (error) {
  await client.query('ROLLBACK');
  throw error;
} finally {
  client.release();
}

finally {
  client.release();
}

finally {
  client.release();
}

await client.query(
  'UPDATE accounts SET balance = balance - $1 WHERE id = $2',
  [amount, accountId],
);