printfPQExpBuffer(&cmd, "\"%s\" --boot %s %s", backend_exec, boot_options, extra_options);
appendPQExpBuffer(&cmd, " -X %d", wal_segment_size_mb * (1024 * 1024));
if (data_checksums)
- appendPQExpBuffer(&cmd, " -k");
+ appendPQExpBufferStr(&cmd, " -k");
if (debug)
- appendPQExpBuffer(&cmd, " -d 5");
+ appendPQExpBufferStr(&cmd, " -d 5");
PG_CMD_OPEN(cmd.data);
* targets (name, time, xid, LSN).
*/
recoveryconfcontents = GenerateRecoveryConfig(conn, NULL, NULL);
- appendPQExpBuffer(recoveryconfcontents, "recovery_target = ''\n");
- appendPQExpBuffer(recoveryconfcontents,
- "recovery_target_timeline = 'latest'\n");
- appendPQExpBuffer(recoveryconfcontents,
- "recovery_target_inclusive = true\n");
- appendPQExpBuffer(recoveryconfcontents,
- "recovery_target_action = promote\n");
- appendPQExpBuffer(recoveryconfcontents, "recovery_target_name = ''\n");
- appendPQExpBuffer(recoveryconfcontents, "recovery_target_time = ''\n");
- appendPQExpBuffer(recoveryconfcontents, "recovery_target_xid = ''\n");
+ appendPQExpBufferStr(recoveryconfcontents, "recovery_target = ''\n");
+ appendPQExpBufferStr(recoveryconfcontents,
+ "recovery_target_timeline = 'latest'\n");
+ appendPQExpBufferStr(recoveryconfcontents,
+ "recovery_target_inclusive = true\n");
+ appendPQExpBufferStr(recoveryconfcontents,
+ "recovery_target_action = promote\n");
+ appendPQExpBufferStr(recoveryconfcontents, "recovery_target_name = ''\n");
+ appendPQExpBufferStr(recoveryconfcontents, "recovery_target_time = ''\n");
+ appendPQExpBufferStr(recoveryconfcontents, "recovery_target_xid = ''\n");
if (dry_run)
{
- appendPQExpBuffer(recoveryconfcontents, "# dry run mode");
+ appendPQExpBufferStr(recoveryconfcontents, "# dry run mode");
appendPQExpBuffer(recoveryconfcontents,
"recovery_target_lsn = '%X/%X'\n",
LSN_FORMAT_ARGS((XLogRecPtr) InvalidXLogRecPtr));
appendPQExpBuffer(pg_ctl_cmd, "\"%s\" start -D ", pg_ctl_path);
appendShellString(pg_ctl_cmd, subscriber_dir);
- appendPQExpBuffer(pg_ctl_cmd, " -s -o \"-c sync_replication_slots=off\"");
+ appendPQExpBufferStr(pg_ctl_cmd, " -s -o \"-c sync_replication_slots=off\"");
/* Prevent unintended slot invalidation */
appendPQExpBufferStr(pg_ctl_cmd, " -o \"-c idle_replication_slot_timeout=0\"");
*/
if (with_child_tables)
{
- appendPQExpBuffer(query, "WITH RECURSIVE partition_tree (relid) AS (\n");
+ appendPQExpBufferStr(query, "WITH RECURSIVE partition_tree (relid) AS (\n");
}
appendPQExpBuffer(query,
if (with_child_tables)
{
- appendPQExpBuffer(query, "UNION"
- "\nSELECT i.inhrelid"
- "\nFROM partition_tree p"
- "\n JOIN pg_catalog.pg_inherits i"
- "\n ON p.relid OPERATOR(pg_catalog.=) i.inhparent"
- "\n)"
- "\nSELECT relid FROM partition_tree");
+ appendPQExpBufferStr(query, "UNION"
+ "\nSELECT i.inhrelid"
+ "\nFROM partition_tree p"
+ "\n JOIN pg_catalog.pg_inherits i"
+ "\n ON p.relid OPERATOR(pg_catalog.=) i.inhparent"
+ "\n)"
+ "\nSELECT relid FROM partition_tree");
}
ExecuteSqlStatement(fout, "RESET search_path");
appendPQExpBufferStr(query,
" s.subfailover\n");
else
- appendPQExpBuffer(query,
- " false AS subfailover\n");
+ appendPQExpBufferStr(query,
+ " false AS subfailover\n");
appendPQExpBufferStr(query,
"FROM pg_subscription s\n");
if (subrinfo->srsublsn && subrinfo->srsublsn[0] != '\0')
appendPQExpBuffer(query, ", '%s'", subrinfo->srsublsn);
else
- appendPQExpBuffer(query, ", NULL");
+ appendPQExpBufferStr(query, ", NULL");
appendPQExpBufferStr(query, ");\n");
}
appendPQExpBufferStr(query, ", disable_on_error = true");
if (!subinfo->subpasswordrequired)
- appendPQExpBuffer(query, ", password_required = false");
+ appendPQExpBufferStr(query, ", password_required = false");
if (subinfo->subrunasowner)
appendPQExpBufferStr(query, ", run_as_owner = true");
{
if (optbuf->data[0] != '\0')
appendPQExpBufferStr(optbuf, ", ");
- appendPQExpBuffer(optbuf, "SET FALSE");
+ appendPQExpBufferStr(optbuf, "SET FALSE");
}
if (optbuf->data[0] != '\0')
fprintf(OPF, " WITH %s", optbuf->data);
LogicalSlotInfo *slot_info = &slot_arr->slots[slotnum];
/* Constructs a query for creating logical replication slots */
- appendPQExpBuffer(query,
- "SELECT * FROM "
- "pg_catalog.pg_create_logical_replication_slot(");
+ appendPQExpBufferStr(query,
+ "SELECT * FROM "
+ "pg_catalog.pg_create_logical_replication_slot(");
appendStringLiteralConn(query, slot_info->slotname, conn);
- appendPQExpBuffer(query, ", ");
+ appendPQExpBufferStr(query, ", ");
appendStringLiteralConn(query, slot_info->plugin, conn);
appendPQExpBuffer(query, ", false, %s, %s);",
char *escname;
if (i > 0)
- appendPQExpBufferStr(&buf, ",");
+ appendPQExpBufferChar(&buf, ',');
name = PQfname(result, i);
escname = PQescapeLiteral(pset.db, name, strlen(name));
if (objects_listed)
{
if (objfilter & OBJFILTER_SCHEMA_EXCLUDE)
- appendPQExpBuffer(&catalog_query,
- " AND listed_objects.object_oid IS NULL\n");
+ appendPQExpBufferStr(&catalog_query,
+ " AND listed_objects.object_oid IS NULL\n");
else
- appendPQExpBuffer(&catalog_query,
- " AND listed_objects.object_oid IS NOT NULL\n");
+ appendPQExpBufferStr(&catalog_query,
+ " AND listed_objects.object_oid IS NOT NULL\n");
}
/*
*/
if ((objfilter & OBJFILTER_TABLE) == 0)
{
- appendPQExpBuffer(&catalog_query,
- " AND c.relkind OPERATOR(pg_catalog.=) ANY (array["
- CppAsString2(RELKIND_RELATION) ", "
- CppAsString2(RELKIND_MATVIEW) "])\n");
+ appendPQExpBufferStr(&catalog_query,
+ " AND c.relkind OPERATOR(pg_catalog.=) ANY (array["
+ CppAsString2(RELKIND_RELATION) ", "
+ CppAsString2(RELKIND_MATVIEW) "])\n");
}
/*