query_utils.c File Reference

#include "postgres_fe.h"
#include "common/logging.h"
#include "fe_utils/cancel.h"
#include "fe_utils/query_utils.h"

Include dependency graph for query_utils.c:

Go to the source code of this file.

Functions
PGresult *	executeQuery (PGconn *conn, const char *query, bool echo)
void	executeCommand (PGconn *conn, const char *query, bool echo)
bool	executeMaintenanceCommand (PGconn *conn, const char *query, bool echo)

Function Documentation

executeCommand()

void executeCommand	(	PGconn *	conn,
		const char *	query,
		bool	echo
	)

Definition at line 47 of file query_utils.c.

{
    PGresult   *res;
 
    if (echo)
        printf("%s\n", query);
 
    res = PQexec(conn, query);
    if (!res ||
        PQresultStatus(res) != PGRES_COMMAND_OK)
    {
        pg_log_error("query failed: %s", PQerrorMessage(conn));
        pg_log_error_detail("Query was: %s", query);
        PQfinish(conn);
        exit(1);
    }
 
    PQclear(res);
}

References conn, pg_log_error, pg_log_error_detail, PGRES_COMMAND_OK, PQclear(), PQerrorMessage(), PQexec(), PQfinish(), PQresultStatus(), and printf.

executeMaintenanceCommand()

bool executeMaintenanceCommand	(	PGconn *	conn,
		const char *	query,
		bool	echo
	)

Definition at line 74 of file query_utils.c.

{
    PGresult   *res;
    bool        r;
 
    if (echo)
        printf("%s\n", query);
 
    SetCancelConn(conn);
    res = PQexec(conn, query);
    ResetCancelConn();
 
    r = (res && PQresultStatus(res) == PGRES_COMMAND_OK);
 
    PQclear(res);
 
    return r;
}

References conn, PGRES_COMMAND_OK, PQclear(), PQexec(), PQresultStatus(), printf, ResetCancelConn(), and SetCancelConn().

Referenced by cluster_one_database(), and run_reindex_command().

executeQuery()

PGresult * executeQuery	(	PGconn *	conn,
		const char *	query,
		bool	echo
	)

Definition at line 22 of file query_utils.c.

{
    PGresult   *res;
 
    if (echo)
        printf("%s\n", query);
 
    res = PQexec(conn, query);
    if (!res ||
        PQresultStatus(res) != PGRES_TUPLES_OK)
    {
        pg_log_error("query failed: %s", PQerrorMessage(conn));
        pg_log_error_detail("Query was: %s", query);
        PQfinish(conn);
        exit(1);
    }
 
    return res;
}

References conn, pg_log_error, pg_log_error_detail, PGRES_TUPLES_OK, PQerrorMessage(), PQexec(), PQfinish(), PQresultStatus(), and printf.