reconnect.c

text/x-csrc

Download

/*
 * reconnect.c
 *
 *		Reconnect at top speed.
 */
#include <stdio.h>
#include <stdlib.h>
#include "libpq-fe.h"

static void
exit_nicely(PGconn *conn)
{
	PQfinish(conn);
	exit(1);
}

int
main(int argc, char **argv)
{
	const char *conninfo;
	PGconn	   *conn;

	/*
	 * If the user supplies a parameter on the command line, use it as the
	 * conninfo string; otherwise default to setting dbname=postgres and using
	 * environment variables or defaults for all other connection parameters.
	 */
	if (argc > 1)
		conninfo = argv[1];
	else
		conninfo = "dbname = postgres";

	/* Loop forever. */
	while (1)
	{
		/* Make a connection to the database */
		conn = PQconnectdb(conninfo);

		/* Check to see that the backend connection was successfully made */
		if (PQstatus(conn) != CONNECTION_OK)
		{
			fprintf(stderr, "Connection to database failed: %s",
					PQerrorMessage(conn));
			exit_nicely(conn);
		}

		/* close the connection to the database and cleanup */
		PQfinish(conn);
	}

	return 0;
}