diff --git a/src/backend/commands/vacuum.c b/src/backend/commands/vacuum.c index b9e7624134c69138586d2d744d4b9fe60c982f25..a5235148d49db724b9092eb30c44e3c8e23ac7fb 100644 --- a/src/backend/commands/vacuum.c +++ b/src/backend/commands/vacuum.c @@ -97,6 +97,7 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast, volatile bool in_outer_xact, use_own_xacts; List *relations; + static bool in_vacuum = false; /* sanity checks on options */ Assert(vacstmt->options & (VACOPT_VACUUM | VACOPT_ANALYZE)); @@ -122,6 +123,14 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast, else in_outer_xact = IsInTransactionChain(isTopLevel); + /* + * Due to static variables vac_context, anl_context and vac_strategy, + * vacuum() is not reentrant. This matters when VACUUM FULL or ANALYZE + * calls a hostile index expression that itself calls ANALYZE. + */ + if (in_vacuum) + elog(ERROR, "%s cannot be executed from VACUUM or ANALYZE", stmttype); + /* * Send info about dead objects to the statistics collector, unless we are * in autovacuum --- autovacuum.c does this for itself. @@ -214,6 +223,7 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast, { ListCell *cur; + in_vacuum = true; VacuumCostActive = (VacuumCostDelay > 0); VacuumCostBalance = 0; VacuumPageHit = 0; @@ -258,13 +268,13 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast, } PG_CATCH(); { - /* Make sure cost accounting is turned off after error */ + in_vacuum = false; VacuumCostActive = false; PG_RE_THROW(); } PG_END_TRY(); - /* Turn off vacuum cost accounting */ + in_vacuum = false; VacuumCostActive = false; /* diff --git a/src/test/regress/expected/vacuum.out b/src/test/regress/expected/vacuum.out index f1b8dd0cacf12530f82f38d6f8514b4c963c1b2e..3d15606e9bb95421496660e6440215244b65b564 100644 --- a/src/test/regress/expected/vacuum.out +++ b/src/test/regress/expected/vacuum.out @@ -61,12 +61,24 @@ VACUUM (ANALYZE, FULL) vactst; CREATE TABLE vaccluster (i INT PRIMARY KEY); NOTICE: CREATE TABLE / PRIMARY KEY will create implicit index "vaccluster_pkey" for table "vaccluster" ALTER TABLE vaccluster CLUSTER ON vaccluster_pkey; -INSERT INTO vaccluster SELECT * FROM vactst; CLUSTER vaccluster; +CREATE FUNCTION do_analyze() RETURNS VOID VOLATILE LANGUAGE SQL + AS 'ANALYZE pg_am'; +CREATE FUNCTION wrap_do_analyze(c INT) RETURNS INT IMMUTABLE LANGUAGE SQL + AS 'SELECT $1 FROM do_analyze()'; +CREATE INDEX ON vactst(wrap_do_analyze(i)); +INSERT INTO vactst VALUES (1), (2); +ANALYZE vactst; +ERROR: ANALYZE cannot be executed from VACUUM or ANALYZE +CONTEXT: SQL function "do_analyze" statement 1 +SQL function "wrap_do_analyze" statement 1 VACUUM FULL pg_am; VACUUM FULL pg_class; VACUUM FULL pg_database; VACUUM FULL vaccluster; VACUUM FULL vactst; +ERROR: ANALYZE cannot be executed from VACUUM or ANALYZE +CONTEXT: SQL function "do_analyze" statement 1 +SQL function "wrap_do_analyze" statement 1 DROP TABLE vaccluster; DROP TABLE vactst; diff --git a/src/test/regress/sql/vacuum.sql b/src/test/regress/sql/vacuum.sql index 30551ad1f276bc139de3405dbf2a3f94725bd1ca..4b624fe379eb6986a2cd1e73f5dd72529d163a33 100644 --- a/src/test/regress/sql/vacuum.sql +++ b/src/test/regress/sql/vacuum.sql @@ -44,9 +44,16 @@ VACUUM (ANALYZE, FULL) vactst; CREATE TABLE vaccluster (i INT PRIMARY KEY); ALTER TABLE vaccluster CLUSTER ON vaccluster_pkey; -INSERT INTO vaccluster SELECT * FROM vactst; CLUSTER vaccluster; +CREATE FUNCTION do_analyze() RETURNS VOID VOLATILE LANGUAGE SQL + AS 'ANALYZE pg_am'; +CREATE FUNCTION wrap_do_analyze(c INT) RETURNS INT IMMUTABLE LANGUAGE SQL + AS 'SELECT $1 FROM do_analyze()'; +CREATE INDEX ON vactst(wrap_do_analyze(i)); +INSERT INTO vactst VALUES (1), (2); +ANALYZE vactst; + VACUUM FULL pg_am; VACUUM FULL pg_class; VACUUM FULL pg_database;