Хост Postgres

Возвращаемое значение:

{
  results: Array<{
    paramName: string;   // имя выходного параметра (в верхнем регистре)
    type: string;        // Oracle-тип: "VARCHAR2", "NUMBER", "CURSOR", "CLOB", "DATE"...
    value: any;          // значение, для курсоров - {columns, list}
  }>
}

Особенности:

• Автоматически преобразует именованные параметры (:name) в позиционные ($1) с помощью oraUtils.convertNameToPos.
• Конвертирует PG-типы в Oracle-типы (convertType).
• Для курсоров преобразует структуру через convertColumns.
• Логирует результат с ограничением размера (если задан limitLogger).
• В случае отсутствия функции в PgFunctions, записывает информацию о недостающем вызове в logs.write_error_log и выбрасывает ComplexError.

Сервис

8. OraLongTransactions

НФазначениейл: Предsrc/ora-adapter/ora-long-transactions/index.mjs

Аналоставляетг Oracle-сOraQueries, новместимый интерфейс для длинных транзакций. ЯвИсполяьзуется обёрткой над PgTransactions, адаптируля удержания соединения. Поддерживает многошаговые сценарии: мсоздать транзакцию, выполнить нетскодлько запросов и, получить результаты, зафиксироваметрыь.

Зависимости: ["PgTransactions"PgTransactions, "DbServices"]DbServices

Методы:

• create({session}) – создать транзакцию (возвращает oltId).
• execFunc({oltId, package, func, params, session}) / execSql(...).
• getExecResult({oltId}) – получить результат выполненного запроса.
• fetch({oltId, count}) – получить строки из открытого курсора.
• commit({oltId}) / rollback({oltId}).
• poolStatus() – состояние пула длинных транзакций.

9. OraQueriesPool

Файл: src/ora-adapter/ora-queries-pool/index.mjs

Административный интерфейс для просмотра состояния пула PgPool.

Зависимости: PgPool, DbServices
Методы:

• state() – возвращает детализацию по соединениям (количество, статусы).

Тестовые сервисы

OLTTest (src/ora-adapter/ora-long-transactions/test/index.mjs)
OraAdpTest (src/ora-adapter/test/index.mjs)

Предназначены для ручного тестирования длинных транзакций и обычных SQL-запросов. Содержат примеры вызовов и могут быть удалены в продуктовой среде.

Вспомогательные классы и утилиты

ArgumentParser

Распарсивает строку аргументов функции PostgreSQL (из pg_get_function_arguments) в структурированный вид: { name, type, isOut, hasDefault }.

PgFormats

Отвечает за:

• Конвертацию типов полей при чтении из БД (числа, даты).
• Формирование SQL-вызова функции с именованными параметрами ("arg" => $1).
• Проверку кодов ошибок PostgreSQL (отделение логических ошибок от проблем соединения).

PgConnection

Управляет одним подключением для «коротких» запросов (PgPool). Выполняет SQL в транзакции (BEGIN → запрос → COMMIT/ROLLBACK). Обрабатывает refcursor, загружая данные из курсора.

PGTransaction

Класс одной длинной транзакции. Хранит состояние, управляет жизненным циклом, поддерживает выполнение SQL и функций, фетч курсора. Используется внутри PGTPool.

PGTPool

Менеджер пула PGTransaction. Создаёт транзакции по требованию, отслеживает таймауты, автоматически подчищает закрытые соединения, пишет ошибки в лог БД.

PgNotifyConnection

Подключение для LISTEN/NOTIFY. Инкапсулирует логику переподключения и подписки.

Конфигурация

Файл config.mjs содержит параметры по умолчанию:

• NatsConnection.queue = "pgqueries", timeout = 60000
• NatsPublisher.interval = 60000

Остальные настройки берутся из config.common и CommonRegistry:

Особенности:

• Параметры execFunc принимают package и func вместо namespace/funcName.
• При выполнении SQL через execSql, параметры могут быть переданы в нотации Oracle (:paramName), они автоматически конвертируются в позиционные через oraUtils.convertNameToPos.
• Все выходные параметры и курсоры приводятся к Oracle-типам.

Сервис OraQueriesPool

Назначение: Управление пулом обычных (не транзакционных) сессий OraQueries. Предоставляет административные методы для мониторинга и управления.

