Подписка из Qt Script на уведомления PostgreSQL, Помогите со статьёй из вашей Вики Опции Подписка на тему Сообщить другу Версия для печати Скачать тему Подписка на этот форум Режимы отображения Переключить на: Древовидный Переключить на: Стандартный Линейный

[sergesb]

Очень нужна реализация уведомлений из PostgreSQL. Нашел на вашем вики очень интересную статью по этому.
Подписка из Qt Script на уведомления PostgreSQL
Так как никогда не работал с QtScript, порошу помощи, или объясните как прикрутить это к программе, или реализацию на с++ без использования QtScript.
Не понял что делают тут :

Определяем в qt script функцию-подписчика:

noticeReceiver = function(severity, primary, detail, hint) {
    message = primary;
    if (detail != "")
        message += "\n" + detail;
    if (hint != "")
        message += "\n" + detail;
    if (severity == "WARNING") {
        print(message);
    } else if (severity == "NOTICE") {
        print(message);
    } else if (severity == "INFO") {
        print(message);
    } else if (severity == "LOG") {
        print(message);
    }
};

Выполняем подписку в qt script:

if (!PQsetNoticeReceiver(sqlConnectionName, noticeReceiver))
        print("Unable to set postgresql notice receiver");

где определяют, что определяют, что такое noticeReceiver ?
Заранее спасибо.

Сообщение отредактировал Litkevich Yuriy - 9.11.2010, 21:51

Причина редактирования: поправил название

[Litkevich Yuriy]

что такое noticeReceiver ?

это переменная. Т.к. я зык Qt Script - язык с динамической типизацией, то тип данных не указывается (смотри также Python, Basic, ...), в отличие от языков со статической типизацией (например, Паскаль, Си, ...)

тип который будет иметь эта переменная, определяется типом, возвращаемым функцией
function(severity, primary, detail, hint)

[sergesb]

а как мне этот код вставить в С++ код, и увязать с ним ?

[fsMark]

а как мне этот код вставить в С++ код, и увязать с ним ?

Как вариант сигналы и слоты.

[asvil]

sergesb, поясните что вам необходимо.
Я в свою очередь просто расскажу как вывести postgresql notice в qWarning(), не доверяя это дейсвтие libpq.
Итак сначала сделаем приложение независимым от библиотек при компиляции.
Определите в вашем заголовочном файле следующие типы.

#include <QtSql/QSqlDatabase>
#include <QtSql/qsql_psql.h>
//#include "libpq-fe.h"

// Переменные обозначающие части сообщений сервера
#define PG_DIAG_SEVERITY        'S'
#define PG_DIAG_SQLSTATE        'C'
#define PG_DIAG_MESSAGE_PRIMARY 'M'
#define PG_DIAG_MESSAGE_DETAIL    'D'
#define PG_DIAG_MESSAGE_HINT    'H'
#define PG_DIAG_STATEMENT_POSITION 'P'
#define PG_DIAG_INTERNAL_POSITION 'p'
#define PG_DIAG_INTERNAL_QUERY    'q'
#define PG_DIAG_CONTEXT            'W'
#define PG_DIAG_SOURCE_FILE        'F'
#define PG_DIAG_SOURCE_LINE        'L'
#define PG_DIAG_SOURCE_FUNCTION 'R'


// Функция-подписчик на PostgreSQL нотисы
typedef void (*PQnoticeReceiver) (void *arg, const PGresult *res);

// Функция устанавливающая подписчика на PostgreSQL нотисы
typedef PQnoticeReceiver (*PQsetNoticeReceiver)(PGconn *conn,
                                                PQnoticeReceiver proc,
                                                void *arg);

// Функция возвращающая определенные части сообщения
typedef char * (*PQresultErrorField)(const PGresult *res, int fieldcode);

В вашем файле реализации сделайте следующие действия:

// Переменные хранящие указатели на функции
PQsetNoticeReceiver pqSetNoticeReceiver;
PQresultErrorField pqResultErrorField;
#include <QtCore/QLibrary>
/*!
  Загрузка libpq.
  \return bool
  \retval true успешно
  \retval false не успешно
*/
bool initPostgresqlLibrary()
{
  QLibrary library("libpq");
  if (library.load()) {
    pqSetNoticeReceiver = (PQsetNoticeReceiver)(library.resolve("PQsetNoticeReceiver"));
    pqResultErrorField = (PQresultErrorField)(library.resolve("PQresultErrorField"));
    return pqSetNoticeReceiver && pqResultErrorField;
  }
  return false;
}

// MINI HACK
// Вызывает qWarning() функцию с 4-мя параметрами severity, primary, detail, hint
// severity - уровень сообщения
void PostgreSQLnoticeReceiver(void *arg ,const PGresult *res)
{
  QString severity = QString::fromUtf8(pqResultErrorField(res, PG_DIAG_SEVERITY));
  QString primary = QString::fromUtf8(pqResultErrorField(res, PG_DIAG_MESSAGE_PRIMARY));
  QString detail = QString::fromUtf8(pqResultErrorField(res, PG_DIAG_MESSAGE_DETAIL));
  QString hint = QString::fromUtf8(pqResultErrorField(res, PG_DIAG_MESSAGE_HINT));

// КЛЮЧЕВАЯ СТРОКА
    qWarning() << severity << primary << detail << hint;
}

//Возмите QSqlDatabase и получите указатель на PGconn
// Далее на этот PGconn установите обработчик сообщений
void PQsetNoticeReceiverWrapper(QSqlDatabase& database)
{
      QVariant driverHandle = database.driver()->handle();
      if (!QString::compare(driverHandle.typeName(),"PGconn*")) {
        PGconn *handle = *static_cast<PGconn **>(driverHandle.data());
        if (handle != 0) {
          if (initPostgresqlLibrary()) {
            pqSetNoticeReceiver(handle, PostgreSQLnoticeReceiver, 0);
            return true;
          }
        }
      }
    }
  }
  return false;
}