<!--
-$Header: /cvsroot/pgsql/doc/src/sgml/ref/create_table.sgml,v 1.57 2002/11/09 23:56:38 momjian Exp $
+$Header: /cvsroot/pgsql/doc/src/sgml/ref/create_table.sgml,v 1.58 2002/11/11 22:19:20 tgl Exp $
PostgreSQL documentation
-->
| <replaceable>table_constraint</replaceable> } [, ... ]
)
[ INHERITS ( <replaceable>parent_table</replaceable> [, ... ] ) ]
-[ WITH OIDS | WITHOUT OIDS ] [ON COMMIT { PRESERVE ROWS | DELETE ROWS | DROP } ]
+[ WITH OIDS | WITHOUT OIDS ]
+[ ON COMMIT { PRESERVE ROWS | DELETE ROWS | DROP } ]
where <replaceable class="PARAMETER">column_constraint</replaceable> is:
<para>
If specified, the table is created as a temporary table.
Temporary tables are automatically dropped at the end of a
- session or optionally at the end of the current transaction
- (See ON COMMIT below). Existing permanent tables with the same
+ session, or optionally at the end of the current transaction
+ (see ON COMMIT below). Existing permanent tables with the same
name are not visible to the current session while the temporary
table exists, unless they are referenced with schema-qualified
names. Any indexes created on a temporary table are automatically
<term><literal>ON COMMIT</literal></term>
<listitem>
<para>
- The behaviour of temporary tables at the end of a transaction
+ The behavior of temporary tables at the end of a transaction
block can be controlled using <literal>ON COMMIT</literal>.
- The table will exhibit the same behavior at the end of
- transaction blocks for the duration of the session unless
- ON COMMIT DROP is specified or the temporary table is dropped.
- </para>
- <para>
- The three parameters to ON COMMIT are:
+ The three options are:
<variablelist>
<varlistentry>
<term><literal>PRESERVE ROWS</literal></term>
<listitem>
<para>
- The rows in the temporary table will persist after the
- transaction block.
+ No special action is taken at the ends of transactions.
+ This is the default behavior.
</para>
</listitem>
</varlistentry>
<term><literal>DELETE ROWS</literal></term>
<listitem>
<para>
- All rows in the temporary table will be deleted at the
- end of the transaction block.
+ All rows in the temporary table will be deleted at the
+ end of each transaction block. Essentially, an automatic
+ <xref linkend="sql-truncate"> is done at each commit.
</para>
</listitem>
</varlistentry>
<term><literal>DROP</literal></term>
<listitem>
<para>
- The temporary table will be dropped at the end of the transaction.
+ The temporary table will be dropped at the end of the current
+ transaction block.
</para>
</listitem>
</varlistentry>
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/access/transam/xact.c,v 1.136 2002/11/09 23:56:38 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/access/transam/xact.c,v 1.137 2002/11/11 22:19:20 tgl Exp $
*
* NOTES
* Transaction aborts can now occur two ways:
*/
DeferredTriggerEndXact();
+ /*
+ * Similarly, let ON COMMIT management do its thing before we start
+ * to commit.
+ */
+ PreCommit_on_commit_actions();
+
/* Prevent cancel/die interrupt while cleaning up */
HOLD_INTERRUPTS();
AtEOXact_hash();
AtEOXact_nbtree();
AtEOXact_rtree();
- AtEOXact_temp_relations(true,s->blockState);
+ AtEOXact_on_commit_actions(true);
AtEOXact_Namespace(true);
AtEOXact_CatCache(true);
AtEOXact_Files();
AtEOXact_hash();
AtEOXact_nbtree();
AtEOXact_rtree();
- AtEOXact_temp_relations(false,s->blockState);
+ AtEOXact_on_commit_actions(false);
AtEOXact_Namespace(false);
AtEOXact_CatCache(false);
AtEOXact_Files();
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/bootstrap/bootparse.y,v 1.54 2002/11/09 23:56:38 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/bootstrap/bootparse.y,v 1.55 2002/11/11 22:19:21 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "catalog/pg_class.h"
#include "catalog/pg_namespace.h"
#include "commands/defrem.h"
-#include "commands/tablecmds.h"
#include "miscadmin.h"
#include "nodes/makefuncs.h"
#include "nodes/nodes.h"
tupdesc,
RELKIND_RELATION,
$3,
- ATEOXACTNOOP,
+ ONCOMMIT_NOOP,
true);
elog(DEBUG3, "relation created with oid %u", id);
}
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/catalog/heap.c,v 1.233 2002/11/09 23:56:39 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/catalog/heap.c,v 1.234 2002/11/11 22:19:21 tgl Exp $
*
*
* INTERFACE ROUTINES
#include "access/heapam.h"
#include "access/genam.h"
-#include "access/xact.h"
#include "catalog/catalog.h"
#include "catalog/catname.h"
#include "catalog/dependency.h"
#include "catalog/heap.h"
#include "catalog/index.h"
#include "catalog/indexing.h"
-#include "catalog/namespace.h"
#include "catalog/pg_attrdef.h"
#include "catalog/pg_constraint.h"
#include "catalog/pg_inherits.h"
* creates a new cataloged relation. see comments above.
* --------------------------------
*/
-
Oid
heap_create_with_catalog(const char *relname,
Oid relnamespace,
TupleDesc tupdesc,
char relkind,
bool shared_relation,
- char ateoxact, /* Only used for temp relations */
+ OnCommitAction oncommit,
bool allow_system_table_mods)
{
Relation pg_class_desc;
/* Assign an OID for the relation's tuple type */
new_type_oid = newoid();
-
- /*
- * Add to temprels if we are a temp relation now that we have oid
- */
-
- if(isTempNamespace(relnamespace)) {
- TempTable *t;
- MemoryContext oldcxt;
-
- oldcxt = MemoryContextSwitchTo(CacheMemoryContext);
- t = (TempTable *) palloc(sizeof(TempTable));
- t->relid = new_rel_oid;
- t->ateoxact = ateoxact;
- t->tid = GetCurrentTransactionId();
- t->dead = false;
- reg_temp_rel(t);
- MemoryContextSwitchTo(oldcxt);
- }
-
/*
* now create an entry in pg_class for the relation.
*
*/
StoreConstraints(new_rel_desc, tupdesc);
+ /*
+ * If there's a special on-commit action, remember it
+ */
+ if (oncommit != ONCOMMIT_NOOP)
+ register_on_commit_action(new_rel_oid, oncommit);
+
/*
* ok, the relation has been cataloged, so close our relations and
* return the oid of the newly created relation.
*/
DeleteRelationTuple(RelationGetRelid(rel));
+ /*
+ * forget any ON COMMIT action for the rel
+ */
+ remove_on_commit_action(rid);
+
/*
* unlink the relation's physical file and finish up.
*/
rel->rd_rel->relkind != RELKIND_COMPOSITE_TYPE)
smgrunlink(DEFAULT_SMGR, rel);
- /*
- * Keep temprels up to date so that we don't have ON COMMIT execution
- * problems at the end of the next transaction block
- */
-
- if(isTempNamespace(RelationGetNamespace(rel)))
- rm_temp_rel(rid);
-
/*
* Close relcache entry, but *keep* AccessExclusiveLock on the
* relation until transaction commit. This ensures no one else will
*
* This routine is used to truncate the data from the
* storage manager of any data within the relation handed
- * to this routine.
+ * to this routine. This is not transaction-safe!
*/
void
heap_truncate(Oid rid)
{
Relation rel;
+ Oid toastrelid;
/* Open relation for processing, and grab exclusive access on it. */
rel = heap_open(rid, AccessExclusiveLock);
/* If this relation has indexes, truncate the indexes too */
RelationTruncateIndexes(rid);
+ /* If it has a toast table, recursively truncate that too */
+ toastrelid = rel->rd_rel->reltoastrelid;
+ if (OidIsValid(toastrelid))
+ heap_truncate(toastrelid);
+
/*
* Close the relation, but keep exclusive lock on it until commit.
*/
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/catalog/namespace.c,v 1.39 2002/11/09 23:56:39 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/catalog/namespace.c,v 1.40 2002/11/11 22:19:21 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "catalog/pg_proc.h"
#include "catalog/pg_shadow.h"
#include "catalog/pg_type.h"
-#include "commands/tablecmds.h"
#include "lib/stringinfo.h"
#include "miscadmin.h"
#include "nodes/makefuncs.h"
CommitTransactionCommand(true);
}
- free_temp_rels();
}
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/cluster.c,v 1.92 2002/11/09 23:56:39 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/cluster.c,v 1.93 2002/11/11 22:19:21 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "catalog/index.h"
#include "catalog/indexing.h"
#include "catalog/catname.h"
-#include "catalog/namespace.h"
#include "commands/cluster.h"
#include "commands/tablecmds.h"
#include "miscadmin.h"
tupdesc,
OldHeap->rd_rel->relkind,
OldHeap->rd_rel->relisshared,
- ATEOXACTNOOP,
+ ONCOMMIT_NOOP,
allowSystemTableMods);
/*
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/sequence.c,v 1.89 2002/11/10 00:10:20 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/sequence.c,v 1.90 2002/11/11 22:19:21 tgl Exp $
*
*-------------------------------------------------------------------------
*/
stmt->inhRelations = NIL;
stmt->constraints = NIL;
stmt->hasoids = false;
+ stmt->oncommit = ONCOMMIT_NOOP;
seqoid = DefineRelation(stmt, RELKIND_SEQUENCE);
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/tablecmds.c,v 1.52 2002/11/09 23:56:39 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/tablecmds.c,v 1.53 2002/11/11 22:19:21 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
-#include "access/xact.h"
#include "access/genam.h"
#include "access/tuptoaster.h"
#include "catalog/catalog.h"
#include "utils/relcache.h"
#include "utils/syscache.h"
-static List *temprels = NIL;
+
+/*
+ * ON COMMIT action list
+ */
+typedef struct OnCommitItem
+{
+ Oid relid; /* relid of relation */
+ OnCommitAction oncommit; /* what to do at end of xact */
+
+ /*
+ * If this entry was created during this xact, it should be deleted at
+ * xact abort. Conversely, if this entry was deleted during this
+ * xact, it should be removed at xact commit. We leave deleted
+ * entries in the list until commit so that we can roll back if needed.
+ */
+ bool created_in_cur_xact;
+ bool deleted_in_cur_xact;
+} OnCommitItem;
+
+static List *on_commits = NIL;
+
static List *MergeAttributes(List *schema, List *supers, bool istemp,
List **supOids, List **supconstr, bool *supHasOids);
int i;
AttrNumber attnum;
-
/*
* Truncate relname to appropriate length (probably a waste of time,
* as parser should have done this already).
*/
StrNCpy(relname, stmt->relation->relname, NAMEDATALEN);
+ /*
+ * Check consistency of arguments
+ */
+ if (stmt->oncommit != ONCOMMIT_NOOP && !stmt->relation->istemp)
+ elog(ERROR, "ON COMMIT can only be used on TEMP tables");
+
/*
* Look up the namespace in which we are supposed to create the
* relation. Check we have permission to create there. Skip check if
descriptor,
relkind,
false,
- stmt->ateoxact,
+ stmt->oncommit,
allowSystemTableMods);
StoreCatalogInheritance(relationId, inheritOids);
/*
* TruncateRelation
- * Removes all the rows from a relation
- *
- * Exceptions:
- * BadArg if name is invalid
+ * Removes all the rows from a relation.
*
- * Note:
- * Rows are removed, indexes are truncated and reconstructed.
+ * Note: This routine only does safety and permissions checks;
+ * heap_truncate does the actual work.
*/
void
TruncateRelation(const RangeVar *relation)
{
Relation rel;
Oid relid;
- Oid toastrelid;
ScanKeyData key;
Relation fkeyRel;
SysScanDesc fkeyScan;
systable_endscan(fkeyScan);
heap_close(fkeyRel, AccessShareLock);
- toastrelid = rel->rd_rel->reltoastrelid;
-
/* Keep the lock until transaction commit */
heap_close(rel, NoLock);
- /* Truncate the table proper */
+ /* Do the real work */
heap_truncate(relid);
-
- /* If it has a toast table, truncate that too */
- if (OidIsValid(toastrelid))
- heap_truncate(toastrelid);
}
/*----------
* when its master is, so there's no need to handle the toast rel as
* temp.
*/
-
- /*
- * Pass ATEOXACTNOOP for ateoxact since we want heap_drop_with_catalog()
- * to remove TOAST tables for temp tables, not AtEOXact_temp_relations()
- */
-
toast_relid = heap_create_with_catalog(toast_relname,
PG_TOAST_NAMESPACE,
tupdesc,
RELKIND_TOASTVALUE,
shared_relation,
- ATEOXACTNOOP,
+ ONCOMMIT_NOOP,
true);
/* make the toast relation visible, else index creation will fail */
return (tuple_length > TOAST_TUPLE_THRESHOLD);
}
+
/*
- * To handle ON COMMIT { DROP | PRESERVE ROWS | DELETE ROWS }
+ * This code supports
+ * CREATE TEMP TABLE ... ON COMMIT { DROP | PRESERVE ROWS | DELETE ROWS }
+ *
+ * Because we only support this for TEMP tables, it's sufficient to remember
+ * the state in a backend-local data structure.
+ */
+
+/*
+ * Register a newly-created relation's ON COMMIT action.
*/
void
-AtEOXact_temp_relations(bool iscommit, int bstate)
+register_on_commit_action(Oid relid, OnCommitAction action)
{
- List *l,
- *prev;
- MemoryContext oldctx;
-
- if (temprels == NIL)
- return;
+ OnCommitItem *oc;
+ MemoryContext oldcxt;
/*
- * These loops are tricky because we are removing items from the List
- * while we are traversing it.
+ * We needn't bother registering the relation unless there is an ON COMMIT
+ * action we need to take.
*/
-
-
- /* Remove 'dead' entries on commit and clear 'dead' status on abort */
- l = temprels;
- prev = NIL;
- while (l != NIL)
- {
- TempTable *t = lfirst(l);
-
- if (t->dead)
- {
- if (iscommit)
- {
- /* Remove from temprels, since the user has DROP'd */
- oldctx = MemoryContextSwitchTo(CacheMemoryContext);
- if (prev == NIL)
- {
- pfree(t);
- temprels = lnext(l);
- pfree(l);
- l = temprels;
- }
- else
- {
- pfree(t);
- lnext(prev) = lnext(l);
- pfree(l);
- l = lnext(prev);
- }
- MemoryContextSwitchTo(oldctx);
- continue;
- }
- else
- /* user dropped but now we're aborted */
- t->dead = false;
- }
- prev = l;
- l = lnext(l);
- }
-
- if ((iscommit && bstate != TBLOCK_END) ||
- (!iscommit && bstate != TBLOCK_ABORT))
+ if (action == ONCOMMIT_NOOP || action == ONCOMMIT_PRESERVE_ROWS)
return;
- /* Perform per-xact actions */
- l = temprels;
- prev = NIL;
-
- if (iscommit)
- {
- while (l != NIL)
- {
- TempTable *t = lfirst(l);
+ oldcxt = MemoryContextSwitchTo(CacheMemoryContext);
- if (t->ateoxact == ATEOXACTDROP)
- {
- ObjectAddress object;
+ oc = (OnCommitItem *) palloc(sizeof(OnCommitItem));
+ oc->relid = relid;
+ oc->oncommit = action;
+ oc->created_in_cur_xact = true;
+ oc->deleted_in_cur_xact = false;
- object.classId = RelOid_pg_class;
- object.objectId = t->relid;
- object.objectSubId = 0;
+ on_commits = lcons(oc, on_commits);
- performDeletion(&object, DROP_CASCADE);
- oldctx = MemoryContextSwitchTo(CacheMemoryContext);
+ MemoryContextSwitchTo(oldcxt);
+}
- if (prev == NIL)
- {
- pfree(t);
- temprels = lnext(l);
- pfree(l);
- l = temprels;
- }
- else
- {
- pfree(t);
- lnext(prev) = lnext(l);
- pfree(l);
- l = lnext(prev);
- }
+/*
+ * Unregister any ON COMMIT action when a relation is deleted.
+ *
+ * Actually, we only mark the OnCommitItem entry as to be deleted after commit.
+ */
+void
+remove_on_commit_action(Oid relid)
+{
+ List *l;
- MemoryContextSwitchTo(oldctx);
- CommandCounterIncrement();
- continue;
- }
- else if (t->ateoxact == ATEOXACTDELETE)
- {
- heap_truncate(t->relid);
- CommandCounterIncrement();
- }
- prev = l;
- l = lnext(l);
- }
- }
- else
+ foreach(l, on_commits)
{
- /* Abort --- remove entries added by this xact */
- TransactionId curtid = GetCurrentTransactionId();
-
- oldctx = MemoryContextSwitchTo(CacheMemoryContext);
+ OnCommitItem *oc = (OnCommitItem *) lfirst(l);
- while (l != NIL)
+ if (oc->relid == relid)
{
- TempTable *t = lfirst(l);
-
- if (t->tid == curtid)
- {
- if (prev == NIL)
- {
- pfree(t);
- temprels = lnext(l);
- pfree(l);
- l = temprels;
- }
- else
- {
- pfree(t);
- lnext(prev) = lnext(l);
- pfree(l);
- l = lnext(prev);
- }
- continue;
- }
- prev = l;
- l = lnext(l);
+ oc->deleted_in_cur_xact = true;
+ break;
}
- MemoryContextSwitchTo(oldctx);
}
}
/*
- * Register a temp rel in temprels
+ * Perform ON COMMIT actions.
+ *
+ * This is invoked just before actually committing, since it's possible
+ * to encounter errors.
*/
-
void
-reg_temp_rel(TempTable * t)
+PreCommit_on_commit_actions(void)
{
- temprels = lcons(t, temprels);
-}
+ List *l;
-/*
- * return the ON COMMIT/ateoxact value for a given temp rel
- */
+ foreach(l, on_commits)
+ {
+ OnCommitItem *oc = (OnCommitItem *) lfirst(l);
-void
-free_temp_rels(void)
-{
- MemoryContext oldctx;
+ /* Ignore entry if already dropped in this xact */
+ if (oc->deleted_in_cur_xact)
+ continue;
- oldctx = MemoryContextSwitchTo(CacheMemoryContext);
- while (temprels != NIL)
- {
- List *l = temprels;
+ switch (oc->oncommit)
+ {
+ case ONCOMMIT_NOOP:
+ case ONCOMMIT_PRESERVE_ROWS:
+ /* Do nothing (there shouldn't be such entries, actually) */
+ break;
+ case ONCOMMIT_DELETE_ROWS:
+ heap_truncate(oc->relid);
+ CommandCounterIncrement(); /* XXX needed? */
+ break;
+ case ONCOMMIT_DROP:
+ {
+ ObjectAddress object;
- temprels = lnext(temprels);
- pfree(lfirst(l));
- pfree(l);
+ object.classId = RelOid_pg_class;
+ object.objectId = oc->relid;
+ object.objectSubId = 0;
+ performDeletion(&object, DROP_CASCADE);
+ /*
+ * Note that table deletion will call remove_on_commit_action,
+ * so the entry should get marked as deleted.
+ */
+ Assert(oc->deleted_in_cur_xact);
+ break;
+ }
+ }
}
- MemoryContextSwitchTo(oldctx);
}
/*
- * Remove (actually just mark for deletion, in case we abort)
- * Relid from the temprels list
+ * Post-commit or post-abort cleanup for ON COMMIT management.
+ *
+ * All we do here is remove no-longer-needed OnCommitItem entries.
+ *
+ * During commit, remove entries that were deleted during this transaction;
+ * during abort, remove those created during this transaction.
*/
-
void
-rm_temp_rel(Oid relid)
+AtEOXact_on_commit_actions(bool isCommit)
{
- List *l;
+ List *l,
+ *prev;
- foreach(l, temprels)
+ prev = NIL;
+ l = on_commits;
+ while (l != NIL)
{
- TempTable *t = lfirst(l);
+ OnCommitItem *oc = (OnCommitItem *) lfirst(l);
- if (t->relid == relid)
+ if (isCommit ? oc->deleted_in_cur_xact :
+ oc->created_in_cur_xact)
{
- t->dead = true;
- return;
+ /* This entry must be removed */
+ if (prev != NIL)
+ {
+ lnext(prev) = lnext(l);
+ pfree(l);
+ l = lnext(prev);
+ }
+ else
+ {
+ on_commits = lnext(l);
+ pfree(l);
+ l = on_commits;
+ }
+ pfree(oc);
+ }
+ else
+ {
+ /* This entry must be preserved */
+ oc->created_in_cur_xact = false;
+ oc->deleted_in_cur_xact = false;
+ prev = l;
+ l = lnext(l);
}
}
-
- /* If we get here, we're in trouble */
- Assert(1==1);
}
-
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/typecmds.c,v 1.15 2002/09/21 18:39:25 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/typecmds.c,v 1.16 2002/11/11 22:19:22 tgl Exp $
*
* DESCRIPTION
* The "DefineFoo" routines take the parse tree and pick out the
createStmt->inhRelations = NIL;
createStmt->constraints = NIL;
createStmt->hasoids = false;
+ createStmt->oncommit = ONCOMMIT_NOOP;
/*
* finally create the relation...
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/commands/view.c,v 1.72 2002/09/22 19:42:50 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/commands/view.c,v 1.73 2002/11/11 22:19:22 tgl Exp $
*
*-------------------------------------------------------------------------
*/
createStmt->inhRelations = NIL;
createStmt->constraints = NIL;
createStmt->hasoids = false;
+ createStmt->oncommit = ONCOMMIT_NOOP;
/*
* finally create the relation (this will error out if there's an
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/executor/execMain.c,v 1.183 2002/11/11 03:02:18 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/executor/execMain.c,v 1.184 2002/11/11 22:19:22 tgl Exp $
*
*-------------------------------------------------------------------------
*/
tupdesc,
RELKIND_RELATION,
false,
- ATEOXACTNOOP,
+ ONCOMMIT_NOOP,
allowSystemTableMods);
FreeTupleDesc(tupdesc);
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/nodes/copyfuncs.c,v 1.216 2002/11/06 22:31:23 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/nodes/copyfuncs.c,v 1.217 2002/11/11 22:19:22 tgl Exp $
*
*-------------------------------------------------------------------------
*/
Node_Copy(from, newnode, inhRelations);
Node_Copy(from, newnode, constraints);
newnode->hasoids = from->hasoids;
+ newnode->oncommit = from->oncommit;
return newnode;
}
* Portions Copyright (c) 1994, Regents of the University of California
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/nodes/equalfuncs.c,v 1.162 2002/11/06 00:00:43 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/nodes/equalfuncs.c,v 1.163 2002/11/11 22:19:22 tgl Exp $
*
*-------------------------------------------------------------------------
*/
return false;
if (a->hasoids != b->hasoids)
return false;
+ if (a->oncommit != b->oncommit)
+ return false;
return true;
}
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Header: /cvsroot/pgsql/src/backend/nodes/outfuncs.c,v 1.178 2002/11/06 22:31:24 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/nodes/outfuncs.c,v 1.179 2002/11/11 22:19:22 tgl Exp $
*
* NOTES
* Every (plan) node in POSTGRES has an associated "out" routine which
appendStringInfo(str, " :constraints ");
_outNode(str, node->constraints);
- appendStringInfo(str, " :hasoids %s ",
- booltostr(node->hasoids));
+ appendStringInfo(str, " :hasoids %s :oncommit %d ",
+ booltostr(node->hasoids),
+ (int) node->oncommit);
}
static void
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/parser/gram.y,v 2.375 2002/11/10 00:10:20 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/parser/gram.y,v 2.376 2002/11/11 22:19:23 tgl Exp $
*
* HISTORY
* AUTHOR DATE MAJOR EVENT
#include "catalog/index.h"
#include "catalog/namespace.h"
#include "catalog/pg_type.h"
-#include "commands/tablecmds.h"
#include "nodes/makefuncs.h"
#include "nodes/params.h"
#include "nodes/parsenodes.h"
bool boolean;
JoinType jtype;
DropBehavior dbehavior;
+ OnCommitAction oncommit;
List *list;
Node *node;
Value *value;
%type <typnam> func_arg func_return func_type aggr_argtype
%type <boolean> opt_arg TriggerForType OptTemp OptWithOids
-%type <chr> OptEOXact
+%type <oncommit> OnCommitOption
%type <list> for_update_clause opt_for_update_clause update_list
%type <boolean> opt_all
*****************************************************************************/
CreateStmt: CREATE OptTemp TABLE qualified_name '(' OptTableElementList ')'
- OptInherit OptWithOids OptEOXact
+ OptInherit OptWithOids OnCommitOption
{
CreateStmt *n = makeNode(CreateStmt);
-
- if($2 == FALSE && $10 != ATEOXACTNOOP)
- elog(ERROR,"ON COMMIT can only be used on TEMP tables");
-
$4->istemp = $2;
n->relation = $4;
n->tableElts = $6;
n->inhRelations = $8;
n->constraints = NIL;
n->hasoids = $9;
- n->ateoxact = $10;
+ n->oncommit = $10;
$$ = (Node *)n;
}
| CREATE OptTemp TABLE qualified_name OF qualified_name
- '(' OptTableElementList ')' OptWithOids
+ '(' OptTableElementList ')' OptWithOids OnCommitOption
{
/* SQL99 CREATE TABLE OF <UDT> (cols) seems to be satisfied
* by our inheritance capabilities. Let's try it...
n->inhRelations = makeList1($6);
n->constraints = NIL;
n->hasoids = $10;
+ n->oncommit = $11;
$$ = (Node *)n;
}
;
| /*EMPTY*/ { $$ = TRUE; }
;
-OptEOXact: ON COMMIT DROP { $$ = ATEOXACTDROP; }
- | ON COMMIT DELETE_P ROWS { $$ = ATEOXACTDELETE; }
- | ON COMMIT PRESERVE ROWS { $$ = ATEOXACTPRESERVE; }
- | /*EMPTY*/ { $$ = ATEOXACTNOOP; }
- ;
+OnCommitOption: ON COMMIT DROP { $$ = ONCOMMIT_DROP; }
+ | ON COMMIT DELETE_P ROWS { $$ = ONCOMMIT_DELETE_ROWS; }
+ | ON COMMIT PRESERVE ROWS { $$ = ONCOMMIT_PRESERVE_ROWS; }
+ | /*EMPTY*/ { $$ = ONCOMMIT_NOOP; }
+ ;
+
+
/*
* Note: CREATE TABLE ... AS SELECT ... is just another spelling for
* SELECT ... INTO.
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/parser/keywords.c,v 1.128 2002/11/09 23:56:39 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/parser/keywords.c,v 1.129 2002/11/11 22:19:23 tgl Exp $
*
*-------------------------------------------------------------------------
*/
{"right", RIGHT},
{"rollback", ROLLBACK},
{"row", ROW},
- {"rows",ROWS},
+ {"rows", ROWS},
{"rule", RULE},
{"schema", SCHEMA},
{"scroll", SCROLL},
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: heap.h,v 1.58 2002/11/09 23:56:39 momjian Exp $
+ * $Id: heap.h,v 1.59 2002/11/11 22:19:23 tgl Exp $
*
*-------------------------------------------------------------------------
*/
TupleDesc tupdesc,
char relkind,
bool shared_relation,
- char ateoxact,
+ OnCommitAction oncommit,
bool allow_system_table_mods);
extern void heap_drop_with_catalog(Oid rid);
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: tablecmds.h,v 1.9 2002/11/09 23:56:39 momjian Exp $
+ * $Id: tablecmds.h,v 1.10 2002/11/11 22:19:24 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#ifndef TABLECMDS_H
#define TABLECMDS_H
-#include "access/htup.h"
#include "nodes/parsenodes.h"
extern void AlterTableAddColumn(Oid myrelid, bool recurse, ColumnDef *colDef);
extern void renamerel(Oid myrelid,
const char *newrelname);
-/*
- * Temp rel stuff
- */
-typedef struct TempTable
-{
- Oid relid; /* relid of temp relation */
- char ateoxact; /* what to do at end of xact */
- TransactionId tid; /* trans id where in rel was created */
- bool dead; /* table was dropped in the current xact */
-} TempTable;
-
-extern void AtEOXact_temp_relations(bool iscommit, int bstate);
-extern void reg_temp_rel(TempTable *t);
-extern void free_temp_rels(void);
-extern void rm_temp_rel(Oid relid);
-
-/*
- * What to do at commit time for temporary relations
- */
+extern void register_on_commit_action(Oid relid, OnCommitAction action);
+extern void remove_on_commit_action(Oid relid);
-#define ATEOXACTNOOP 0 /* no operation at commit */
-#define ATEOXACTPRESERVE 1 /* preserve rows */
-#define ATEOXACTDELETE 2 /* delete rows */
-#define ATEOXACTDROP 3 /* drop temp table */
+extern void PreCommit_on_commit_actions(void);
+extern void AtEOXact_on_commit_actions(bool isCommit);
#endif /* TABLECMDS_H */
* Portions Copyright (c) 1996-2002, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
- * $Id: parsenodes.h,v 1.211 2002/11/09 23:56:39 momjian Exp $
+ * $Id: parsenodes.h,v 1.212 2002/11/11 22:19:24 tgl Exp $
*
*-------------------------------------------------------------------------
*/
* implementation).
* ----------------------
*/
+
+/* What to do at commit time for temporary relations */
+typedef enum OnCommitAction
+{
+ ONCOMMIT_NOOP, /* No ON COMMIT clause (do nothing) */
+ ONCOMMIT_PRESERVE_ROWS, /* ON COMMIT PRESERVE ROWS (do nothing) */
+ ONCOMMIT_DELETE_ROWS, /* ON COMMIT DELETE ROWS */
+ ONCOMMIT_DROP /* ON COMMIT DROP */
+} OnCommitAction;
+
typedef struct CreateStmt
{
NodeTag type;
List *inhRelations; /* relations to inherit from */
List *constraints; /* constraints (list of Constraint nodes) */
bool hasoids; /* should it have OIDs? */
- char ateoxact; /* what do we do at COMMIT for TEMP ? */
+ OnCommitAction oncommit; /* what do we do at COMMIT? */
} CreateStmt;
/* ----------
-- test temp table/index masking
CREATE TABLE temptest(col int);
CREATE INDEX i_temptest ON temptest(col);
-CREATE TEMP TABLE temptest(col int);
-CREATE INDEX i_temptest ON temptest(col);
+CREATE TEMP TABLE temptest(tcol int);
+CREATE INDEX i_temptest ON temptest(tcol);
+SELECT * FROM temptest;
+ tcol
+------
+(0 rows)
+
DROP INDEX i_temptest;
DROP TABLE temptest;
+SELECT * FROM temptest;
+ col
+-----
+(0 rows)
+
DROP INDEX i_temptest;
DROP TABLE temptest;
-- test temp table selects
CREATE TABLE temptest(col int);
INSERT INTO temptest VALUES (1);
-CREATE TEMP TABLE temptest(col int);
-INSERT INTO temptest VALUES (2);
+CREATE TEMP TABLE temptest(tcol float);
+INSERT INTO temptest VALUES (2.1);
SELECT * FROM temptest;
- col
------
- 2
+ tcol
+------
+ 2.1
(1 row)
DROP TABLE temptest;
(1 row)
DROP TABLE temptest;
-CREATE TEMP TABLE temptest(col int);
-- test temp table deletion
+CREATE TEMP TABLE temptest(col int);
\c regression
SET autocommit TO 'on';
SELECT * FROM temptest;
ERROR: Relation "temptest" does not exist
+-- Test ON COMMIT DELETE ROWS
+CREATE TEMP TABLE temptest(col int) ON COMMIT DELETE ROWS;
+BEGIN;
+INSERT INTO temptest VALUES (1);
+INSERT INTO temptest VALUES (2);
+SELECT * FROM temptest;
+ col
+-----
+ 1
+ 2
+(2 rows)
+
+COMMIT;
+SELECT * FROM temptest;
+ col
+-----
+(0 rows)
+
+DROP TABLE temptest;
+-- Test ON COMMIT DROP
+BEGIN;
+CREATE TEMP TABLE temptest(col int) ON COMMIT DROP;
+INSERT INTO temptest VALUES (1);
+INSERT INTO temptest VALUES (2);
+SELECT * FROM temptest;
+ col
+-----
+ 1
+ 2
+(2 rows)
+
+COMMIT;
+SELECT * FROM temptest;
+ERROR: Relation "temptest" does not exist
+-- ON COMMIT is only allowed for TEMP
+CREATE TABLE temptest(col int) ON COMMIT DELETE ROWS;
+ERROR: ON COMMIT can only be used on TEMP tables
CREATE INDEX i_temptest ON temptest(col);
-CREATE TEMP TABLE temptest(col int);
+CREATE TEMP TABLE temptest(tcol int);
-CREATE INDEX i_temptest ON temptest(col);
+CREATE INDEX i_temptest ON temptest(tcol);
+
+SELECT * FROM temptest;
DROP INDEX i_temptest;
DROP TABLE temptest;
+SELECT * FROM temptest;
+
DROP INDEX i_temptest;
DROP TABLE temptest;
INSERT INTO temptest VALUES (1);
-CREATE TEMP TABLE temptest(col int);
+CREATE TEMP TABLE temptest(tcol float);
-INSERT INTO temptest VALUES (2);
+INSERT INTO temptest VALUES (2.1);
SELECT * FROM temptest;
DROP TABLE temptest;
-CREATE TEMP TABLE temptest(col int);
-
-- test temp table deletion
+CREATE TEMP TABLE temptest(col int);
+
\c regression
SET autocommit TO 'on';
SELECT * FROM temptest;
+-- Test ON COMMIT DELETE ROWS
+
+CREATE TEMP TABLE temptest(col int) ON COMMIT DELETE ROWS;
+
+BEGIN;
+INSERT INTO temptest VALUES (1);
+INSERT INTO temptest VALUES (2);
+
+SELECT * FROM temptest;
+COMMIT;
+
+SELECT * FROM temptest;
+
+DROP TABLE temptest;
+
+-- Test ON COMMIT DROP
+
+BEGIN;
+
+CREATE TEMP TABLE temptest(col int) ON COMMIT DROP;
+
+INSERT INTO temptest VALUES (1);
+INSERT INTO temptest VALUES (2);
+
+SELECT * FROM temptest;
+COMMIT;
+
+SELECT * FROM temptest;
+
+-- ON COMMIT is only allowed for TEMP
+
+CREATE TABLE temptest(col int) ON COMMIT DELETE ROWS;
projects / postgresql / commitdiff