diff --git a/src/backend/distributed/commands/database.c b/src/backend/distributed/commands/database.c index cabe69fd6..ce429825e 100644 --- a/src/backend/distributed/commands/database.c +++ b/src/backend/distributed/commands/database.c @@ -669,7 +669,7 @@ GenerateCreateDatabaseCommandList(void) /* Generate the CREATE DATABASE statement */ appendStringInfo(outerDbStmt, - "SELECT pg_catalog.citus_internal_database_command( %s)", + "SELECT pg_catalog.citus_internal_database_command(%s)", quote_literal_cstr( createStmt)); diff --git a/src/backend/distributed/sql/udfs/citus_internal_database_command/latest.sql b/src/backend/distributed/sql/udfs/citus_internal_database_command/latest.sql index b20f6278e..f6aaa4642 100644 --- a/src/backend/distributed/sql/udfs/citus_internal_database_command/latest.sql +++ b/src/backend/distributed/sql/udfs/citus_internal_database_command/latest.sql @@ -5,6 +5,7 @@ CREATE OR REPLACE FUNCTION pg_catalog.citus_internal_database_command(command te RETURNS void LANGUAGE C VOLATILE + STRICT AS 'MODULE_PATHNAME', $$citus_internal_database_command$$; COMMENT ON FUNCTION pg_catalog.citus_internal_database_command(text) IS 'run a database command without transaction block restrictions';