postgres
diff --git a/‎src/backend/commands/prepare.c
Copy file name to clipboardExpand all lines: src/backend/commands/prepare.c
+11-7Lines changed: 11 additions & 7 deletions b/‎src/backend/commands/prepare.c
Copy file name to clipboardExpand all lines: src/backend/commands/prepare.c
+11-7Lines changed: 11 additions & 7 deletions
@@ -234,6 +234,17 @@ ExecuteQuery(ExecuteStmt *stmt, IntoClause *intoClause,
 	cplan = GetCachedPlan(entry->plansource, paramLI, false);
 	plan_list = cplan->stmt_list;
 
+	/*
+	 * DO NOT add any logic that could possibly throw an error between
+	 * GetCachedPlan and PortalDefineQuery, or you'll leak the plan refcount.
+	 */
+	PortalDefineQuery(portal,
+					  NULL,
+					  query_string,
+					  entry->plansource->commandTag,
+					  plan_list,
+					  cplan);
+
 	/*
 	 * For CREATE TABLE ... AS EXECUTE, we must verify that the prepared
 	 * statement is one that produces tuples.  Currently we insist that it be
@@ -279,13 +290,6 @@ ExecuteQuery(ExecuteStmt *stmt, IntoClause *intoClause,
 		count = FETCH_ALL;
 	}
 
-	PortalDefineQuery(portal,
-					  NULL,
-					  query_string,
-					  entry->plansource->commandTag,
-					  plan_list,
-					  cplan);
-
 	/*
 	 * Run the portal as appropriate.
 	 */