Class PgDatabase

java.lang.Object
ru.technoliga74.PgDatabase

public class PgDatabase extends Object
Класс для работы с базой данных PostgreSQL. Предоставляет методы для подключения, отключения, выполнения транзакций и загрузки строк прайс-листа.
  • Constructor Summary

    Constructors
    Constructor
    Description
    PgDatabase(String jdbcUrl, String username, String password)
    Создаёт новый экземпляр PgDatabase и загружает драйвер PostgreSQL.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Фиксирует текущую транзакцию.
    void
    Устанавливает подключение к базе данных, если оно ещё не установлено или было закрыто.
    void
    Закрывает подключение к базе данных.
    void
    Очищает таблицу цен, вызывая хранимую процедуру fnc_EmptyPrices.
    void
    Вставляет или обновляет строку прайс-листа в базе данных через хранимую процедуру fnc_LoadCatalogLine.
    void
    Откатывает текущую транзакцию.
    void
    Начинает транзакцию, отключая режим автофиксации.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • PgDatabase

      public PgDatabase(String jdbcUrl, String username, String password) throws ClassNotFoundException, SQLException
      Создаёт новый экземпляр PgDatabase и загружает драйвер PostgreSQL.
      Parameters:
      jdbcUrl - JDBC URL для подключения к базе данных
      username - имя пользователя
      password - пароль
      Throws:
      ClassNotFoundException - если драйвер PostgreSQL не найден
      SQLException - если ошибка подключения
  • Method Details

    • Connect

      public void Connect() throws SQLException
      Устанавливает подключение к базе данных, если оно ещё не установлено или было закрыто.
      Throws:
      SQLException - если ошибка подключения
    • Disconnect

      public void Disconnect() throws SQLException
      Закрывает подключение к базе данных.
      Throws:
      SQLException - если ошибка при закрытии
    • startTransaction

      public void startTransaction() throws SQLException
      Начинает транзакцию, отключая режим автофиксации.
      Throws:
      SQLException - если ошибка при настройке автофиксации
    • emptyPrices

      public void emptyPrices() throws SQLException
      Очищает таблицу цен, вызывая хранимую процедуру fnc_EmptyPrices.
      Throws:
      SQLException - если ошибка выполнения запроса
    • commit

      public void commit() throws SQLException
      Фиксирует текущую транзакцию.
      Throws:
      SQLException - если ошибка при фиксации
    • rollback

      public void rollback() throws SQLException
      Откатывает текущую транзакцию.
      Throws:
      SQLException - если ошибка при откате
    • insertOrUpdatePriceLine

      public void insertOrUpdatePriceLine(PriceLine l, Integer catNoGroup) throws SQLException
      Вставляет или обновляет строку прайс-листа в базе данных через хранимую процедуру fnc_LoadCatalogLine.
      Parameters:
      l - строка прайс-листа
      catNoGroup - номер группы каталога
      Throws:
      SQLException - если ошибка выполнения запроса