数据库系统

开发平台：
Unix_Linux

temprel.c：源码内容
							/*-------------------------------------------------------------------------
 *
 * temprel.c
 *	  POSTGRES temporary relation handling
 *
 * Copyright (c) 1994, Regents of the University of California
 *
 *
 * IDENTIFICATION
 *	  $Header: /usr/local/cvsroot/pgsql/src/backend/utils/cache/temprel.c,v 1.6.2.1 1999/08/02 05:25:01 scrappy Exp $
 *
 *-------------------------------------------------------------------------
 */
/*
 * This implements temp tables by modifying the relname cache lookups
 * of pg_class.
 * When a temp table is created, a linked list of temp table tuples is
 * stored here.  When a relname cache lookup is done, references to user-named
 * temp tables are converted to the internal temp table names.
 *
 */
#include <sys/types.h>
#include "postgres.h"
#include "access/heapam.h"
#include "catalog/heap.h"
#include "catalog/index.h"
#include "utils/temprel.h"
GlobalMemory CacheCxt;
/* ----------------
 *		global variables
 * ----------------
 */
static List *temp_rels = NIL;
typedef struct TempTable
{
	char	   *user_relname;
	HeapTuple	pg_class_tuple;
} TempTable;
void
create_temp_relation(char *relname, HeapTuple pg_class_tuple)
{
	MemoryContext oldcxt;
	TempTable  *temp_rel;
	oldcxt = MemoryContextSwitchTo((MemoryContext) CacheCxt);
	temp_rel = palloc(sizeof(TempTable));
	temp_rel->user_relname = palloc(NAMEDATALEN);
	/* save user-supplied name */
	strcpy(temp_rel->user_relname, relname);
	temp_rel->pg_class_tuple = heap_copytuple(pg_class_tuple);
	temp_rels = lcons(temp_rel, temp_rels);
	MemoryContextSwitchTo(oldcxt);
}
void
remove_all_temp_relations(void)
{
	List	   *l,
			   *next;
	AbortOutOfAnyTransaction();
	StartTransactionCommand();
	l = temp_rels;
	while (l != NIL)
	{
		TempTable  *temp_rel = lfirst(l);
		Form_pg_class classtuple;
		classtuple = (Form_pg_class) GETSTRUCT(temp_rel->pg_class_tuple);
		next = lnext(l);		/* do this first, l is deallocated */
		if (classtuple->relkind != RELKIND_INDEX)
		{
			char		relname[NAMEDATALEN];
			/* safe from deallocation */
			strcpy(relname, temp_rel->user_relname);
			heap_destroy_with_catalog(relname);
		}
		else
			index_destroy(temp_rel->pg_class_tuple->t_data->t_oid);
		l = next;
	}
	CommitTransactionCommand();
}
/* we don't have the relname for indexes, so we just pass the oid */
void
remove_temp_relation(Oid relid)
{
	MemoryContext oldcxt;
	List	   *l,
			   *prev;
	oldcxt = MemoryContextSwitchTo((MemoryContext) CacheCxt);
	prev = NIL;
	l = temp_rels;
	while (l != NIL)
	{
		TempTable  *temp_rel = lfirst(l);
		if (temp_rel->pg_class_tuple->t_data->t_oid == relid)
		{
			pfree(temp_rel->user_relname);
			pfree(temp_rel->pg_class_tuple);
			pfree(temp_rel);
			/* remove from linked list */
			if (prev != NIL)
			{
				lnext(prev) = lnext(l);
				pfree(l);
				l = lnext(prev);
			}
			else
			{
				temp_rels = lnext(l);
				pfree(l);
				l = temp_rels;
			}
		}
		else
		{
			prev = l;
			l = lnext(l);
		}
	}
	MemoryContextSwitchTo(oldcxt);
}
HeapTuple
get_temp_rel_by_name(char *user_relname)
{
	List	   *l;
	foreach(l, temp_rels)
	{
		TempTable  *temp_rel = lfirst(l);
		if (strcmp(temp_rel->user_relname, user_relname) == 0)
			return temp_rel->pg_class_tuple;
	}
	return NULL;
}

						