multi_cluster_management errors: ambiguous collation in LIKE

m3hm3t/pg18_rel_oid_2
Mehmet Yilmaz 2025-06-13 14:27:18 +00:00
parent 6220ff57e8
commit 5fe3aa296e
2 changed files with 6 additions and 4 deletions

View File

@ -371,8 +371,9 @@ CommandMatchesLogGrepPattern(const char *command)
if (GrepRemoteCommands && strnlen(GrepRemoteCommands, NAMEDATALEN) > 0) if (GrepRemoteCommands && strnlen(GrepRemoteCommands, NAMEDATALEN) > 0)
{ {
Datum boolDatum = Datum boolDatum =
DirectFunctionCall2(textlike, CStringGetTextDatum(command), DirectFunctionCall2Coll(textlike, DEFAULT_COLLATION_OID,
CStringGetTextDatum(GrepRemoteCommands)); CStringGetTextDatum(command),
CStringGetTextDatum(GrepRemoteCommands));
return DatumGetBool(boolDatum); return DatumGetBool(boolDatum);
} }

View File

@ -514,8 +514,9 @@ PendingWorkerTransactionList(MultiConnection *connection)
List *transactionNames = NIL; List *transactionNames = NIL;
int32 coordinatorId = GetLocalGroupId(); int32 coordinatorId = GetLocalGroupId();
appendStringInfo(command, "SELECT gid FROM pg_prepared_xacts " appendStringInfo(command,
"WHERE gid LIKE 'citus\\_%d\\_%%' and database = current_database()", "SELECT gid FROM pg_prepared_xacts "
"WHERE gid COLLATE pg_catalog.default LIKE 'citus\\_%d\\_%%' COLLATE pg_catalog.default AND database = current_database()",
coordinatorId); coordinatorId);
int querySent = SendRemoteCommand(connection, command->data); int querySent = SendRemoteCommand(connection, command->data);