mirror of
https://github.com/postgres/postgres.git
synced 2025-04-18 13:44:19 +03:00
Improve various new-to-v18 appendStringInfo calls
Similar to 8461424fd, here we adjust a few new locations which were not using the most suitable appendStringInfo* function for the intended purpose. Author: David Rowley <drowleyml@gmail.com Discussion: https://postgr.es/m/CAApHDvqJnNjueb=Eoj8K+8n0g7nj_AcPWSiCj5RNV4fDejAfqA@mail.gmail.com
This commit is contained in:
parent
55ef7abf88
commit
928394b664
@ -3228,7 +3228,7 @@ appendSCRAMKeysInfo(StringInfo buf)
|
|||||||
|
|
||||||
appendStringInfo(buf, "scram_client_key='%s' ", client_key);
|
appendStringInfo(buf, "scram_client_key='%s' ", client_key);
|
||||||
appendStringInfo(buf, "scram_server_key='%s' ", server_key);
|
appendStringInfo(buf, "scram_server_key='%s' ", server_key);
|
||||||
appendStringInfo(buf, "require_auth='scram-sha-256' ");
|
appendStringInfoString(buf, "require_auth='scram-sha-256' ");
|
||||||
|
|
||||||
pfree(client_key);
|
pfree(client_key);
|
||||||
pfree(server_key);
|
pfree(server_key);
|
||||||
|
@ -292,7 +292,7 @@ overexplain_debug(PlannedStmt *plannedstmt, ExplainState *es)
|
|||||||
if (es->format == EXPLAIN_FORMAT_TEXT)
|
if (es->format == EXPLAIN_FORMAT_TEXT)
|
||||||
{
|
{
|
||||||
ExplainIndentText(es);
|
ExplainIndentText(es);
|
||||||
appendStringInfo(es->str, "PlannedStmt:\n");
|
appendStringInfoString(es->str, "PlannedStmt:\n");
|
||||||
es->indent++;
|
es->indent++;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -329,19 +329,19 @@ overexplain_debug(PlannedStmt *plannedstmt, ExplainState *es)
|
|||||||
/* Print various properties as a comma-separated list of flags. */
|
/* Print various properties as a comma-separated list of flags. */
|
||||||
initStringInfo(&flags);
|
initStringInfo(&flags);
|
||||||
if (plannedstmt->hasReturning)
|
if (plannedstmt->hasReturning)
|
||||||
appendStringInfo(&flags, ", hasReturning");
|
appendStringInfoString(&flags, ", hasReturning");
|
||||||
if (plannedstmt->hasModifyingCTE)
|
if (plannedstmt->hasModifyingCTE)
|
||||||
appendStringInfo(&flags, ", hasModifyingCTE");
|
appendStringInfoString(&flags, ", hasModifyingCTE");
|
||||||
if (plannedstmt->canSetTag)
|
if (plannedstmt->canSetTag)
|
||||||
appendStringInfo(&flags, ", canSetTag");
|
appendStringInfoString(&flags, ", canSetTag");
|
||||||
if (plannedstmt->transientPlan)
|
if (plannedstmt->transientPlan)
|
||||||
appendStringInfo(&flags, ", transientPlan");
|
appendStringInfoString(&flags, ", transientPlan");
|
||||||
if (plannedstmt->dependsOnRole)
|
if (plannedstmt->dependsOnRole)
|
||||||
appendStringInfo(&flags, ", dependsOnRole");
|
appendStringInfoString(&flags, ", dependsOnRole");
|
||||||
if (plannedstmt->parallelModeNeeded)
|
if (plannedstmt->parallelModeNeeded)
|
||||||
appendStringInfo(&flags, ", parallelModeNeeded");
|
appendStringInfoString(&flags, ", parallelModeNeeded");
|
||||||
if (flags.len == 0)
|
if (flags.len == 0)
|
||||||
appendStringInfo(&flags, ", none");
|
appendStringInfoString(&flags, ", none");
|
||||||
ExplainPropertyText("Flags", flags.data + 2, es);
|
ExplainPropertyText("Flags", flags.data + 2, es);
|
||||||
|
|
||||||
/* Various lists of integers. */
|
/* Various lists of integers. */
|
||||||
@ -763,7 +763,7 @@ overexplain_intlist(const char *qlabel, List *list, ExplainState *es)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
appendStringInfo(&buf, " not an integer list");
|
appendStringInfoString(&buf, " not an integer list");
|
||||||
Assert(false);
|
Assert(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1848,7 +1848,7 @@ ExplainNode(PlanState *planstate, List *ancestors,
|
|||||||
|
|
||||||
if (es->format == EXPLAIN_FORMAT_TEXT)
|
if (es->format == EXPLAIN_FORMAT_TEXT)
|
||||||
{
|
{
|
||||||
appendStringInfo(es->str, " (actual ");
|
appendStringInfoString(es->str, " (actual ");
|
||||||
|
|
||||||
if (es->timing)
|
if (es->timing)
|
||||||
appendStringInfo(es->str, "time=%.3f..%.3f ", startup_ms, total_ms);
|
appendStringInfo(es->str, "time=%.3f..%.3f ", startup_ms, total_ms);
|
||||||
@ -1917,7 +1917,7 @@ ExplainNode(PlanState *planstate, List *ancestors,
|
|||||||
if (es->format == EXPLAIN_FORMAT_TEXT)
|
if (es->format == EXPLAIN_FORMAT_TEXT)
|
||||||
{
|
{
|
||||||
ExplainIndentText(es);
|
ExplainIndentText(es);
|
||||||
appendStringInfo(es->str, "actual ");
|
appendStringInfoString(es->str, "actual ");
|
||||||
if (es->timing)
|
if (es->timing)
|
||||||
appendStringInfo(es->str, "time=%.3f..%.3f ", startup_ms, total_ms);
|
appendStringInfo(es->str, "time=%.3f..%.3f ", startup_ms, total_ms);
|
||||||
|
|
||||||
|
@ -1012,7 +1012,7 @@ libpqrcv_alter_slot(WalReceiverConn *conn, const char *slotname,
|
|||||||
*failover ? "true" : "false");
|
*failover ? "true" : "false");
|
||||||
|
|
||||||
if (failover && two_phase)
|
if (failover && two_phase)
|
||||||
appendStringInfo(&cmd, ", ");
|
appendStringInfoString(&cmd, ", ");
|
||||||
|
|
||||||
if (two_phase)
|
if (two_phase)
|
||||||
appendStringInfo(&cmd, "TWO_PHASE %s",
|
appendStringInfo(&cmd, "TWO_PHASE %s",
|
||||||
|
@ -262,7 +262,7 @@ errdetail_apply_conflict(EState *estate, ResultRelInfo *relinfo,
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case CT_UPDATE_MISSING:
|
case CT_UPDATE_MISSING:
|
||||||
appendStringInfo(&err_detail, _("Could not find the row to be updated."));
|
appendStringInfoString(&err_detail, _("Could not find the row to be updated."));
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case CT_DELETE_ORIGIN_DIFFERS:
|
case CT_DELETE_ORIGIN_DIFFERS:
|
||||||
@ -281,7 +281,7 @@ errdetail_apply_conflict(EState *estate, ResultRelInfo *relinfo,
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case CT_DELETE_MISSING:
|
case CT_DELETE_MISSING:
|
||||||
appendStringInfo(&err_detail, _("Could not find the row to be deleted."));
|
appendStringInfoString(&err_detail, _("Could not find the row to be deleted."));
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -304,7 +304,7 @@ errdetail_apply_conflict(EState *estate, ResultRelInfo *relinfo,
|
|||||||
if (err_msg->len > 0)
|
if (err_msg->len > 0)
|
||||||
appendStringInfoChar(err_msg, '\n');
|
appendStringInfoChar(err_msg, '\n');
|
||||||
|
|
||||||
appendStringInfo(err_msg, "%s", err_detail.data);
|
appendStringInfoString(err_msg, err_detail.data);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -238,7 +238,7 @@ logicalrep_get_attrs_str(LogicalRepRelation *remoterel, Bitmapset *atts)
|
|||||||
{
|
{
|
||||||
attcnt++;
|
attcnt++;
|
||||||
if (attcnt > 1)
|
if (attcnt > 1)
|
||||||
appendStringInfo(&attsbuf, _(", "));
|
appendStringInfoString(&attsbuf, _(", "));
|
||||||
|
|
||||||
appendStringInfo(&attsbuf, _("\"%s\""), remoterel->attnames[i]);
|
appendStringInfo(&attsbuf, _("\"%s\""), remoterel->attnames[i]);
|
||||||
}
|
}
|
||||||
|
@ -940,15 +940,15 @@ fetch_remote_table_info(char *nspname, char *relname, LogicalRepRelation *lrel,
|
|||||||
* Now fetch column names and types.
|
* Now fetch column names and types.
|
||||||
*/
|
*/
|
||||||
resetStringInfo(&cmd);
|
resetStringInfo(&cmd);
|
||||||
appendStringInfo(&cmd,
|
appendStringInfoString(&cmd,
|
||||||
"SELECT a.attnum,"
|
"SELECT a.attnum,"
|
||||||
" a.attname,"
|
" a.attname,"
|
||||||
" a.atttypid,"
|
" a.atttypid,"
|
||||||
" a.attnum = ANY(i.indkey)");
|
" a.attnum = ANY(i.indkey)");
|
||||||
|
|
||||||
/* Generated columns can be replicated since version 18. */
|
/* Generated columns can be replicated since version 18. */
|
||||||
if (server_version >= 180000)
|
if (server_version >= 180000)
|
||||||
appendStringInfo(&cmd, ", a.attgenerated != ''");
|
appendStringInfoString(&cmd, ", a.attgenerated != ''");
|
||||||
|
|
||||||
appendStringInfo(&cmd,
|
appendStringInfo(&cmd,
|
||||||
" FROM pg_catalog.pg_attribute a"
|
" FROM pg_catalog.pg_attribute a"
|
||||||
|
@ -428,13 +428,13 @@ RI_FKey_check(TriggerData *trigdata)
|
|||||||
{
|
{
|
||||||
Oid fk_type = RIAttType(fk_rel, riinfo->fk_attnums[riinfo->nkeys - 1]);
|
Oid fk_type = RIAttType(fk_rel, riinfo->fk_attnums[riinfo->nkeys - 1]);
|
||||||
|
|
||||||
appendStringInfo(&querybuf, ") x1 HAVING ");
|
appendStringInfoString(&querybuf, ") x1 HAVING ");
|
||||||
sprintf(paramname, "$%d", riinfo->nkeys);
|
sprintf(paramname, "$%d", riinfo->nkeys);
|
||||||
ri_GenerateQual(&querybuf, "",
|
ri_GenerateQual(&querybuf, "",
|
||||||
paramname, fk_type,
|
paramname, fk_type,
|
||||||
riinfo->agged_period_contained_by_oper,
|
riinfo->agged_period_contained_by_oper,
|
||||||
"pg_catalog.range_agg", ANYMULTIRANGEOID);
|
"pg_catalog.range_agg", ANYMULTIRANGEOID);
|
||||||
appendStringInfo(&querybuf, "(x1.r)");
|
appendStringInfoString(&querybuf, "(x1.r)");
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Prepare and save the plan */
|
/* Prepare and save the plan */
|
||||||
@ -597,13 +597,13 @@ ri_Check_Pk_Match(Relation pk_rel, Relation fk_rel,
|
|||||||
{
|
{
|
||||||
Oid fk_type = RIAttType(fk_rel, riinfo->fk_attnums[riinfo->nkeys - 1]);
|
Oid fk_type = RIAttType(fk_rel, riinfo->fk_attnums[riinfo->nkeys - 1]);
|
||||||
|
|
||||||
appendStringInfo(&querybuf, ") x1 HAVING ");
|
appendStringInfoString(&querybuf, ") x1 HAVING ");
|
||||||
sprintf(paramname, "$%d", riinfo->nkeys);
|
sprintf(paramname, "$%d", riinfo->nkeys);
|
||||||
ri_GenerateQual(&querybuf, "",
|
ri_GenerateQual(&querybuf, "",
|
||||||
paramname, fk_type,
|
paramname, fk_type,
|
||||||
riinfo->agged_period_contained_by_oper,
|
riinfo->agged_period_contained_by_oper,
|
||||||
"pg_catalog.range_agg", ANYMULTIRANGEOID);
|
"pg_catalog.range_agg", ANYMULTIRANGEOID);
|
||||||
appendStringInfo(&querybuf, "(x1.r)");
|
appendStringInfoString(&querybuf, "(x1.r)");
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Prepare and save the plan */
|
/* Prepare and save the plan */
|
||||||
@ -838,12 +838,12 @@ ri_restrict(TriggerData *trigdata, bool is_no_action)
|
|||||||
|
|
||||||
/* Intersect the fk with the old pk range */
|
/* Intersect the fk with the old pk range */
|
||||||
initStringInfo(&intersectbuf);
|
initStringInfo(&intersectbuf);
|
||||||
appendStringInfoString(&intersectbuf, "(");
|
appendStringInfoChar(&intersectbuf, '(');
|
||||||
ri_GenerateQual(&intersectbuf, "",
|
ri_GenerateQual(&intersectbuf, "",
|
||||||
attname, fk_period_type,
|
attname, fk_period_type,
|
||||||
riinfo->period_intersect_oper,
|
riinfo->period_intersect_oper,
|
||||||
paramname, pk_period_type);
|
paramname, pk_period_type);
|
||||||
appendStringInfoString(&intersectbuf, ")");
|
appendStringInfoChar(&intersectbuf, ')');
|
||||||
|
|
||||||
/* Find the remaining history */
|
/* Find the remaining history */
|
||||||
initStringInfo(&replacementsbuf);
|
initStringInfo(&replacementsbuf);
|
||||||
|
@ -1312,7 +1312,7 @@ process_global_sql_commands(PGconn *conn, const char *dumpdirpath, const char *o
|
|||||||
appendStringInfoString(&user_create, "CREATE ROLE ");
|
appendStringInfoString(&user_create, "CREATE ROLE ");
|
||||||
/* should use fmtId here, but we don't know the encoding */
|
/* should use fmtId here, but we don't know the encoding */
|
||||||
appendStringInfoString(&user_create, PQuser(conn));
|
appendStringInfoString(&user_create, PQuser(conn));
|
||||||
appendStringInfoString(&user_create, ";");
|
appendStringInfoChar(&user_create, ';');
|
||||||
|
|
||||||
/* Process file till EOF and execute sql statements. */
|
/* Process file till EOF and execute sql statements. */
|
||||||
while (read_one_statement(&sqlstatement, pfile) != EOF)
|
while (read_one_statement(&sqlstatement, pfile) != EOF)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user