Add some error checking for SPI_connect

leto · Jan 8, 2010 · c9755c5 · c9755c5
1 parent 821e790
commit c9755c5
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/handler/plparrot.c b/src/handler/plparrot.c
@@ -25,11 +25,15 @@ int execq(text *sql, int cnt);
 int
 execq(text *sql, int cnt)
 {
-    char *command;
-    int ret;
+    //char *command;
     int proc;
+    int ret;
 
-    SPI_connect();
+    ret = SPI_connect();
+    if ( ret == SPI_ERROR_CONNECT ) {
+        printf("SPI connect error!\n");
+        return 1;
+    }
 
     SPI_finish();
     //pfree(command);