44 if (connOptions == NULL)
51 if (strcmp(opt->keyword,
"replication") == 0 ||
52 strcmp(opt->keyword,
"dbname") == 0 ||
53 strcmp(opt->keyword,
"fallback_application_name") == 0 ||
55 (opt->val != NULL && opt->val[0] ==
'\0'))
59 if (conninfo_buf.
len != 0)
109 bool use_recovery_conf;
117 use_recovery_conf ?
"recovery.conf" :
"postgresql.auto.conf");
119 cf = fopen(
filename, use_recovery_conf ?
"w" :
"a");
123 if (fwrite(contents->
data, contents->
len, 1, cf) != 1)
128 if (!use_recovery_conf)
int PQserverVersion(const PGconn *conn)
void PQconninfoFree(PQconninfoOption *connOptions)
PQconninfoOption * PQconninfo(PGconn *conn)
Assert(fmt[strlen(fmt) - 1] !='\n')
static char * replication_slot
char * escape_single_quotes_ascii(const char *src)
PQExpBuffer createPQExpBuffer(void)
void initPQExpBuffer(PQExpBuffer str)
void appendPQExpBuffer(PQExpBuffer str, const char *fmt,...)
void appendPQExpBufferChar(PQExpBuffer str, char ch)
void appendPQExpBufferStr(PQExpBuffer str, const char *data)
void termPQExpBuffer(PQExpBuffer str)
#define PQExpBufferBroken(str)
#define PQExpBufferDataBroken(buf)
void WriteRecoveryConfig(PGconn *pgconn, char *target_dir, PQExpBuffer contents)
static char * escape_quotes(const char *src)
PQExpBuffer GenerateRecoveryConfig(PGconn *pgconn, char *replication_slot)
#define MINIMUM_VERSION_FOR_RECOVERY_GUC
void appendConnStrVal(PQExpBuffer buf, const char *str)