greenplumn gp_partition_template 源码

greenplumn gp_partition_template 代码

文件路径：/src/backend/catalog/gp_partition_template.c

/*-------------------------------------------------------------------------
 *
 * gp_partition_template.c
 *	  routines to support manipulation of the gp_partition_template relation
 *
 * Portions Copyright (c) 1996-2019, PostgreSQL Global Development Group
 * Portions Copyright (c) 1994, Regents of the University of California
 *
 * IDENTIFICATION
 *	  src/backend/catalog/gp_partition_template.c
 *
 *-------------------------------------------------------------------------
 */
#include "postgres.h"

#include "access/genam.h"
#include "access/heapam.h"
#include "access/htup_details.h"
#include "access/tableam.h"
#include "catalog/indexing.h"
#include "catalog/gp_partition_template.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"

void
StoreGpPartitionTemplate(Oid relid, int32 level,
						 GpPartitionDefinition *gpPartDef)
{
	Relation	gp_template;
	ScanKeyData key[2];
	SysScanDesc scan;
	HeapTuple	tuple;
	Datum values[Natts_gp_partition_template];
	bool  nulls[Natts_gp_partition_template];

	memset(nulls, 0, sizeof(nulls));
	values[Anum_gp_partition_template_relid - 1] = relid;
	values[Anum_gp_partition_template_level - 1] = level;
	values[Anum_gp_partition_template_template - 1] = CStringGetTextDatum(nodeToString(gpPartDef));

	gp_template = table_open(PartitionTemplateRelationId, RowExclusiveLock);
	ScanKeyInit(&key[0],
				Anum_gp_partition_template_relid,
				BTEqualStrategyNumber, F_OIDEQ,
				ObjectIdGetDatum(relid));
	ScanKeyInit(&key[1],
				Anum_gp_partition_template_level,
				BTEqualStrategyNumber, F_OIDEQ,
				Int16GetDatum(level));

	scan = systable_beginscan(gp_template, GpPartitionTemplateRelidLevelIndexId,
							  true, NULL, 2, key);

	tuple = systable_getnext(scan);
	if (HeapTupleIsValid(tuple))
	{
		/* update */
		bool doreplace[Natts_gp_partition_template];
		memset(doreplace, false, sizeof(doreplace));

		doreplace[Anum_gp_partition_template_template - 1] = true;
		tuple = heap_modify_tuple(tuple, RelationGetDescr(gp_template),
									values, nulls, doreplace);
		CatalogTupleUpdate(gp_template, &tuple->t_self, tuple);
		heap_freetuple(tuple);
	}
	else
	{
		/* insert */
		tuple = heap_form_tuple(RelationGetDescr(gp_template), values, nulls);
		CatalogTupleInsert(gp_template, tuple);
		heap_freetuple(tuple);
	}

	systable_endscan(scan);
	table_close(gp_template, RowExclusiveLock);
}

GpPartitionDefinition *
GetGpPartitionTemplate(Oid relid, int32 level)
{
	Relation	gp_template;
	ScanKeyData key[2];
	SysScanDesc scan;
	HeapTuple	tuple;
	GpPartitionDefinition *def = NULL;

	gp_template = table_open(PartitionTemplateRelationId, RowExclusiveLock);
	ScanKeyInit(&key[0],
				Anum_gp_partition_template_relid,
				BTEqualStrategyNumber, F_OIDEQ,
				ObjectIdGetDatum(relid));
	ScanKeyInit(&key[1],
				Anum_gp_partition_template_level,
				BTEqualStrategyNumber, F_OIDEQ,
				Int16GetDatum(level));

	scan = systable_beginscan(gp_template, GpPartitionTemplateRelidLevelIndexId,
							  true, NULL, 2, key);

	tuple = systable_getnext(scan);
	if (HeapTupleIsValid(tuple))
	{
		Datum       datum;
		bool        isnull;

		datum = heap_getattr(tuple, Anum_gp_partition_template_template,
							 RelationGetDescr(gp_template), &isnull);

		if (!isnull)
		{
			char *defStr = TextDatumGetCString(datum);
			def = stringToNode(defStr);
			def->fromCatalog = true;
			pfree(defStr);
		}
	}

	systable_endscan(scan);
	table_close(gp_template, RowExclusiveLock);

	return def;
}

/*
 * Remove gp_patition_template entry for a relation
 */
void
RemoveGpPartitionTemplateByRelId(Oid relid)
{
	Relation	gp_template;
	ScanKeyData key;
	SysScanDesc scan;
	HeapTuple	tuple;

	gp_template = table_open(PartitionTemplateRelationId, RowExclusiveLock);
	ScanKeyInit(&key,
				Anum_gp_partition_template_relid,
				BTEqualStrategyNumber, F_OIDEQ,
				ObjectIdGetDatum(relid));
	scan = systable_beginscan(gp_template, GpPartitionTemplateRelidLevelIndexId,
							  true, NULL, 1, &key);

	while (HeapTupleIsValid(tuple = systable_getnext(scan)))
		CatalogTupleDelete(gp_template, &tuple->t_self);

	systable_endscan(scan);
	table_close(gp_template, RowExclusiveLock);
}

bool
RemoveGpPartitionTemplate(Oid relid, int32 level)
{
	Relation	gp_template;
	ScanKeyData key[2];
	SysScanDesc scan;
	HeapTuple	tuple;
	bool		removed = false;

	gp_template = table_open(PartitionTemplateRelationId, RowExclusiveLock);
	ScanKeyInit(&key[0],
				Anum_gp_partition_template_relid,
				BTEqualStrategyNumber, F_OIDEQ,
				ObjectIdGetDatum(relid));
	ScanKeyInit(&key[1],
				Anum_gp_partition_template_level,
				BTEqualStrategyNumber, F_OIDEQ,
				Int16GetDatum(level));

	scan = systable_beginscan(gp_template, GpPartitionTemplateRelidLevelIndexId,
							  true, NULL, 2, key);

	while (HeapTupleIsValid(tuple = systable_getnext(scan)))
	{
		CatalogTupleDelete(gp_template, &tuple->t_self);
		removed = true;
	}

	systable_endscan(scan);
	table_close(gp_template, RowExclusiveLock);

	return removed;
}

相关信息

greenplumn 源码目录

相关文章

greenplumn aclchk 源码

greenplumn aoblkdir 源码

greenplumn aocatalog 源码

greenplumn aoseg 源码

greenplumn aovisimap 源码

greenplumn catalog 源码

greenplumn dependency 源码

greenplumn gp_fastsequence 源码

greenplumn gp_segment_config 源码

greenplumn heap 源码