common.h File Reference

#include "common/username.h"
#include "fe_utils/connect_utils.h"
#include "getopt_long.h"
#include "libpq-fe.h"
#include "pqexpbuffer.h"

Include dependency graph for common.h:

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

Go to the source code of this file.

Functions
void	splitTableColumnsSpec (const char *spec, int encoding, char **table, const char **columns)
void	appendQualifiedRelation (PQExpBuffer buf, const char *spec, PGconn *conn, bool echo)
bool	yesno_prompt (const char *question)

Function Documentation

appendQualifiedRelation()

void appendQualifiedRelation ( PQExpBuffer  buf, const char *  spec, PGconn *  conn, bool  echo  )

extern

Definition at line 68 of file common.c.

{
    char       *table;
    const char *columns;
    PQExpBufferData sql;
    PGresult   *res;
    int         ntups;
 
    splitTableColumnsSpec(spec, PQclientEncoding(conn), &table, &columns);
 
    /*
     * Query must remain ABSOLUTELY devoid of unqualified names.  This would
     * be unnecessary given a regclassin() variant taking a search_path
     * argument.
     */
    initPQExpBuffer(&sql);
    appendPQExpBufferStr(&sql,
                         "SELECT c.relname, ns.nspname\n"
                         " FROM pg_catalog.pg_class c,"
                         " pg_catalog.pg_namespace ns\n"
                         " WHERE c.relnamespace OPERATOR(pg_catalog.=) ns.oid\n"
                         "  AND c.oid OPERATOR(pg_catalog.=) ");
    appendStringLiteralConn(&sql, table, conn);
    appendPQExpBufferStr(&sql, "::pg_catalog.regclass;");
 
    executeCommand(conn, "RESET search_path;", echo);
 
    /*
     * One row is a typical result, as is a nonexistent relation ERROR.
     * regclassin() unconditionally accepts all-digits input as an OID; if no
     * relation has that OID; this query returns no rows.  Catalog corruption
     * might elicit other row counts.
     */
    res = executeQuery(conn, sql.data, echo);
    ntups = PQntuples(res);
    if (ntups != 1)
    {
        pg_log_error(ngettext("query returned %d row instead of one: %s",
                              "query returned %d rows instead of one: %s",
                              ntups),
                     ntups, sql.data);
        PQfinish(conn);
        exit(1);
    }
    appendPQExpBufferStr(buf,
                         fmtQualifiedIdEnc(PQgetvalue(res, 0, 1),
                                           PQgetvalue(res, 0, 0),
                                           PQclientEncoding(conn)));
    appendPQExpBufferStr(buf, columns);
    PQclear(res);
    termPQExpBuffer(&sql);
    pg_free(table);
 
    PQclear(executeQuery(conn, ALWAYS_SECURE_SEARCH_PATH_SQL, echo));
}

References ALWAYS_SECURE_SEARCH_PATH_SQL, appendPQExpBufferStr(), appendStringLiteralConn(), buf, conn, PQExpBufferData::data, executeCommand(), executeQuery(), fb(), fmtQualifiedIdEnc(), initPQExpBuffer(), ngettext, pg_free(), pg_log_error, PQclear, PQclientEncoding(), PQfinish(), PQgetvalue, PQntuples, splitTableColumnsSpec(), table, and termPQExpBuffer().

Referenced by cluster_one_database(), gen_reindex_command(), and get_parallel_tabidx_list().

splitTableColumnsSpec()

void splitTableColumnsSpec ( const char *  spec, int  encoding, char **  table, const char **  columns  )

extern

Definition at line 33 of file common.c.

{
    bool        inquotes = false;
    const char *cp = spec;
 
    /*
     * Find the first '(' not identifier-quoted.  Based on
     * dequote_downcase_identifier().
     */
    while (*cp && (*cp != '(' || inquotes))
    {
        if (*cp == '"')
        {
            if (inquotes && cp[1] == '"')
                cp++;           /* pair does not affect quoting */
            else
                inquotes = !inquotes;
            cp++;
        }
        else
            cp += PQmblenBounded(cp, encoding);
    }
    *table = pnstrdup(spec, cp - spec);
    *columns = cp;
}

References encoding, fb(), pnstrdup(), PQmblenBounded(), and table.

Referenced by appendQualifiedRelation(), and retrieve_objects().

yesno_prompt()

bool yesno_prompt ( const char *  question )

extern

Definition at line 136 of file common.c.

{
    char        prompt[256];
 
    /*------
       translator: This is a question followed by the translated options for
       "yes" and "no". */
    snprintf(prompt, sizeof(prompt), _("%s (%s/%s) "),
             _(question), _(PG_YESLETTER), _(PG_NOLETTER));
 
    for (;;)
    {
        char       *resp;
 
        resp = simple_prompt(prompt, true);
 
        if (strcmp(resp, _(PG_YESLETTER)) == 0)
        {
            free(resp);
            return true;
        }
        if (strcmp(resp, _(PG_NOLETTER)) == 0)
        {
            free(resp);
            return false;
        }
        free(resp);
 
        printf(_("Please answer \"%s\" or \"%s\".\n"),
               _(PG_YESLETTER), _(PG_NOLETTER));
    }
}

References _, fb(), free, PG_NOLETTER, PG_YESLETTER, printf, question, simple_prompt(), and snprintf.

Referenced by main().