本机接口postgresql提供以下命令:NOTIFY channel [ , payload ]
,其中payload是变量字符串。我使用库pqxx
与数据库进行交互。提供notify_listener
接口。作为通知执行的回调只有一个参数——id
。这是我的代码:
class notif : public pqxx::notify_listener {
public:
notif(pqxx::connection_base &conn, const std::string &table, std::shared_ptr<notify_processor_t> pr) :
pqxx::notify_listener(conn, table), _table(table), _pr(pr) {}
notif(pqxx::connection_base &conn, const std::string &table) :
pqxx::notify_listener(conn, table), _table(table) {}
virtual void operator()(int id)
{
std::cout << "notification " << _table << std::endl;
if (_pr.get())
_pr->operator()();
}
private:
std::shared_ptr<notify_processor_t> _pr;
std::string _table;
};
如何使用提供的pqxx
接口获取payload
内容?
在libpqxx 4.0.1版本中发现以下内容:
// Obsolete notification receiver.
/** @deprecated Use notification_receiver instead.
*/
class PQXX_LIBEXPORT PQXX_NOVTABLE notify_listener
您应该使用notification receiver
类而不是notify_listener