Зависимости: ["PgPool", "DbServices"]

Методы (запросы):

Формат state:

{
  "result": [
    {
      "name": "main",
      "pid": 0,
      "sessionsCount": 4,
      "workedSessions": [{"id": "pool_0", "status": "exec"}, ...],
      "queryQueue": [],
      "killerSession": null,
      "usage": { ... }
    }
  ]
}

Особенности:

• Фактически является административной панелью для PgPool.
• Методы recreate и brakeQuery пока не реализованы (выбрасывают ошибку).

Общая архитектура и зависимости

graph TD
    subgraph "Внешние сервисы"
        DbServices[DbServices]
        CommonRegistry[CommonRegistry]
        RegistryHelper[RegistryHelper]
    end

    subgraph "Сервисы PostgreSQL"
        PgFunctions --> |загрузка метаданных| PostgreSQL
        OraFunctions --> PgFunctions
        PgPool --> PgFunctions
        PgPool --> RegistryHelper
        PgTransactions --> PgFunctions
        PgTransactions --> RegistryHelper
        PgTransactions --> DbServices
        PgTools --> PostgreSQL
        PgNotify --> PgNotifyConnection --> PostgreSQL
        OraQueries --> PgPool
        OraQueries --> DbServices
        OraLongTransactions --> PgTransactions
        OraLongTransactions --> DbServices
        OraQueriesPool --> PgPool
        OraQueriesPool --> DbServices
    end

    RegistryHelper --> CommonRegistry

Все соединения с PostgreSQL используют строку подключения из конфигурации common.postgresUri. Настройки пулов и таймаутов управляются через CommonRegistry, изменения вступают в силу после перезагрузки пула (для PgPool — автоматически при изменении схемы).

Конфигурация по умолчанию

Файл config.mjs:

{
  "NatsConnection": {
    "queue": "pgqueries",
    "timeout": 60000
  },
  "NatsPublisher": {
    "interval": 60000
  }
}

Дополнительные параметры (из config.common):

• postgresUri – строка подключения к PostgreSQL.
PostgreSQL
• common.timeZone – чЧасовой пояс для сессий (нБД pgQueryPool.connectionCount Размер пула коротких запросов (в CommonRegistry) PgTransactions.idleTimeout Таймаут простоя транзакции (мс) PgTransactions.cleanTimeout Интервал очистки закрытых транзакций (мс)

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

  ---

  Схема взаимодействия

  1. Загрузка метаданных PgFunctions при старте загружает список всех функций PostgreSQL. OraFunctions на его основе строит «оракул-подобное» представление.

  2. Регистрация в DbServices Сер,вис 'Europe/Moscow'DbServices (из внешнего пакета) хранит каталог всех доступных вызовов (жёсткие и мягкие). OraQueries и OraLongTransactions используют DbServices.getOraSql() для генерации PL/SQL‑блока с подстановкой параметров.

  3. Выполнение запросов

     • Короткие запросы: OraQueries.exec → DbServices.getOraSql → формирование вызова → PgPool.execFunc → PgConnection.
     • Длинные транзакции: OraLongTransactions.create → PgTransactions.create (создаётся PGTransaction) → далее execFunc/execSql → по окончании getExecResult + commit/rollback.

  4. Нотификации PgNotify слушает каналы PostgreSQL и генерирует событие onNotify, на которое могут подписываться другие сервисы.

  5. Администрирование OraQueriesPool и метод poolStatus у длинных транзакций дают мониторинг соединений.

  ---

  Примечания по использованию

  • Большинство сервисов требуют наличия DbServices дДля проверки и выполнения хранимого кода. DbServices – это внешний сервис, который должен быть доступен в кластере (предктноставляет запросы getOraSql и др.).
  • Дляй работы с необходлинными транзакциями используйте OraLongTransactions, а неастройка PgTransactionscommon.postgresUri и напряличие в БД схемую, чтобы обеспечить совместимость с Oracle-клиентами.
  • Административные методы защищены флагом needAdmin: truecarabimeta, который требует аутентифицированной сессии с правоцедурами администратора.
  • Все ошибки базы данных логируются вset_user_id, logs.write_error_log (если функция доступна и не отключена флагом noLog).

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