30#define ERRCODE_DUPLICATE_OBJECT "42710"
37#define MINIMUM_VERSION_FOR_SHOW_CMD 100000
42#define MINIMUM_VERSION_FOR_GROUP_ACCESS 110000
88 if (conn_opts == NULL)
91 for (conn_opt = conn_opts; conn_opt->
keyword != NULL; conn_opt++)
93 if (conn_opt->
val != NULL && conn_opt->
val[0] !=
'\0')
108 for (conn_opt = conn_opts; conn_opt->
keyword != NULL; conn_opt++)
110 if (conn_opt->
val != NULL && conn_opt->
val[0] !=
'\0')
130 keywords[
i] =
"fallback_application_name";
163 need_password =
false;
189 pg_fatal(
"could not connect to server");
197 need_password =
true;
200 while (need_password);
246 pg_log_error(
"could not determine server setting for \"integer_datetimes\"");
251 if (strcmp(tmpparam,
"on") != 0)
253 pg_log_error(
"\"integer_datetimes\" compile flag does not match server");
296 pg_log_error(
"could not send replication command \"%s\": %s",
304 pg_log_error(
"could not fetch WAL segment size: got %d rows and %d fields, expected %d rows and %d or more fields",
312 if (sscanf(
PQgetvalue(res, 0, 0),
"%d%2s", &xlog_val, xlog_unit) != 2)
322 if (strcmp(xlog_unit,
"MB") == 0)
323 multiplier = 1024 * 1024;
324 else if (strcmp(xlog_unit,
"GB") == 0)
325 multiplier = 1024 * 1024 * 1024;
333 "remote server reported invalid WAL segment size (%d bytes)",
367 res =
PQexec(
conn,
"SHOW data_directory_mode");
370 pg_log_error(
"could not send replication command \"%s\": %s",
378 pg_log_error(
"could not fetch group access flag: got %d rows and %d fields, expected %d rows and %d or more fields",
387 pg_log_error(
"group access flag could not be parsed: %s",
422 pg_log_error(
"could not send replication command \"%s\": %s",
430 pg_log_error(
"could not identify system: got %d rows and %d fields, expected %d rows and %d or more fields",
442 if (starttli != NULL)
448 if (sscanf(
PQgetvalue(res, 0, 2),
"%X/%X", &hi, &lo) != 2)
450 pg_log_error(
"could not parse write-ahead log location \"%s\"",
467 pg_log_error(
"could not identify system: got %d rows and %d fields, expected %d rows and %d or more fields",
499 *restart_lsn = lsn_loc;
501 *restart_tli = tli_loc;
510 pg_log_error(
"could not send replication command \"%s\": %s",
519 pg_log_error(
"could not read replication slot \"%s\": got %d rows and %d fields, expected %d rows and %d fields",
531 pg_log_error(
"replication slot \"%s\" does not exist", slot_name);
540 if (strcmp(
PQgetvalue(res, 0, 0),
"physical") != 0)
542 pg_log_error(
"expected a physical replication slot, got type \"%s\" instead",
554 if (sscanf(
PQgetvalue(res, 0, 1),
"%X/%X", &hi, &lo) != 2)
556 pg_log_error(
"could not parse restart_lsn \"%s\" for replication slot \"%s\"",
561 lsn_loc = ((
uint64) hi) << 32 | lo;
572 *restart_lsn = lsn_loc;
574 *restart_tli = tli_loc;
585 bool is_temporary,
bool is_physical,
bool reserve_wal,
595 (!is_physical &&
plugin != NULL));
597 Assert(slot_name != NULL);
609 if (use_new_option_syntax)
626 if (use_new_option_syntax)
628 "SNAPSHOT",
"nothing");
631 "NOEXPORT_SNAPSHOT");
634 if (use_new_option_syntax)
637 if (query->
data[query->
len - 1] ==
'(')
640 query->
data[query->
len] =
'\0';
662 pg_log_error(
"could not send replication command \"%s\": %s",
673 pg_log_error(
"could not create replication slot \"%s\": got %d rows and %d fields, expected %d rows and %d fields",
697 Assert(slot_name != NULL);
707 pg_log_error(
"could not send replication command \"%s\": %s",
717 pg_log_error(
"could not drop replication slot \"%s\": got %d rows and %d fields, expected %d rows and %d fields",
744 if (
buf->len > 0 &&
buf->data[
buf->len - 1] !=
'(')
746 if (use_new_option_syntax)
763 char *option_name,
char *option_value)
767 if (option_value != NULL)
769 size_t length = strlen(option_value);
770 char *escaped_value =
palloc(1 + 2 * length);
774 pfree(escaped_value);
786 char *option_name,
int32 option_value)
818 long *secs,
int *microsecs)
856 memcpy(
buf, &n64,
sizeof(n64));
867 memcpy(&n64,
buf,
sizeof(n64));
static Datum values[MAXATTR]
#define ngettext(s, p, n)
#define ALWAYS_SECURE_SEARCH_PATH_SQL
#define POSTGRES_EPOCH_JDATE
int PQserverVersion(const PGconn *conn)
void PQconninfoFree(PQconninfoOption *connOptions)
PQconninfoOption * PQconninfoParse(const char *conninfo, char **errmsg)
const char * PQparameterStatus(const PGconn *conn, const char *paramName)
int PQconnectionNeedsPassword(const PGconn *conn)
ConnStatusType PQstatus(const PGconn *conn)
void PQfinish(PGconn *conn)
char * PQerrorMessage(const PGconn *conn)
PGconn * PQconnectdbParams(const char *const *keywords, const char *const *values, int expand_dbname)
size_t PQescapeStringConn(PGconn *conn, char *to, const char *from, size_t length, int *error)
char * PQgetvalue(const PGresult *res, int tup_num, int field_num)
ExecStatusType PQresultStatus(const PGresult *res)
void PQclear(PGresult *res)
int PQntuples(const PGresult *res)
int PQgetisnull(const PGresult *res, int tup_num, int field_num)
char * PQresultErrorField(const PGresult *res, int fieldcode)
PGresult * PQexec(PGconn *conn, const char *query)
int PQnfields(const PGresult *res)
char * pg_strdup(const char *in)
void * pg_malloc0(size_t size)
void SetDataDirectoryCreatePerm(int dataDirMode)
Assert(PointerIsAligned(start, uint64))
static const JsonPathKeyword keywords[]
#define pg_log_error(...)
#define pg_log_error_detail(...)
void pfree(void *pointer)
#define DEFAULT_XLOG_SEG_SIZE
static bool slot_exists_ok
static const char * plugin
static XLogRecPtr startpos
PQExpBuffer createPQExpBuffer(void)
void appendPQExpBuffer(PQExpBuffer str, const char *fmt,...)
void destroyPQExpBuffer(PQExpBuffer str)
void appendPQExpBufferChar(PQExpBuffer str, char ch)
void appendPQExpBufferStr(PQExpBuffer str, const char *data)
char * simple_prompt(const char *prompt, bool echo)
void AppendIntegerCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name, int32 option_value)
PGconn * GetConnection(void)
bool RetrieveWalSegSize(PGconn *conn)
#define ERRCODE_DUPLICATE_OBJECT
#define MINIMUM_VERSION_FOR_SHOW_CMD
int64 fe_recvint64(char *buf)
bool CreateReplicationSlot(PGconn *conn, const char *slot_name, const char *plugin, bool is_temporary, bool is_physical, bool reserve_wal, bool slot_exists_ok, bool two_phase)
TimestampTz feGetCurrentTimestamp(void)
#define MINIMUM_VERSION_FOR_GROUP_ACCESS
void feTimestampDifference(TimestampTz start_time, TimestampTz stop_time, long *secs, int *microsecs)
void AppendPlainCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name)
void AppendStringCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name, char *option_value)
void fe_sendint64(int64 i, char *buf)
bool feTimestampDifferenceExceeds(TimestampTz start_time, TimestampTz stop_time, int msec)
bool GetSlotInformation(PGconn *conn, const char *slot_name, XLogRecPtr *restart_lsn, TimeLineID *restart_tli)
static bool RetrieveDataDirCreatePerm(PGconn *conn)
bool DropReplicationSlot(PGconn *conn, const char *slot_name)
bool RunIdentifySystem(PGconn *conn, char **sysid, TimeLineID *starttli, XLogRecPtr *startpos, char **db_name)
int gettimeofday(struct timeval *tp, void *tzp)
#define IsValidWalSegSize(size)
#define InvalidXLogRecPtr