diff options
Diffstat (limited to 'src/interfaces/libpq++/examples/testlibpq4.cc')
-rw-r--r-- | src/interfaces/libpq++/examples/testlibpq4.cc | 59 |
1 files changed, 0 insertions, 59 deletions
diff --git a/src/interfaces/libpq++/examples/testlibpq4.cc b/src/interfaces/libpq++/examples/testlibpq4.cc deleted file mode 100644 index a3248ea2586..00000000000 --- a/src/interfaces/libpq++/examples/testlibpq4.cc +++ /dev/null @@ -1,59 +0,0 @@ -/* - * testlibpq4.cc - * Test of the asynchronous notification interface - * - populate a test database with the following (use testlibpq4.sql): - -CREATE TABLE TBL1 (i int4); - -CREATE TABLE TBL2 (i int4); - -CREATE RULE r1 AS ON INSERT TO TBL1 DO [INSERT INTO TBL2 values (new.i); NOTIFY TBL2]; - - * Then start up this program - * After the program has begun, do - -INSERT INTO TBL1 values (10); - - * - * - */ -#include <iostream.h> -#include "libpq++.h" -#include <stdlib.h> - -int main() -{ - // Begin, by connecting to the backend using hardwired constants - // and a test database created by the user prior to the invokation - // of this test program. - const char* dbName = "dbname=template1"; - PgDatabase data(dbName); - - // Check to see that the backend connection was successfully made - if ( data.ConnectionBad() ) { - cerr << "Connection to database '" << dbName << "' failed." << endl - << data.ErrorMessage() << endl; - exit(1); - } - - // Listen to a table - if ( !data.ExecCommandOk("LISTEN TBL2") ) { - cerr << "LISTEN command failed" << endl; - exit(1); - } - - // Test asynchronous notification - while (1) { - // check for asynchronous returns - PGnotify* notify = data.Notifies(); - if (notify) { - cerr << "ASYNC NOTIFY of '" << notify->relname - << "' from backend pid '" << notify->be_pid - << "' received" << endl; - free(notify); - break; - } - } - return 0; -} |