[フレーム]

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

)

Definition at line 47 of file query_utils.c.

48{

49 PGresult *res;

50

51 if (echo)

52 printf("%s\n", query);

53

54 res = PQexec(conn, query);

55 if (!res ||

56 PQresultStatus(res) != PGRES_COMMAND_OK)

57 {

58 pg_log_error("query failed: %s", PQerrorMessage(conn));

59 pg_log_error_detail("Query was: %s", query);

60 PQfinish(conn);

61 exit(1);

62 }

63

64 PQclear(res);

65}

PQfinish

void PQfinish(PGconn *conn)

Definition: fe-connect.c:5305

PQerrorMessage

char * PQerrorMessage(const PGconn *conn)

Definition: fe-connect.c:7679

PQexec

PGresult * PQexec(PGconn *conn, const char *query)

Definition: fe-exec.c:2273

PQclear

#define PQclear

Definition: libpq-be-fe.h:245

PQresultStatus

#define PQresultStatus

Definition: libpq-be-fe.h:247

PGRES_COMMAND_OK

@ PGRES_COMMAND_OK

Definition: libpq-fe.h:125

pg_log_error

#define pg_log_error(...)

Definition: logging.h:106

pg_log_error_detail

#define pg_log_error_detail(...)

Definition: logging.h:109

printf

#define printf(...)

Definition: port.h:245

conn

PGconn * conn

Definition: streamutil.c:52

pg_result

Definition: libpq-int.h:165

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.

75{

76 PGresult *res;

77 bool r;

78

79 if (echo)

80 printf("%s\n", query);

81

82 SetCancelConn(conn);

83 res = PQexec(conn, query);

84 ResetCancelConn();

85

86 r = (res && PQresultStatus(res) == PGRES_COMMAND_OK);

87

88 PQclear(res);

89

90 return r;

91}

ResetCancelConn

void ResetCancelConn(void)

Definition: cancel.c:107

SetCancelConn

void SetCancelConn(PGconn *conn)

Definition: cancel.c:77

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

)

Definition at line 22 of file query_utils.c.

23{

24 PGresult *res;

25

26 if (echo)

27 printf("%s\n", query);

28

29 res = PQexec(conn, query);

30 if (!res ||

31 PQresultStatus(res) != PGRES_TUPLES_OK)

32 {

33 pg_log_error("query failed: %s", PQerrorMessage(conn));

34 pg_log_error_detail("Query was: %s", query);

35 PQfinish(conn);

36 exit(1);

37 }

38

39 return res;

40}

PGRES_TUPLES_OK

@ PGRES_TUPLES_OK

Definition: libpq-fe.h:128

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