greenplumn tablecmds_gp 源码
greenplumn tablecmds_gp 代码
文件路径：/src/backend/commands/tablecmds_gp.c
/*-------------------------------------------------------------------------
*
* tablecmds_gp.c
* Greenplum extensions for ALTER TABLE.
*
* Portions Copyright (c) 2005-2010, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
* Portions Copyright (c) 1996-2019, PostgreSQL Global Development Group
* Portions Copyright (c) 1994, Regents of the University of California
*
*
* IDENTIFICATION
* src/backend/commands/tablecmds_gp.c
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
#include "access/reloptions.h"
#include "access/table.h"
#include "access/xact.h"
#include "catalog/gp_partition_template.h"
#include "catalog/partition.h"
#include "catalog/pg_attribute.h"
#include "catalog/pg_attribute_encoding.h"
#include "catalog/pg_collation.h"
#include "catalog/pg_inherits.h"
#include "catalog/pg_partitioned_table.h"
#include "catalog/pg_opclass.h"
#include "catalog/heap.h"
#include "cdb/cdbvars.h"
#include "cdb/memquota.h"
#include "commands/extension.h"
#include "commands/defrem.h"
#include "commands/tablecmds.h"
#include "commands/tablespace.h"
#include "executor/execPartition.h"
#include "nodes/parsenodes.h"
#include "nodes/primnodes.h"
#include "nodes/makefuncs.h"
#include "optimizer/optimizer.h"
#include "parser/parse_utilcmd.h"
#include "partitioning/partdesc.h"
#include "postmaster/autostats.h"
#include "rewrite/rewriteHandler.h"
#include "tcop/utility.h"
#include "utils/builtins.h"
#include "utils/datum.h"
#include "utils/partcache.h"
#include "utils/lsyscache.h"
#include "utils/rel.h"
#include "utils/relcache.h"
#include "utils/ruleutils.h"
#include "utils/snapmgr.h"
#include "utils/syscache.h"
/*
* Build a datum according to tables partition key based on parse expr. Would
* have been nice if FormPartitionKeyDatum() was generic and could have been
* used instead.
*/
static void
FormPartitionKeyDatumFromExpr(Relation rel, Node *expr, Datum *values, bool *isnull)
{
PartitionKey partkey;
int num_expr;
ListCell *lc;
int i;
Assert(rel);
partkey = RelationGetPartitionKey(rel);
Assert(partkey != NULL);
Assert(IsA(expr, List));
num_expr = list_length((List *) expr);
if (num_expr > RelationGetDescr(rel)->natts)
ereport(ERROR,
(errcode(ERRCODE_DATATYPE_MISMATCH),
errmsg("too many columns in boundary specification (%d > %d)",
num_expr, RelationGetDescr(rel)->natts)));
if (num_expr > partkey->partnatts)
ereport(ERROR,
(errcode(ERRCODE_DATATYPE_MISMATCH),
errmsg("too many columns in boundary specification (%d > %d)",
num_expr, partkey->partnatts)));
i = 0;
foreach(lc, (List *) expr)
{
Const *result;
char *colname;
Oid coltype;
int32 coltypmod;
Oid partcollation;
Node *n1 = (Node *) lfirst(lc);
/* Get column's name in case we need to output an error */
if (partkey->partattrs[i] != 0)
colname = get_attname(RelationGetRelid(rel),
partkey->partattrs[i], false);
else
colname = deparse_expression((Node *) linitial(partkey->partexprs),
deparse_context_for(RelationGetRelationName(rel),
RelationGetRelid(rel)),
false, false);
coltype = get_partition_col_typid(partkey, i);
coltypmod = get_partition_col_typmod(partkey, i);
partcollation = get_partition_col_collation(partkey, i);
result = transformPartitionBoundValue(make_parsestate(NULL), n1,
colname, coltype, coltypmod,
partcollation);
values[i] = result->constvalue;
isnull[i] = result->constisnull;
i++;
}
for (; i < partkey->partnatts; i++)
{
values[i] = 0;
isnull[i] = true;
}
}
static Oid
GpFindTargetPartition(Relation parent, GpAlterPartitionId *partid,
bool missing_ok)
{
Oid target_relid = InvalidOid;
switch (partid->idtype)
{
case AT_AP_IDDefault:
/* Find default partition */
target_relid =
get_default_oid_from_partdesc(RelationGetPartitionDesc(parent));
if (!OidIsValid(target_relid) && !missing_ok)
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT),
errmsg("DEFAULT partition of relation \"%s\" does not exist",
RelationGetRelationName(parent))));
break;
case AT_AP_IDName:
{
/*
* Find partition by name.
* After PG12 merge, users may use pg syntax to do the partition maintenance,
* like ALTER TABLE ... DETACH/ATTACH PARTITION.
* This may cause the partition table's name different from GPDB's partition
* table name pattern <parentname>_<level>_prt_<partition_name>.
* When this happens, it's not possible to find the target partition table based
* on the name specified by the user.
*
* And if user do use the GPDB's syntax, we still have cases that the partition
* table's namespace different from it's parent namespace. See issue:
* https://github.com/greenplum-db/gpdb/issues/9903.
* Users could always use PARTITION FOR or pg syntax instead.
*/
RangeVar *partrv;
char *schemaname;
char *partname;
Relation partRel;
char partsubstring[NAMEDATALEN];
List *ancestors = get_partition_ancestors(RelationGetRelid(parent));
int level = list_length(ancestors) + 1;
char levelStr[NAMEDATALEN];
snprintf(levelStr, NAMEDATALEN, "%d", level);
snprintf(partsubstring, NAMEDATALEN, "prt_%s",
strVal(partid->partiddef));
partname = makeObjectName(RelationGetRelationName(parent),
levelStr, partsubstring);
schemaname = get_namespace_name(parent->rd_rel->relnamespace);
partrv = makeRangeVar(schemaname, partname, -1);
partRel = table_openrv_extended(partrv, AccessShareLock, missing_ok);
if (partRel)
{
if (partRel->rd_rel->relispartition)
{
bool found = false;
PartitionDesc partdesc = RelationGetPartitionDesc(parent);
target_relid = RelationGetRelid(partRel);
table_close(partRel, AccessShareLock);
/*
* Make sure the result partition table is the right one.
* Here check whether the target_relid belong to the parent
* through the partdesc->oids instead of call get_partition_parent
* is because the get_partition_parent scan from the disk.
* In-memory check should be faster.
*/
for(int i = 0; i < partdesc->nparts; i++)
{
if (target_relid == partdesc->oids[i])
{
found = true;
break;
}
}
if (!found)
target_relid = InvalidOid;
}
else
table_close(partRel, AccessShareLock);
}
if (!OidIsValid(target_relid) && !missing_ok)
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT),
errmsg("partition \"%s\" of \"%s\" does not exist",
strVal(partid->partiddef), RelationGetRelationName(parent))));
break;
}
case AT_AP_IDValue:
{
Datum values[PARTITION_MAX_KEYS];
bool isnull[PARTITION_MAX_KEYS];
PartitionDesc partdesc = RelationGetPartitionDesc(parent);
int partidx;
FormPartitionKeyDatumFromExpr(parent, partid->partiddef, values, isnull);
partidx = get_partition_for_tuple(RelationGetPartitionKey(parent),
partdesc, values, isnull);
if (partidx < 0)
{
if (missing_ok)
break;
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT),
errmsg("partition for specified value of %s does not exist",
RelationGetRelationName(parent))));
}
if (partdesc->oids[partidx] ==
get_default_oid_from_partdesc(RelationGetPartitionDesc(parent)))
{
ereport(ERROR,
(errcode(ERRCODE_WRONG_OBJECT_TYPE),
errmsg("FOR expression matches DEFAULT partition for specified value of relation \"%s\"",
RelationGetRelationName(parent)),
errhint("FOR expression may only specify a non-default partition in this context.")));
}
target_relid = partdesc->oids[partidx];
break;
}
case AT_AP_IDNone:
elog(ERROR, "not expected value");
break;
}
return target_relid;
}
/*
* Generate partition key specification of a partitioned table
*/
static PartitionSpec *
generatePartitionSpec(Relation rel)
{
HeapTuple tuple;
Form_pg_partitioned_table form;
AttrNumber *attrs;
oidvector *opclass;
oidvector *collation;
Datum datum;
bool isnull;
Oid relid = RelationGetRelid(rel);
PartitionSpec* subpart = makeNode(PartitionSpec);
/*
* We cannot get the opclass oids of the partition keys directly from
* rel->rd_partkey because it only stores opcfamily oids and opcintype oids,
* and there are no syscache entries exists to lookup pg_opclass with those
* two values. Therefore we need to lookup pg_partitioned_table to fetch
* the opclass names. Since we have just opened the relation and built the
* partition descriptor, changes are high we hit the cache.
*
* We choose to as well use Form_pg_partitioned_table to fetch the partition
* attributes, their collations and expressions, even though we do have
* access to the same from rel->rd_partkey.
*/
tuple = SearchSysCache1(PARTRELID, ObjectIdGetDatum(relid));
if (!HeapTupleIsValid(tuple))
elog(ERROR, "missing partition key information for oid %d", relid);
/* Fixed-length attributes */
form = (Form_pg_partitioned_table) GETSTRUCT(tuple);
switch (form->partstrat)
{
case PARTITION_STRATEGY_RANGE:
subpart->strategy = psprintf("range");
break;
case PARTITION_STRATEGY_LIST:
subpart->strategy = psprintf("list");
break;
case PARTITION_STRATEGY_HASH:
subpart->strategy = psprintf("hash");
break;
}
subpart->location = -1;
/*
* We can rely on the first variable-length attribute being mapped to the
* relevant field of the catalog's C struct, because all previous
* attributes are non-nullable and fixed-length.
*/
attrs = form->partattrs.values;
/* But use the hard way to retrieve further variable-length attributes */
/* Operator class */
datum = SysCacheGetAttr(PARTRELID, tuple,
Anum_pg_partitioned_table_partclass, &isnull);
Assert(!isnull);
opclass = (oidvector *) DatumGetPointer(datum);
/* Collation */
datum = SysCacheGetAttr(PARTRELID, tuple,
Anum_pg_partitioned_table_partcollation, &isnull);
Assert(!isnull);
collation = (oidvector *) DatumGetPointer(datum);
/* Expression */
SysCacheGetAttr(PARTRELID, tuple,
Anum_pg_partitioned_table_partexprs, &isnull);
if (!isnull)
{
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("SUBPARTITION BY contain expressions. Cannot ADD PARTITION if expressions in partition key using legacy syntax"),
errhint("Table was created using new partition syntax. Hence, use CREATE TABLE... PARTITION OF instead.")));
}
subpart->partParams = NIL;
for (int i = 0; i < form->partnatts; i++)
{
PartitionElem *elem = makeNode(PartitionElem);
AttrNumber attno = attrs[i];
Form_pg_opclass opclassform;
Form_pg_collation collationform;
char *opclassname;
char *collationname = NULL;
HeapTuple tmptuple;
Assert(attno > 0);
Assert(attno <= RelationGetDescr(rel)->natts);
Form_pg_attribute attr = TupleDescAttr(RelationGetDescr(rel), attno - 1);
Assert(attr != NULL);
Assert(NameStr(attr->attname) != NULL);
elem->name = pstrdup(NameStr(attr->attname));
/* Collect opfamily information */
tmptuple = SearchSysCache1(CLAOID,
ObjectIdGetDatum(opclass->values[i]));
if (!HeapTupleIsValid(tmptuple))
elog(ERROR, "cache lookup failed for opclass %u", opclass->values[i]);
opclassform = (Form_pg_opclass) GETSTRUCT(tmptuple);
opclassname = psprintf("%s", NameStr(opclassform->opcname));
elem->opclass = list_make1(makeString(opclassname));
ReleaseSysCache(tmptuple);
/* Collect collation information */
if (collation->values[i])
{
tmptuple = SearchSysCache1(COLLOID, ObjectIdGetDatum(collation->values[i]));
if (!HeapTupleIsValid(tmptuple))
elog(ERROR, "collation with OID %u does not exist", collation->values[i]);
collationform = (Form_pg_collation) GETSTRUCT(tmptuple);
collationname = psprintf("%s", NameStr(collationform->collname));
elem->collation = list_make1(makeString(collationname));
ReleaseSysCache(tmptuple);
}
subpart->partParams = lappend(subpart->partParams, elem);
}
ReleaseSysCache(tuple);
return subpart;
}
static RenameStmt *
generateRenameStmt(RangeVar *rv, const char *newname)
{
RenameStmt *rstmt = makeNode(RenameStmt);
rstmt->renameType = OBJECT_TABLE;
rstmt->relation = rv;
rstmt->subname = NULL;
rstmt->newname = pstrdup(newname);
rstmt->missing_ok = false;
return rstmt;
}
static AlterObjectSchemaStmt *
generateAlterSchema(RangeVar *rv, const char *newname)
{
AlterObjectSchemaStmt *shstmt = makeNode(AlterObjectSchemaStmt);
shstmt->objectType = OBJECT_TABLE;
shstmt->relation = rv;
shstmt->newschema = pstrdup(newname);
shstmt->missing_ok = false;
return shstmt;
}
/*
* ------------------------------
* Implementation for command:
*
* ALTER TABLE <tab> EXCHANGE PARTITION <oldpart> with table <newpart>
*
* Above alter is converted into following sequence of cmds on QD:
*
* 1. ALTER TABLE <tab> DETACH PARTITION <oldpart>;
* 2. ALTER TABLE <tab> ATTACH PARTITION <oldpart>;
* 3. ALTER TABLE <oldpart> RENAME TO tmp;
* 4. if namespace differ between oldpart and newpart
* a. ALTER TABLE <tmp> SET SCHEMA <newpart_schema>
* b. ALTER TABLE <newpart> RENAME TO <tmp2>
* c. ALTER TABLE <tmp2> SET SCHEMA <oldpart_schema>
* 5. ALTER TABLE <newpart> RENAME TO <oldpart>;
* 6. ALTER TABLE tmp RENAME TO <newpart>
* ------------------------------
*/
static List *
AtExecGPExchangePartition(Relation rel, AlterTableCmd *cmd)
{
GpAlterPartitionCmd *pc = castNode(GpAlterPartitionCmd, cmd->def);
RangeVar *newpartrv = (RangeVar *) pc->arg;
PartitionBoundSpec *boundspec;
RangeVar *oldpartrv;
RangeVar *tmprv;
List *stmts = NIL;
char *newpartname = pstrdup(newpartrv->relname);
char tmpname2[NAMEDATALEN];
/* detach oldpart partition cmd construction */
{
AlterTableStmt *atstmt = makeNode(AlterTableStmt);
GpAlterPartitionId *pid = (GpAlterPartitionId *) pc->partid;
AlterTableCmd *atcmd = makeNode(AlterTableCmd);
PartitionCmd *pcmd = makeNode(PartitionCmd);
char tmpname[NAMEDATALEN];
Oid partrelid;
Relation partrel;
HeapTuple tuple;
partrelid = GpFindTargetPartition(rel, pid, false);
Assert(OidIsValid(partrelid));
partrel = table_open(partrelid, AccessShareLock);
if (partrel->rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("cannot EXCHANGE PARTITION for relation \"%s\" -- partition has children",
RelationGetRelationName(rel))));
oldpartrv = makeRangeVar(get_namespace_name(RelationGetNamespace(partrel)),
pstrdup(RelationGetRelationName(partrel)),
pc->location);
snprintf(tmpname, sizeof(tmpname), "pg_temp_%u", partrelid);
tmprv = makeRangeVar(get_namespace_name(RelationGetNamespace(partrel)),
pstrdup(tmpname),
pc->location);
/*
* Get the oldpart's boundspec which will be used for attaching
* newpart. Fetch the tuple from the catcache, for speed. Relcache
* doesn't store the part bound hence need to fetch from catalog.
*/
tuple = SearchSysCache1(RELOID, partrelid);
if (HeapTupleIsValid(tuple))
{
Datum datum;
bool isnull;
datum = SysCacheGetAttr(RELOID, tuple,
Anum_pg_class_relpartbound,
&isnull);
if (!isnull)
boundspec = stringToNode(TextDatumGetCString(datum));
else
boundspec = NULL;
ReleaseSysCache(tuple);
}
else
elog(ERROR, "pg_class tuple not found for relation %s",
RelationGetRelationName(partrel));
table_close(partrel, AccessShareLock);
pcmd->name = oldpartrv;
pcmd->bound = NULL;
atcmd->subtype = AT_DetachPartition;
atcmd->def = (Node *) pcmd;
atstmt->relation = makeRangeVar(get_namespace_name(RelationGetNamespace(rel)),
pstrdup(RelationGetRelationName(rel)),
pc->location);
atstmt->relkind = OBJECT_TABLE;
atstmt->missing_ok = false;
atstmt->cmds = list_make1(atcmd);
atstmt->is_internal = true; /* set this to avoid transform */
stmts = lappend(stmts, (Node *) atstmt);
}
/* attach newpart partition cmd construction */
{
AlterTableStmt *atstmt = makeNode(AlterTableStmt);
AlterTableCmd *atcmd = makeNode(AlterTableCmd);
PartitionCmd *pcmd = makeNode(PartitionCmd);
Relation newpartrel = table_openrv(newpartrv, AccessShareLock);
newpartrv->schemaname = get_namespace_name(RelationGetNamespace(newpartrel));
snprintf(tmpname2, sizeof(tmpname2), "pg_temp_%u", RelationGetRelid(newpartrel));
table_close(newpartrel, AccessShareLock);
pcmd->name = newpartrv;
pcmd->bound = boundspec;
atcmd->subtype = AT_AttachPartition;
atcmd->def = (Node *) pcmd;
atstmt->relation = makeRangeVar(get_namespace_name(RelationGetNamespace(rel)),
pstrdup(RelationGetRelationName(rel)),
pc->location);
atstmt->relkind = OBJECT_TABLE;
atstmt->missing_ok = false;
atstmt->cmds = list_make1(atcmd);
atstmt->is_internal = true; /* set this to avoid transform */
stmts = lappend(stmts, (Node *) atstmt);
}
/* rename oldpart to tmp */
stmts = lappend(stmts, (Node *) generateRenameStmt(oldpartrv, tmprv->relname));
/*
* if schema is different for tables, need to swap the schema
*/
if (strcmp(oldpartrv->schemaname, newpartrv->schemaname) != 0)
{
/* change schema for tmp to newpart schema */
stmts = lappend(stmts, (Node *) generateAlterSchema(tmprv, newpartrv->schemaname));
/* reflect new reality in temprv for later use */
tmprv = makeRangeVar(pstrdup(newpartrv->schemaname),
pstrdup(tmprv->relname),
pc->location);
/* rename newpart to tmp2 */
stmts = lappend(stmts, (Node *) generateRenameStmt(newpartrv, tmpname2));
/* change schema for temp2 to oldpart schema */
stmts = lappend(stmts, (Node *) generateAlterSchema(
makeRangeVar(pstrdup(newpartrv->schemaname),
pstrdup(tmpname2),
pc->location),
oldpartrv->schemaname));
/* reflect new reality in newpartrv for later use */
newpartrv = makeRangeVar(pstrdup(oldpartrv->schemaname),
pstrdup(tmpname2),
pc->location);
}
/* rename newpart to oldpart */
stmts = lappend(stmts, (Node *) generateRenameStmt(newpartrv, oldpartrv->relname));
/* rename tmp to newpart */
stmts = lappend(stmts, (Node *) generateRenameStmt(tmprv, newpartname));
return stmts;
}
static List *
AtExecGPSplitPartition(Relation rel, AlterTableCmd *cmd)
{
GpSplitPartitionCmd *pc = castNode(GpSplitPartitionCmd, cmd->def);
RangeVar *oldpartrv;
RangeVar *tmprv;
PartitionBoundSpec *boundspec;
char *p_tablespacename;
char *p_accessMethod;
List *p_colencs;
List *p_reloptions;
const char *defaultpartname;
List *stmts = NIL;
ListCell *l;
Oid partrelid;
/* detach current partition */
{
GpAlterPartitionId *pid = (GpAlterPartitionId *) pc->partid;
AlterTableStmt *atstmt = makeNode(AlterTableStmt);
AlterTableCmd *atcmd = makeNode(AlterTableCmd);
PartitionCmd *pcmd = makeNode(PartitionCmd);
char tmpname[NAMEDATALEN];
Relation partrel;
HeapTuple tuple;
partrelid = GpFindTargetPartition(rel, pid, false);
Assert(OidIsValid(partrelid));
partrel = table_open(partrelid, AccessShareLock);
if (partrelid == get_default_oid_from_partdesc(RelationGetPartitionDesc(rel)))
defaultpartname = pstrdup(RelationGetRelationName(partrel));
else
defaultpartname = NULL;
if (partrel->rd_rel->relkind == RELKIND_PARTITIONED_TABLE)
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("cannot SPLIT PARTITION for relation \"%s\" -- partition has children",
RelationGetRelationName(rel)),
errhint("Try splitting the child partitions.")));
oldpartrv = makeRangeVar(get_namespace_name(RelationGetNamespace(partrel)),
pstrdup(RelationGetRelationName(partrel)),
pc->location);
snprintf(tmpname, sizeof(tmpname), "pg_temp_%u", partrelid);
tmprv = makeRangeVar(get_namespace_name(RelationGetNamespace(partrel)),
pstrdup(tmpname),
pc->location);
/*
* Get the part's boundspec. Fetch the tuple from the
* catcache, for speed. Relcache doesn't store the part bound
* hence need to fetch from catalog.
*/
tuple = SearchSysCache1(RELOID, partrelid);
if (HeapTupleIsValid(tuple))
{
Datum datum;
bool isnull;
datum = SysCacheGetAttr(RELOID, tuple,
Anum_pg_class_relpartbound,
&isnull);
if (!isnull)
boundspec = stringToNode(TextDatumGetCString(datum));
else
boundspec = NULL;
datum = SysCacheGetAttr(RELOID, tuple,
Anum_pg_class_reloptions,
&isnull);
if (isnull)
p_reloptions = NIL;
else
p_reloptions = untransformRelOptions(datum);
ReleaseSysCache(tuple);
}
else
elog(ERROR, "pg_class tuple not found for relation %s",
RelationGetRelationName(partrel));
p_tablespacename = get_tablespace_name(partrel->rd_rel->reltablespace);
p_accessMethod = get_am_name(partrel->rd_rel->relam);
p_colencs = rel_get_column_encodings(partrel);
table_close(partrel, AccessShareLock);
pcmd->name = oldpartrv;
pcmd->bound = NULL;
atcmd->subtype = AT_DetachPartition;
atcmd->def = (Node *) pcmd;
atstmt->relation = makeRangeVar(get_namespace_name(RelationGetNamespace(rel)),
pstrdup(RelationGetRelationName(rel)),
pc->location);
atstmt->relkind = OBJECT_TABLE;
atstmt->missing_ok = false;
atstmt->cmds = list_make1(atcmd);
atstmt->is_internal = true; /* set this to avoid transform */
stmts = lappend(stmts, (Node *) atstmt);
}
/* rename old part to temp */
stmts = lappend(stmts, (Node *) generateRenameStmt(oldpartrv, tmprv->relname));
/* create new partitions */
{
partname_comp partcomp = {.tablename=NULL, .level=0, .partnum=0};
List *ancestors = get_partition_ancestors(RelationGetRelid(rel));
GpPartDefElem *elem;
PartitionBoundSpec *boundspec1;
PartitionBoundSpec *boundspec2 = boundspec;
PartitionKey partkey = RelationGetPartitionKey(rel);
ParseState *pstate = make_parsestate(NULL);
char *part_col_name;
Oid part_col_typid;
int32 part_col_typmod;
Oid part_col_collation;
GpAlterPartitionCmd *into = (GpAlterPartitionCmd *) pc->arg2;
char *partname1 = NULL;
char *partname2 = NULL;
pstate->p_sourcetext = cmd->queryString;
/* Extract the two partition names from the INTO (<part1>, <part2>) clause */
if (into)
{
GpAlterPartitionId *partid1 = into->partid;
GpAlterPartitionId *partid2 = (GpAlterPartitionId *) into->arg;
Oid intorel1 = GpFindTargetPartition(rel, partid1, true);
Oid intorel2 = GpFindTargetPartition(rel, partid2, true);
if (intorel1 != InvalidOid && intorel2 != InvalidOid)
ereport(ERROR,
(errcode(ERRCODE_DUPLICATE_OBJECT),
errmsg("both INTO partitions already exist")));
/*
* If we're splitting the default partition, the INTO clause must
* include the default partition. Either as DEFAULT PARTITION, or by name.
*/
if (defaultpartname)
{
if (intorel1 == partrelid)
{
if (partid2->idtype != AT_AP_IDName)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("new partition in INTO clause must be given by name"),
parser_errposition(pstate, partid2->location)));
partname1 = strVal(partid2->partiddef);
}
else if (intorel2 == partrelid)
{
if (partid1->idtype != AT_AP_IDName)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("new partition in INTO clause must be given by name"),
parser_errposition(pstate, partid1->location)));
partname1 = strVal(partid1->partiddef);
}
else
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("default partition name missing from INTO clause")));
}
else
{
if (partid1->idtype != AT_AP_IDName)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("INTO can only have first partition by name"),
parser_errposition(pstate, partid1->location)));
if (partid2->idtype != AT_AP_IDName)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("INTO can only have first partition by name"),
parser_errposition(pstate, partid1->location)));
partname1 = strVal(partid1->partiddef);
partname2 = strVal(partid2->partiddef);
}
}
Assert(partkey->partnatts == 1);
partcomp.level = list_length(ancestors) + 1;
part_col_name =
NameStr(TupleDescAttr(RelationGetDescr(rel),
partkey->partattrs[0] - 1)->attname);
part_col_typid = get_partition_col_typid(partkey, 0);
part_col_typmod = get_partition_col_typmod(partkey, 0);
part_col_collation = get_partition_col_collation(partkey, 0);
boundspec1 = makeNode(PartitionBoundSpec);
boundspec1->strategy = boundspec->strategy;
boundspec1->is_default = false;
switch (boundspec->strategy)
{
case PARTITION_STRATEGY_RANGE:
{
GpPartitionRangeItem *startItem = pc->start;
GpPartitionRangeItem *endItem = pc->end;
List *at = pc->at;
List *start;
bool startExclusive;
List *end;
bool endInclusive;
Assert((startItem == NULL && endItem == NULL && at != NULL) ||
(startItem != NULL && endItem != NULL && at == NULL));
start = startItem ? startItem->val : NULL;
end = endItem ? endItem->val : at;
startExclusive = (startItem && startItem->edge == PART_EDGE_EXCLUSIVE) ? true : false;
endInclusive = (endItem && endItem->edge == PART_EDGE_INCLUSIVE) ? true : false;
if (end)
{
Const *endConst;
if (list_length(end) != partkey->partnatts)
ereport(ERROR,
(errcode(ERRCODE_INVALID_TABLE_DEFINITION),
errmsg("number of END values should cover all partition key columns"),
parser_errposition(pstate, pc->end->location)));
endConst = transformPartitionBoundValue(pstate,
linitial(end),
part_col_name,
part_col_typid,
part_col_typmod,
part_col_collation);
if (endConst->constisnull)
ereport(ERROR,
(errcode(ERRCODE_INVALID_TABLE_DEFINITION),
errmsg("cannot use NULL with range partition specification"),
parser_errposition(pstate, pc->location)));
if (endInclusive)
convert_exclusive_start_inclusive_end(endConst, part_col_typid, part_col_typmod, false);
if (!endConst->constisnull)
boundspec1->upperdatums =
list_make1(makeConst(partkey->parttypid[0],
partkey->parttypmod[0],
partkey->parttypcoll[0],
partkey->parttyplen[0],
datumCopy(endConst->constvalue,
partkey->parttypbyval[0],
partkey->parttyplen[0]),
false,
partkey->parttypbyval[0]));
else
{
Assert(endInclusive == true);
ColumnRef *maxvalue = makeNode(ColumnRef);
maxvalue->fields = list_make1(makeString("maxvalue"));
boundspec1->upperdatums = list_make1(maxvalue);
}
}
if (start)
{
Const *startConst;
if (list_length(start) != partkey->partnatts)
ereport(ERROR,
(errcode(ERRCODE_INVALID_TABLE_DEFINITION),
errmsg("number of START values should cover all partition key columns"),
parser_errposition(pstate, pc->start->location)));
startConst = transformPartitionBoundValue(pstate,
linitial(start),
part_col_name,
part_col_typid,
part_col_typmod,
part_col_collation);
if (startConst->constisnull)
ereport(ERROR,
(errcode(ERRCODE_INVALID_TABLE_DEFINITION),
errmsg("cannot use NULL with range partition specification"),
parser_errposition(pstate, pc->location)));
if (startExclusive)
convert_exclusive_start_inclusive_end(startConst,
part_col_typid, part_col_typmod,
true);
boundspec1->lowerdatums =
list_make1(makeConst(partkey->parttypid[0],
partkey->parttypmod[0],
partkey->parttypcoll[0],
partkey->parttyplen[0],
datumCopy(startConst->constvalue,
partkey->parttypbyval[0],
partkey->parttyplen[0]),
false,
partkey->parttypbyval[0]));
}
else
{
if (defaultpartname)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("AT clause cannot be used when splitting a default RANGE partition")));
/*
* Start not-specified means splitting non-default
* partition. Use existing partitions lowerdatum as start
* for this partition.
*/
boundspec1->lowerdatums = boundspec2->lowerdatums;
boundspec2->lowerdatums =
copyObject(boundspec1->upperdatums);
}
}
break;
case PARTITION_STRATEGY_LIST:
{
ListCell *cell;
List *at = pc->at;
PartitionBoundSpec *boundspec_newvals = boundspec1;
PartitionBoundSpec *boundspec_remainingvals = boundspec2;
if (pc->start || pc->end)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("cannot SPLIT LIST PARTITION with START"),
errhint("Use SPLIT with the AT clause instead.")));
if (partcomp.level != 1)
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("SPLIT PARTITION is not currently supported when leaf partition is list partitioned in multi level partition table")));
Assert(at != NULL);
foreach(cell, at)
{
Node *expr = lfirst(cell);
Const *value;
value = transformPartitionBoundValue(pstate,
expr,
part_col_name,
part_col_typid,
part_col_typmod,
part_col_collation);
/* Skip if the value is already moved to the new list */
if (list_member(boundspec_newvals->listdatums, value))
continue;
if (!boundspec_remainingvals->is_default)
{
if (!list_member(boundspec_remainingvals->listdatums, value))
ereport(ERROR,
(errcode(ERRCODE_WRONG_OBJECT_TYPE),
errmsg("AT clause parameter is not a member of the target partition specification")));
boundspec_remainingvals->listdatums =
list_delete(boundspec_remainingvals->listdatums, value);
if (list_length(boundspec_remainingvals->listdatums) == 0)
ereport(ERROR,
(errcode(ERRCODE_SYNTAX_ERROR),
errmsg("AT clause cannot contain all values in the partition to be split")));
}
boundspec_newvals->listdatums =
lappend(boundspec_newvals->listdatums, value);
}
/* if splitting default partition, new partition is created first and default later */
if (!defaultpartname)
{
boundspec1 = boundspec_remainingvals;
boundspec2 = boundspec_newvals;
}
}
break;
default:
ereport(ERROR,
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("partition strategy: %c not supported by SPLIT partition",
boundspec->strategy),
parser_errposition(pstate, pc->location)));
break;
}
boundspec1->location = -1;
elem = makeNode(GpPartDefElem);
elem->tablespacename = p_tablespacename;
elem->accessMethod = p_accessMethod;
elem->colencs = p_colencs;
elem->options = p_reloptions;
/* create first partition stmt */
stmts = lappend(stmts, makePartitionCreateStmt(rel, partname1, boundspec1, NULL, elem, &partcomp));
/* create second partition stmt */
if (defaultpartname)
{
partcomp.tablename = defaultpartname;
partname2 = NULL;
}
stmts = lappend(stmts, makePartitionCreateStmt(rel, partname2, boundspec2, NULL, elem, &partcomp));
}
foreach (l, stmts)
{
/* No planning needed, just make a wrapper PlannedStmt */
Node *stmt = (Node *) lfirst(l);
PlannedStmt *pstmt = makeNode(PlannedStmt);
pstmt->commandType = CMD_UTILITY;
pstmt->canSetTag = false;
pstmt->utilityStmt = stmt;
pstmt->stmt_location = -1;
pstmt->stmt_len = 0;
ProcessUtility(pstmt,
synthetic_sql,
PROCESS_UTILITY_SUBCOMMAND,
NULL,
NULL,
None_Receiver,
NULL);
}
/* insert into parent select * from tmp */
{
StringInfoData buf;
initStringInfo(&buf);
appendStringInfo(&buf, "INSERT INTO %s.%s SELECT * FROM %s.%s",
quote_identifier(get_namespace_name(rel->rd_rel->relnamespace)),
quote_identifier(RelationGetRelationName(rel)),
quote_identifier(tmprv->schemaname),
quote_identifier(tmprv->relname));
execute_sql_string(buf.data);
}
/* drop tmp table */
{
DropStmt *dropstmt = makeNode(DropStmt);
dropstmt->objects = list_make1(
list_make2(makeString(tmprv->schemaname),
makeString(tmprv->relname)));
dropstmt->removeType = OBJECT_TABLE;
dropstmt->behavior = DROP_CASCADE;
dropstmt->missing_ok = false;
stmts = NIL;
stmts = lappend(stmts, (Node *)dropstmt);
}
return stmts;
}
void GpAlterPartMetaTrackUpdObject(Oid relid, AlterTableType subcmdtype)
{
char *subtype;
switch (subcmdtype)
{
case AT_PartTruncate:
subtype = "TRUNCATE";
break;
case AT_PartAdd:
subtype = "ADD";
break;
case AT_PartDrop:
subtype = "DROP";
break;
case AT_PartExchange:
subtype = "EXCHANGE";
break;
case AT_PartSplit:
subtype = "SPLIT";
break;
case AT_SetDistributedBy:
subtype = "SET DISTRIBUTED BY";
break;
case AT_SetTableSpace:
subtype = "SET TABLESPACE";
break;
case AT_PartSetTemplate:
subtype = "SET TEMPLATE";
break;
case AT_PartRename:
subtype = "RENAME";
break;
default:
subtype = "UNKNOWN ALTER PARTITION COMMAND";
break;
}
MetaTrackUpdObject(RelationRelationId,
relid,
GetUserId(),
"PARTITION",
subtype);
}
void
ATExecGPPartCmds(Relation origrel, AlterTableCmd *cmd)
{
Relation rel = origrel;
List *stmts = NIL;
ListCell *l;
Assert(Gp_role != GP_ROLE_EXECUTE);
if (Gp_role != GP_ROLE_DISPATCH)
return;
while (cmd->subtype == AT_PartAlter)
{
GpAlterPartitionCmd *pc;
GpAlterPartitionId *pid;
Oid partrelid;
pc = castNode(GpAlterPartitionCmd, cmd->def);
pid = (GpAlterPartitionId *) pc->partid;
cmd = (AlterTableCmd *) pc->arg;
if (rel->rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
{
ereport(ERROR,
(errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
errmsg("table \"%s\" is not partitioned",
RelationGetRelationName(rel))));
}
partrelid = GpFindTargetPartition(rel, pid, false);
Assert(OidIsValid(partrelid));
if (rel != origrel)
table_close(rel, AccessShareLock);
rel = table_open(partrelid, AccessShareLock);
}
/*
* Most ALTER PARTITION commands are to ADD/DROP subpartitions, and don't
* make sense unless the partition itself is a partitioned table. SET
* DISTRIBUTED BY and SET TABLESPACE are exceptions.
*/
if (rel->rd_rel->relkind != RELKIND_PARTITIONED_TABLE &&
cmd->subtype != AT_SetDistributedBy &&
cmd->subtype != AT_SetTableSpace)
{
ereport(ERROR,
(errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
errmsg("table \"%s\" is not partitioned",
RelationGetRelationName(rel))));
}
switch (cmd->subtype)
{
case AT_PartTruncate:
{
GpAlterPartitionCmd *pc = castNode(GpAlterPartitionCmd, cmd->def);
GpAlterPartitionId *pid = (GpAlterPartitionId *) pc->partid;
TruncateStmt *truncstmt = (TruncateStmt *) pc->arg;
Oid partrelid;
RangeVar *rv;
Relation partrel;
partrelid = GpFindTargetPartition(rel, pid, false);
Assert(OidIsValid(partrelid));
partrel = table_open(partrelid, AccessShareLock);
rv = makeRangeVar(get_namespace_name(RelationGetNamespace(partrel)),
pstrdup(RelationGetRelationName(partrel)),
pc->location);
truncstmt->relations = list_make1(rv);
table_close(partrel, AccessShareLock);
stmts = lappend(stmts, (Node *) truncstmt);
}
break;
case AT_PartAdd: /* Add */
{
GpAlterPartitionCmd *add_cmd = castNode(GpAlterPartitionCmd, cmd->def);
GpPartitionDefinition *gpPartDef = makeNode(GpPartitionDefinition);
GpPartDefElem *elem = castNode(GpPartDefElem, add_cmd->arg);
PartitionSpec *subpart = NULL;
Relation temprel = rel;
PartitionSpec *tempsubpart = NULL;
ListCell *l;
List *ancestors = get_partition_ancestors(RelationGetRelid(rel));
int level = list_length(ancestors) + 1;
gpPartDef->partDefElems = list_make1(elem);
gpPartDef->fromCatalog = false;
/*
* Populate PARTITION BY spec for each level of the parents
* in the partitioning hierarchy. The PartitionSpec or a chain of
* PartitionSpecs if subpartitioning exists, are generated based on
* the first existing partition of each partition depth.
*/
do
{
PartitionDesc partdesc;
PartitionSpec *temptempsubpart = NULL;
Oid firstchildoid;
Assert(temprel->rd_rel->relkind == RELKIND_PARTITIONED_TABLE);
partdesc = RelationGetPartitionDesc(temprel);
if (partdesc->nparts == 0)
elog(ERROR, "GPDB add partition syntax needs at least one sibling to exist");
if (partdesc->is_leaf[0])
{
if (temprel != rel)
table_close(temprel, AccessShareLock);
break;
}
firstchildoid = partdesc->oids[0];
if (temprel != rel)
table_close(temprel, AccessShareLock);
temprel = table_open(firstchildoid, AccessShareLock);
temptempsubpart = generatePartitionSpec(temprel);
temptempsubpart->gpPartDef = GetGpPartitionTemplate(
ancestors ? llast_oid(ancestors) : RelationGetRelid(rel), level);
level++;
if (tempsubpart == NULL)
subpart = tempsubpart = temptempsubpart;
else
{
tempsubpart->subPartSpec = temptempsubpart;
tempsubpart = tempsubpart->subPartSpec;
}
} while (1);
List *cstmts = generatePartitions(RelationGetRelid(rel),
gpPartDef, subpart, cmd->queryString,
NIL, NULL, NULL, false);
foreach(l, cstmts)
{
Node *stmt = (Node *) lfirst(l);
stmts = lappend(stmts, (Node *) stmt);
}
}
break;
case AT_PartDrop: /* Drop */
{
GpDropPartitionCmd *pc = castNode(GpDropPartitionCmd, cmd->def);
GpAlterPartitionId *pid = (GpAlterPartitionId *) pc->partid;
DropStmt *dropstmt = makeNode(DropStmt);
Oid partrelid;
Relation partrel;
PartitionDesc partdesc;
partrelid = GpFindTargetPartition(rel, pid, pc->missing_ok);
if (!OidIsValid(partrelid))
break;
partrel = table_open(partrelid, AccessShareLock);
partdesc = RelationGetPartitionDesc(rel);
/*
* If two drop partition cmds are specified in same alter table stmt,
* the blow check still works to make sure the partitioned table at least
* have one partition table.
* When the first drop get executed, the catalog will have an update which make
* current Relation get invalid and call RelationClearRelation to refresh
* the Relation. After that the next drop cmd will have partdesc->nparts = 1,
* and raise error to abort.
*/
if (partdesc->nparts == 1)
{
ereport(ERROR,
(errcode(ERRCODE_DEPENDENT_OBJECTS_STILL_EXIST),
errmsg("cannot drop partition \"%s\" of \"%s\" -- only one remains",
RelationGetRelationName(partrel),
RelationGetRelationName(rel)),
errhint("Use DROP TABLE \"%s\" to remove the table and the final partition ",
RelationGetRelationName(rel))));
}
dropstmt->objects = list_make1(
list_make2(makeString(
get_namespace_name(RelationGetNamespace(partrel))),
makeString(pstrdup(RelationGetRelationName(partrel)))));
dropstmt->removeType = OBJECT_TABLE;
dropstmt->behavior = pc->behavior;
dropstmt->missing_ok = pc->missing_ok;
table_close(partrel, AccessShareLock);
stmts = lappend(stmts, (Node *)dropstmt);
}
break;
case AT_PartExchange:
{
List *returnstmt = AtExecGPExchangePartition(rel, cmd);
stmts = list_concat(stmts, returnstmt);
}
break;
case AT_PartSplit:
{
List *returnstmt = AtExecGPSplitPartition(rel, cmd);
stmts = list_concat(stmts, returnstmt);
}
break;
case AT_SetDistributedBy:
case AT_SetTableSpace:
{
AlterTableStmt *newstmt = makeNode(AlterTableStmt);
newstmt->relation = makeRangeVar(get_namespace_name(rel->rd_rel->relnamespace),
pstrdup(RelationGetRelationName(rel)), -1);
newstmt->cmds = list_make1(cmd);
newstmt->relkind = OBJECT_TABLE;
newstmt->missing_ok = false;
stmts = lappend(stmts, newstmt);
}
break;
case AT_PartSetTemplate:
{
GpAlterPartitionCmd *pc = castNode(GpAlterPartitionCmd, cmd->def);
GpPartitionDefinition *templateDef = (GpPartitionDefinition *) pc->arg;
List *ancestors = get_partition_ancestors(RelationGetRelid(rel));
int level = list_length(ancestors) + 1;
Oid topParentrelid = ancestors ? llast_oid(ancestors) : RelationGetRelid(rel);
if (templateDef)
{
Relation firstrel;
Oid firstchildoid;
PartitionDesc partdesc = RelationGetPartitionDesc(rel);
if (partdesc->nparts == 0)
elog(ERROR, "GPDB SET SUBPARTITION TEMPLATE syntax needs at least one sibling to exist");
firstchildoid = partdesc->oids[0];
firstrel = table_open(firstchildoid, AccessShareLock);
if (firstrel->rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
elog(ERROR, "level %d is not partitioned and hence can't set subpartition template for the same",
level);
/* if this is not leaf level partition then sub-partition must exist for next level */
if (!RelationGetPartitionDesc(firstrel)->is_leaf[0])
{
if (GetGpPartitionTemplate(topParentrelid, level + 1) == NULL)
{
ereport(ERROR,
(errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
errmsg("can't add sub-partition template at level %d since next level template doesn't exist",
level),
errhint("Add sub-partition template for next level.")));
}
}
/*
* call generatePartitions() using first child as partition to
* add partitions, just to validate the subpartition template,
* if anything wrong it will error out.
*/
generatePartitions(firstchildoid, templateDef, NULL, cmd->queryString,
NIL, NULL, NULL, true);
table_close(firstrel, AccessShareLock);
StoreGpPartitionTemplate(topParentrelid, level, templateDef);
}
else
{
bool removed = RemoveGpPartitionTemplate(topParentrelid, level);
if (!removed)
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT),
errmsg("relation \"%s\" does not have a level %d subpartition template specification",
RelationGetRelationName(origrel), level)));
}
if (rel != origrel)
table_close(rel, AccessShareLock);
return;
}
break;
case AT_PartRename:
{
GpAlterPartitionCmd *pc = castNode(GpAlterPartitionCmd, cmd->def);
GpAlterPartitionId *pid = (GpAlterPartitionId *) pc->partid;
char *newpartname = strVal(pc->arg);
RenameStmt *renStmt = makeNode(RenameStmt);
Oid namespaceId;
char *newrelname;
char targetrelname[NAMEDATALEN];
List *ancestors = get_partition_ancestors(RelationGetRelid(rel));
int level = list_length(ancestors) + 1;
Oid partrelid;
Relation targetrelation;
partrelid = GpFindTargetPartition(rel, pid, false);
targetrelation = table_open(partrelid, AccessExclusiveLock);
StrNCpy(targetrelname, RelationGetRelationName(targetrelation),
NAMEDATALEN);
namespaceId = RelationGetNamespace(targetrelation);
table_close(targetrelation, AccessExclusiveLock);
/* the "label" portion of the new relation is prt_`newpartname',
* and makeObjectName won't truncate this portion of the partition
* name -- it will assert instead.
*/
if (strlen(newpartname) > (NAMEDATALEN - 8))
ereport(ERROR,
(errcode(ERRCODE_INVALID_TABLE_DEFINITION),
errmsg("name \"%s\" for child partition is too long",
newpartname)));
newrelname = ChoosePartitionName(RelationGetRelationName(rel), level, namespaceId,
newpartname, 0);
renStmt->renameType = OBJECT_TABLE;
renStmt->relation = makeRangeVar(get_namespace_name(namespaceId),
pstrdup(targetrelname), -1);
renStmt->newname = newrelname;
/*
* rename stmt is only constructed for specified table here. If it
* happens to be Partitioned Table, then RenameRelationInternal()
* will recurse to its child partitions and perform renames.
*/
stmts = lappend(stmts, renStmt);
}
break;
default:
elog(ERROR, "Not implemented");
break;
}
if (rel != origrel)
table_close(rel, AccessShareLock);
foreach (l, stmts)
{
/* No planning needed, just make a wrapper PlannedStmt */
Node *stmt = (Node *) lfirst(l);
PlannedStmt *pstmt = makeNode(PlannedStmt);
pstmt->commandType = CMD_UTILITY;
pstmt->canSetTag = false;
pstmt->utilityStmt = stmt;
pstmt->stmt_location = -1;
pstmt->stmt_len = 0;
ProcessUtility(pstmt,
synthetic_sql,
PROCESS_UTILITY_SUBCOMMAND,
NULL,
NULL,
None_Receiver,
NULL);
}
/*
* The pg_stat_last_operation table contains metadata tracking
* information about operations on database objects. Greenplum
* Database updates this table when a database object is
* created, altered, truncated, vacuumed, analyzed, or
* partitioned, and when privileges are granted to an object.
* GpAlterPartMetaTrackUpdObject() will update
* pg_stat_last_operation for GPDB specific alter partition
* commands.
*/
if (Gp_role == GP_ROLE_DISPATCH)
GpAlterPartMetaTrackUpdObject(RelationGetRelid(rel), cmd->subtype);
}
/*
* This function calls RenameRelationInternal() for all child partitions of
* the targetrelation. This function should only be called for
* RELKIND_PARTITIONED_TABLE. Rename is performed only if child partition name
* contains oldparentrelname as prefix else skipped.
*
* This function is called on QD and QE to recurse and perform renamaes,
* instead of constructing RenameStmt on QD and dispatching stmt via
* ProcessUtility().
*/
void
GpRenameChildPartitions(Relation targetrelation,
const char *oldparentrelname,
const char *newparentrelname)
{
int skipped = 0;
int renamed = 1;
ListCell *lc;
List *oids = find_all_inheritors(RelationGetRelid(targetrelation), AccessExclusiveLock, NULL);
/* remove parent from the list */
oids = list_delete_first(oids);
foreach(lc, oids)
{
Oid part_oid = lfirst_oid(lc);
char newpartname[NAMEDATALEN * 2];
Relation partrel = table_open(part_oid, NoLock);
char *relname = pstrdup(RelationGetRelationName(partrel));
/* don't release the lock till end of transaction */
table_close(partrel, NoLock);
/*
* The child name should contain the old parent name as a prefix - check
* the length and compare to make sure.
*
* To build the new child name, just use the new name as a prefix, and use
* the remainder of the child name (the part after the old parent name
* prefix) as the suffix.
*/
if ((strlen(oldparentrelname) <= strlen(relname))
&& (strncmp(oldparentrelname, relname, strlen(oldparentrelname)) == 0))
{
snprintf(newpartname, sizeof(newpartname), "%s%s",
newparentrelname, relname + strlen(oldparentrelname));
if (strlen(newpartname) < NAMEDATALEN)
{
RenameRelationInternal(part_oid, newpartname, false, false);
renamed++;
continue;
}
}
skipped++;
}
if (skipped && Gp_role != GP_ROLE_EXECUTE)
elog(WARNING, "renamed %d relations, skipped %d child partitions as old parent name is not part of partition name",
renamed, skipped);
}
相关信息
相关文章
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