break;
case TRANS_STMT_COMMIT_PREPARED:
- PreventTransactionChain(isTopLevel, "COMMIT PREPARED");
+ PreventInTransactionBlock(isTopLevel, "COMMIT PREPARED");
PreventCommandDuringRecovery("COMMIT PREPARED");
FinishPreparedTransaction(stmt->gid, true);
break;
case TRANS_STMT_ROLLBACK_PREPARED:
- PreventTransactionChain(isTopLevel, "ROLLBACK PREPARED");
+ PreventInTransactionBlock(isTopLevel, "ROLLBACK PREPARED");
PreventCommandDuringRecovery("ROLLBACK PREPARED");
FinishPreparedTransaction(stmt->gid, false);
break;
ListCell *cell;
char *name = NULL;
- RequireTransactionChain(isTopLevel, "SAVEPOINT");
+ RequireTransactionBlock(isTopLevel, "SAVEPOINT");
foreach(cell, stmt->options)
{
break;
case TRANS_STMT_RELEASE:
- RequireTransactionChain(isTopLevel, "RELEASE SAVEPOINT");
+ RequireTransactionBlock(isTopLevel, "RELEASE SAVEPOINT");
ReleaseSavepoint(stmt->options);
break;
case TRANS_STMT_ROLLBACK_TO:
- RequireTransactionChain(isTopLevel, "ROLLBACK TO SAVEPOINT");
+ RequireTransactionBlock(isTopLevel, "ROLLBACK TO SAVEPOINT");
RollbackToSavepoint(stmt->options);
/*
case T_CreateTableSpaceStmt:
/* no event triggers for global objects */
- PreventTransactionChain(isTopLevel, "CREATE TABLESPACE");
+ PreventInTransactionBlock(isTopLevel, "CREATE TABLESPACE");
CreateTableSpace((CreateTableSpaceStmt *) parsetree);
break;
case T_DropTableSpaceStmt:
/* no event triggers for global objects */
- PreventTransactionChain(isTopLevel, "DROP TABLESPACE");
+ PreventInTransactionBlock(isTopLevel, "DROP TABLESPACE");
DropTableSpace((DropTableSpaceStmt *) parsetree);
break;
case T_CreatedbStmt:
/* no event triggers for global objects */
- PreventTransactionChain(isTopLevel, "CREATE DATABASE");
+ PreventInTransactionBlock(isTopLevel, "CREATE DATABASE");
createdb(pstate, (CreatedbStmt *) parsetree);
break;
DropdbStmt *stmt = (DropdbStmt *) parsetree;
/* no event triggers for global objects */
- PreventTransactionChain(isTopLevel, "DROP DATABASE");
+ PreventInTransactionBlock(isTopLevel, "DROP DATABASE");
dropdb(stmt->dbname, stmt->missing_ok);
}
break;
break;
case T_AlterSystemStmt:
- PreventTransactionChain(isTopLevel, "ALTER SYSTEM");
+ PreventInTransactionBlock(isTopLevel, "ALTER SYSTEM");
AlterSystemSetConfigFile((AlterSystemStmt *) parsetree);
break;
* Since the lock would just get dropped immediately, LOCK TABLE
* outside a transaction block is presumed to be user error.
*/
- RequireTransactionChain(isTopLevel, "LOCK TABLE");
+ RequireTransactionBlock(isTopLevel, "LOCK TABLE");
/* forbidden in parallel mode due to CommandIsReadOnly */
LockTableCommand((LockStmt *) parsetree);
break;
case T_ConstraintsSetStmt:
- WarnNoTransactionChain(isTopLevel, "SET CONSTRAINTS");
+ WarnNoTransactionBlock(isTopLevel, "SET CONSTRAINTS");
AfterTriggerSetState((ConstraintsSetStmt *) parsetree);
break;
* start-transaction-command calls would not have the
* intended effect!
*/
- PreventTransactionChain(isTopLevel,
+ PreventInTransactionBlock(isTopLevel,
(stmt->kind == REINDEX_OBJECT_SCHEMA) ? "REINDEX SCHEMA" :
(stmt->kind == REINDEX_OBJECT_SYSTEM) ? "REINDEX SYSTEM" :
"REINDEX DATABASE");
List *inheritors = NIL;
if (stmt->concurrent)
- PreventTransactionChain(isTopLevel,
+ PreventInTransactionBlock(isTopLevel,
"CREATE INDEX CONCURRENTLY");
/*
{
case OBJECT_INDEX:
if (stmt->concurrent)
- PreventTransactionChain(isTopLevel,
+ PreventInTransactionBlock(isTopLevel,
"DROP INDEX CONCURRENTLY");
/* fall through */