query_utils.h File Reference

#include "libpq-fe.h"

Include dependency graph for query_utils.h:

This graph shows which files directly or indirectly include this file:

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  )

extern

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, fb(), 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  )

extern

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().

executeQuery()

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

extern

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, fb(), pg_log_error, pg_log_error_detail, PGRES_TUPLES_OK, PQerrorMessage(), PQexec(), PQfinish(), PQresultStatus, and printf.