#include #include #include #include #include #include "libpq-fe.h" static void exit_nicely(PGconn *conn) { PQfinish(conn); exit(1); } main() { char *conninfo = "port=11003 dbname=test"; PGconn *conn; PGresult *res; const char *paramValues[1]; conn = PQconnectdb(conninfo); if (PQstatus(conn) != CONNECTION_OK) { fprintf(stderr, "Connection to database failed: %s", PQerrorMessage(conn)); exit_nicely(conn); } paramValues[0] = "2"; fprintf(stderr, "start #1 query\n"); PQsendQueryParams(conn, "SELECT pg_sleep($1::int)", 1, /* one param */ NULL, /* let the backend deduce param type */ paramValues, NULL, /* don't need param lengths since text */ NULL, /* default to all text params */ 0); /* ask for text results */ fprintf(stderr, "end #1 query\n"); sleep(10); exit(0); }