Merge branch 'kaare-master'

Author: salortiz

README.pod

@@ -118,6 +118,22 @@ string Pg can understand.
   #prepare an insertion of an array field;
   $sth.execute($sth.pg-array-str(@data));
 
+=head3 B<pg_notifies>
+
+  $ret = $dbh.pg_notifies;
+
+Looks for any asynchronous notifications received and returns a pg-notify object that looks like this
+
+	class pg-notify {
+		has Str                           $.relname; # Channel Name
+		has int32                         $.be_pid; # Backend pid
+		has Str                           $.extra; # Payload
+	}
+
+or nothing if there is no pending notifications.
+
+The payload is optional and will always be an empty string for Postgres servers less than version 9.0.
+
 =head2 SQLite
 
 Supports basic CRUD operations and prepared statements with placeholders

lib/DBDish/Pg/Connection.pm6

@@ -115,6 +115,10 @@ method ping {
     }
 }
 
+method pg-notifies {
+    return $!pg_conn.pg-notifies;
+}
+
 method _disconnect() {
     .PQfinish with $!pg_conn;
     $!pg_conn = Nil;

lib/DBDish/Pg/Native.pm6

@@ -85,6 +85,12 @@ class PGresult	is export is repr('CPointer') {
     }
 }
 
+class pg-notify {
+	has Str                           $.relname; # char* relname
+	has int32                         $.be_pid; # int be_pid
+	has Str                           $.extra; # char* extra
+}
+
 class PGconn is export is repr('CPointer') {
     method PQexec(str --> PGresult) is native(LIB) { * }
     method PQexecPrepared(
@@ -115,6 +121,28 @@ class PGconn is export is repr('CPointer') {
 	    die "Can't allocate memory!"
 	}
     }
+    method pg-notifies {
+
+        class PGnotify is repr('CStruct') {
+        	has Str                           $.relname; # char* relname
+        	has int32                         $.be_pid; # int be_pid
+        	has Str                           $.extra; # char* extra
+        }
+        sub PQnotifies(PGconn) returns Pointer is native(LIB) is export { * }
+
+	    my \ptr = PQnotifies(self);
+        LEAVE { PQfreemem(ptr) if ptr }
+        with ptr {
+            with my PGnotify $pgnote = nativecast(PGnotify, $_) {
+                my $note = pg-notify.new(
+                    relname => $_.relname,
+                    be_pid => $_.be_pid,
+                    extra => $_.extra,
+                );
+                return $note;
+            }
+		}
+    }
 
     method new(Str $conninfo) { # Our constructor
 	sub PQconnectdb(str --> PGconn) is native(LIB) { * };

t/36-pg-native.t

@@ -0,0 +1,44 @@
+v6;
+use Test;
+use DBIish;
+
+plan 13;
+
+my %con-parms;
+
+# If env var set, no parameter needed.
+%con-parms<dbname> = 'dbdishtest' unless %*ENV<PGDATABASE>;
+%con-parms<user> = 'postgres' unless %*ENV<PGUSER>;
+
+my $dbh;
+
+try {
+  $dbh = DBIish.connect('Pg', |%con-parms);
+  CATCH {
+	    when X::DBIish::LibraryMissing | X::DBDish::ConnectionFailed {
+		diag "$_\nCan't continue.";
+	    }
+            default { .throw; }
+  }
+}
+without $dbh {
+    skip-rest 'prerequisites failed';
+    exit;
+}
+
+ok $dbh,    'Connected';
+lives-ok { $dbh.do('LISTEN test') }, 'Listen to test';
+my $note = $dbh.pg-notifies;
+isa-ok $note, Any, 'No notification';
+lives-ok { $dbh.do('NOTIFY test') }, 'Notify test';
+lives-ok { $dbh.do("NOTIFY test, 'Payload'") }, 'Notify test w/payload';
+$note = $dbh.pg-notifies;
+isa-ok $note, 'DBDish::Pg::Native::pg-notify', 'A notification received';
+is $note.relname, 'test', 'Test channel';
+isa-ok $note.be_pid, Int, 'Pid';
+is $note.extra, '', 'No extras';
+$note = $dbh.pg-notifies;
+isa-ok $note, 'DBDish::Pg::Native::pg-notify', 'A notification received';
+is $note.relname, 'test', 'Test channel';
+isa-ok $note.be_pid, Int, 'Pid';
+is $note.extra, 'Payload', 'w/ extras';