From a31f24ec08b19056184d5da4d1d27f92b87451eb Mon Sep 17 00:00:00 2001
From: Karina Litskevich <litskevichkarina@gmail.com>
Date: Fri, 9 Aug 2024 13:10:23 +0300
Subject: [PATCH] Avoid using backslash in SQL string literals

---
 src/backend/columnar/sql/citus_columnar--11.1-1.sql           | 2 +-
 src/backend/columnar/sql/columnar--10.0-3--10.1-1.sql         | 2 +-
 src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql          | 2 +-
 .../columnar/sql/downgrades/columnar--10.0-1--9.5-1.sql       | 2 +-
 .../sql/udfs/columnar_ensure_objects_exist/10.0-1.sql         | 2 +-
 .../sql/udfs/columnar_ensure_objects_exist/latest.sql         | 2 +-
 src/backend/distributed/sql/citus--8.0-1.sql                  | 2 +-
 src/backend/distributed/sql/udfs/any_value/9.1-1.sql          | 2 +-
 src/backend/distributed/sql/udfs/any_value/latest.sql         | 2 +-
 .../sql/udfs/citus_finish_citus_upgrade/11.0-2.sql            | 2 +-
 .../sql/udfs/citus_finish_citus_upgrade/latest.sql            | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/10.2-1.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/10.2-4.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/10.2-5.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/11.0-1.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/11.0-4.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/11.1-1.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/11.2-1.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/12.0-1.sql   | 2 +-
 .../distributed/sql/udfs/citus_finish_pg_upgrade/12.1-1.sql   | 4 ++--
 .../distributed/sql/udfs/citus_finish_pg_upgrade/12.2-1.sql   | 4 ++--
 .../distributed/sql/udfs/citus_finish_pg_upgrade/latest.sql   | 4 ++--
 src/backend/distributed/sql/udfs/citus_shards/10.1-1.sql      | 2 +-
 src/backend/distributed/sql/udfs/citus_shards/11.1-1.sql      | 2 +-
 src/backend/distributed/transaction/transaction_recovery.c    | 2 +-
 25 files changed, 28 insertions(+), 28 deletions(-)

diff --git a/src/backend/columnar/sql/citus_columnar--11.1-1.sql b/src/backend/columnar/sql/citus_columnar--11.1-1.sql
index c1081aba29d..1ab06beee01 100644
--- a/src/backend/columnar/sql/citus_columnar--11.1-1.sql
+++ b/src/backend/columnar/sql/citus_columnar--11.1-1.sql
@@ -71,7 +71,7 @@ BEGIN
 -- from version 12 and up we have support for tableam's if installed on pg11 we can't
 -- create the objects here. Instead we rely on citus_finish_pg_upgrade to be called by the
 -- user instead to add the missing objects
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
   EXECUTE $$
 --#include "udfs/columnar_handler/10.0-1.sql"
 CREATE OR REPLACE FUNCTION columnar.columnar_handler(internal)
diff --git a/src/backend/columnar/sql/columnar--10.0-3--10.1-1.sql b/src/backend/columnar/sql/columnar--10.0-3--10.1-1.sql
index f4429a985fe..b70f3f664c7 100644
--- a/src/backend/columnar/sql/columnar--10.0-3--10.1-1.sql
+++ b/src/backend/columnar/sql/columnar--10.0-3--10.1-1.sql
@@ -4,7 +4,7 @@
 -- Postgres assigns different names to those foreign keys in PG11, so act accordingly.
 DO $proc$
 BEGIN
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
   EXECUTE $$
 ALTER TABLE columnar.chunk DROP CONSTRAINT chunk_storage_id_stripe_num_chunk_group_num_fkey;
 ALTER TABLE columnar.chunk_group DROP CONSTRAINT chunk_group_storage_id_stripe_num_fkey;
diff --git a/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql b/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql
index eeec28584d8..6e90a77cf5c 100644
--- a/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql
+++ b/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql
@@ -67,7 +67,7 @@ BEGIN
 -- from version 12 and up we have support for tableam's if installed on pg11 we can't
 -- create the objects here. Instead we rely on citus_finish_pg_upgrade to be called by the
 -- user instead to add the missing objects
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
   EXECUTE $$
 #include "udfs/columnar_handler/10.0-1.sql"
 #include "udfs/alter_columnar_table_set/10.0-1.sql"
diff --git a/src/backend/columnar/sql/downgrades/columnar--10.0-1--9.5-1.sql b/src/backend/columnar/sql/downgrades/columnar--10.0-1--9.5-1.sql
index bb856e78913..cba55abc50a 100644
--- a/src/backend/columnar/sql/downgrades/columnar--10.0-1--9.5-1.sql
+++ b/src/backend/columnar/sql/downgrades/columnar--10.0-1--9.5-1.sql
@@ -5,7 +5,7 @@ SET search_path TO columnar;
 DO $proc$
 BEGIN
 
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
   EXECUTE $$
     DROP FUNCTION pg_catalog.alter_columnar_table_reset(
         table_name regclass,
diff --git a/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/10.0-1.sql b/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/10.0-1.sql
index f8d21103ad2..be98bdfc84a 100644
--- a/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/10.0-1.sql
+++ b/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/10.0-1.sql
@@ -15,7 +15,7 @@ BEGIN
 
 -- when postgres is version 12 or above we need to create the tableam. If the tableam
 -- exist we assume all objects have been created.
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
 IF NOT EXISTS (SELECT 1 FROM pg_am WHERE amname = 'columnar') THEN
 
 #include "../columnar_handler/10.0-1.sql"
diff --git a/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/latest.sql b/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/latest.sql
index f8d21103ad2..be98bdfc84a 100644
--- a/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/latest.sql
+++ b/src/backend/columnar/sql/udfs/columnar_ensure_objects_exist/latest.sql
@@ -15,7 +15,7 @@ BEGIN
 
 -- when postgres is version 12 or above we need to create the tableam. If the tableam
 -- exist we assume all objects have been created.
-IF substring(current_Setting('server_version'), '\d+')::int >= 12 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 12 THEN
 IF NOT EXISTS (SELECT 1 FROM pg_am WHERE amname = 'columnar') THEN
 
 #include "../columnar_handler/10.0-1.sql"
diff --git a/src/backend/distributed/sql/citus--8.0-1.sql b/src/backend/distributed/sql/citus--8.0-1.sql
index baac9dd4257..437c460f260 100644
--- a/src/backend/distributed/sql/citus--8.0-1.sql
+++ b/src/backend/distributed/sql/citus--8.0-1.sql
@@ -323,7 +323,7 @@ CREATE TRIGGER dist_shard_cache_invalidate
 
 DO $proc$
 BEGIN
-IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $$
 CREATE AGGREGATE array_cat_agg(anycompatiblearray) (SFUNC = array_cat, STYPE = anycompatiblearray);
 COMMENT ON AGGREGATE array_cat_agg(anycompatiblearray)
diff --git a/src/backend/distributed/sql/udfs/any_value/9.1-1.sql b/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
index 4a7748fea18..a40b8507adf 100644
--- a/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
+++ b/src/backend/distributed/sql/udfs/any_value/9.1-1.sql
@@ -1,7 +1,7 @@
 DO $proc$
 BEGIN
 -- PG16 has its own any_value, so only create it pre PG16.
-IF substring(current_Setting('server_version'), '\d+')::int < 16 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int < 16 THEN
     EXECUTE $$
 
 CREATE OR REPLACE FUNCTION pg_catalog.any_value_agg ( anyelement, anyelement )
diff --git a/src/backend/distributed/sql/udfs/any_value/latest.sql b/src/backend/distributed/sql/udfs/any_value/latest.sql
index 4a7748fea18..a40b8507adf 100644
--- a/src/backend/distributed/sql/udfs/any_value/latest.sql
+++ b/src/backend/distributed/sql/udfs/any_value/latest.sql
@@ -1,7 +1,7 @@
 DO $proc$
 BEGIN
 -- PG16 has its own any_value, so only create it pre PG16.
-IF substring(current_Setting('server_version'), '\d+')::int < 16 THEN
+IF substring(current_Setting('server_version'), '[0-9]+')::int < 16 THEN
     EXECUTE $$
 
 CREATE OR REPLACE FUNCTION pg_catalog.any_value_agg ( anyelement, anyelement )
diff --git a/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/11.0-2.sql b/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/11.0-2.sql
index b64f1ffa85b..f131297cebb 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/11.0-2.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/11.0-2.sql
@@ -18,7 +18,7 @@ BEGIN
 	FROM pg_dist_node_metadata;
 
 	SELECT r[1], r[2], r[3]
-	FROM regexp_matches(last_upgrade_version_string,'([0-9]+)\.([0-9]+)-([0-9]+)','') r
+	FROM regexp_matches(last_upgrade_version_string,'([0-9]+)[.]([0-9]+)-([0-9]+)','') r
 	INTO last_upgrade_major_version, last_upgrade_minor_version, last_upgrade_sqlpatch_version;
 
 	IF last_upgrade_major_version IS NULL OR last_upgrade_minor_version IS NULL OR last_upgrade_sqlpatch_version IS NULL THEN
diff --git a/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/latest.sql b/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/latest.sql
index b64f1ffa85b..f131297cebb 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/latest.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_citus_upgrade/latest.sql
@@ -18,7 +18,7 @@ BEGIN
 	FROM pg_dist_node_metadata;
 
 	SELECT r[1], r[2], r[3]
-	FROM regexp_matches(last_upgrade_version_string,'([0-9]+)\.([0-9]+)-([0-9]+)','') r
+	FROM regexp_matches(last_upgrade_version_string,'([0-9]+)[.]([0-9]+)-([0-9]+)','') r
 	INTO last_upgrade_major_version, last_upgrade_minor_version, last_upgrade_sqlpatch_version;
 
 	IF last_upgrade_major_version IS NULL OR last_upgrade_minor_version IS NULL OR last_upgrade_sqlpatch_version IS NULL THEN
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-1.sql
index b66ee76cc05..aafc1bdd38e 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         CREATE AGGREGATE array_cat_agg(anycompatiblearray) (SFUNC = array_cat, STYPE = anycompatiblearray);
         COMMENT ON AGGREGATE array_cat_agg(anycompatiblearray)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-4.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-4.sql
index 2921de9626d..6e7ccf4b21e 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-4.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-4.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         CREATE AGGREGATE array_cat_agg(anycompatiblearray) (SFUNC = array_cat, STYPE = anycompatiblearray);
         COMMENT ON AGGREGATE array_cat_agg(anycompatiblearray)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-5.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-5.sql
index 0f34b874019..734dc995dac 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-5.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/10.2-5.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         CREATE AGGREGATE array_cat_agg(anycompatiblearray) (SFUNC = array_cat, STYPE = anycompatiblearray);
         COMMENT ON AGGREGATE array_cat_agg(anycompatiblearray)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-1.sql
index 2c26356877f..97048e01ee4 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-4.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-4.sql
index 3626c0287b3..2d21cdd764a 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-4.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.0-4.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.1-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.1-1.sql
index 1486f143123..d8b3a007b51 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.1-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.1-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.2-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.2-1.sql
index 448937c289f..0e1ef480bac 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.2-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/11.2-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.0-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.0-1.sql
index 6dd46607a25..83bb17e2c80 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.0-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.0-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.1-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.1-1.sql
index 766e86a2e29..4a98854b44b 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.1-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.1-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
@@ -53,7 +53,7 @@ BEGIN
 
     -- PG16 has its own any_value, so only create it pre PG16.
     -- We can remove this part when we drop support for PG16
-    IF substring(current_Setting('server_version'), '\d+')::int < 16 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int < 16 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.2-1.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.2-1.sql
index 4d3a17bd47a..f7614d5f49b 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.2-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/12.2-1.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
@@ -53,7 +53,7 @@ BEGIN
 
     -- PG16 has its own any_value, so only create it pre PG16.
     -- We can remove this part when we drop support for PG16
-    IF substring(current_Setting('server_version'), '\d+')::int < 16 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int < 16 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/latest.sql b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/latest.sql
index 4d3a17bd47a..f7614d5f49b 100644
--- a/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/latest.sql
+++ b/src/backend/distributed/sql/udfs/citus_finish_pg_upgrade/latest.sql
@@ -10,7 +10,7 @@ DECLARE
 BEGIN
 
 
-    IF substring(current_Setting('server_version'), '\d+')::int >= 14 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int >= 14 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
@@ -53,7 +53,7 @@ BEGIN
 
     -- PG16 has its own any_value, so only create it pre PG16.
     -- We can remove this part when we drop support for PG16
-    IF substring(current_Setting('server_version'), '\d+')::int < 16 THEN
+    IF substring(current_Setting('server_version'), '[0-9]+')::int < 16 THEN
     EXECUTE $cmd$
         -- disable propagation to prevent EnsureCoordinator errors
         -- the aggregate created here does not depend on Citus extension (yet)
diff --git a/src/backend/distributed/sql/udfs/citus_shards/10.1-1.sql b/src/backend/distributed/sql/udfs/citus_shards/10.1-1.sql
index ff98638e7b9..43d856d6817 100644
--- a/src/backend/distributed/sql/udfs/citus_shards/10.1-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_shards/10.1-1.sql
@@ -23,7 +23,7 @@ JOIN
 ON
    pg_dist_partition.logicalrelid = pg_dist_shard.logicalrelid
 LEFT JOIN
-   (SELECT (regexp_matches(table_name,'_(\d+)$'))[1]::int as shard_id, max(size) as size from citus_shard_sizes() GROUP BY shard_id) as shard_sizes
+   (SELECT (regexp_matches(table_name,'_([0-9]+)$'))[1]::int as shard_id, max(size) as size from citus_shard_sizes() GROUP BY shard_id) as shard_sizes
 ON
     pg_dist_shard.shardid = shard_sizes.shard_id
 WHERE
diff --git a/src/backend/distributed/sql/udfs/citus_shards/11.1-1.sql b/src/backend/distributed/sql/udfs/citus_shards/11.1-1.sql
index 08e039899e0..8d24f37c7dd 100644
--- a/src/backend/distributed/sql/udfs/citus_shards/11.1-1.sql
+++ b/src/backend/distributed/sql/udfs/citus_shards/11.1-1.sql
@@ -23,7 +23,7 @@ JOIN
 ON
    pg_dist_partition.logicalrelid = pg_dist_shard.logicalrelid
 LEFT JOIN
-   (SELECT (regexp_matches(table_name,'_(\d+)$'))[1]::int as shard_id, max(size) as size from citus_shard_sizes() GROUP BY shard_id) as shard_sizes
+   (SELECT (regexp_matches(table_name,'_([0-9]+)$'))[1]::int as shard_id, max(size) as size from citus_shard_sizes() GROUP BY shard_id) as shard_sizes
 ON
     pg_dist_shard.shardid = shard_sizes.shard_id
 WHERE
diff --git a/src/backend/distributed/transaction/transaction_recovery.c b/src/backend/distributed/transaction/transaction_recovery.c
index c31dc85a2a9..75191ee7b15 100644
--- a/src/backend/distributed/transaction/transaction_recovery.c
+++ b/src/backend/distributed/transaction/transaction_recovery.c
@@ -474,7 +474,7 @@ PendingWorkerTransactionList(MultiConnection *connection)
 	int32 coordinatorId = GetLocalGroupId();
 
 	appendStringInfo(command, "SELECT gid FROM pg_prepared_xacts "
-							  "WHERE gid LIKE 'citus\\_%d\\_%%' and database = current_database()",
+							  "WHERE gid LIKE 'citus/_%d/_%%' ESCAPE '/' and database = current_database()",
 					 coordinatorId);
 
 	int querySent = SendRemoteCommand(connection, command->data);