hcq/openGauss-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!4699 修复在有限表空间上能够创建分区表问题（段页式存储）

Browse Source 
Merge pull request !4699 from 姜岩/prepared_statement
This commit is contained in:
opengauss_bot
2024-01-04 09:30:54 +00:00
committed by Gitee
parent 1522a2c31b c7608820e1
commit 3519527c74
1 changed files with 53 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/gausskernel/optimizer/commands/tablecmds.cpp
View File

@ -2026,6 +2026,25 @@ void UpdatePartKeyExpr(Relation rel, PartitionState *partTableState, Oid partOid
}
}
/*Check whether tables or partition stored in segment are created
in limited tablespaces */
void CheckSegmentIsInLimitTablespace(char* tablespacename, char* relname)
{
Oid tablespaceId = InvalidOid;
if (tablespacename != NULL) {
tablespaceId = get_tablespace_oid(tablespacename, false);
}
Oid tbspcId = (tablespaceId == InvalidOid) ? u_sess->proc_cxt.MyDatabaseTableSpace : tablespaceId;
uint64 tablespaceMaxSize = 0;
bool isLimit = TableSpaceUsageManager::IsLimited(tbspcId, &tablespaceMaxSize);
if (isLimit) {
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED), errmodule(MOD_SEGMENT_PAGE),
errmsg("The partition %s do not support segment-page storage", relname != NULL ? relname : ""),
errdetail("Segment-page storage doest not support limited tablespace \"%s\"", get_tablespace_name(tbspcId)),
errhint("use default or unlimited user defined tablespace before using segment-page storage.")));
}
}
/* ----------------------------------------------------------------
* DefineRelation
* Creates a new relation.
@ -2895,6 +2914,40 @@ ObjectAddress DefineRelation(CreateStmt* stmt, char relkind, Oid ownerId, Object
errdetail("Segment-page storage doest not support limited tablespace \"%s\"", get_tablespace_name(tbspcId)),
errhint("use default or unlimited user defined tablespace before using segment-page storage.")));
}
if (stmt->partTableState) {
ListCell* cell = NULL;
Oid partTablespaceId = InvalidOid;
char* partitionName = NULL;
char* tablespacename = NULL;
foreach (cell, stmt->partTableState->partitionList) {
char* partitionName = NULL;
char* tablespacename = NULL;
if (IsA((lfirst(cell)), IntervalPartitionDefState)) {
IntervalPartitionDefState* partition = (IntervalPartitionDefState*)lfirst(cell);
ListCell* speccell = NULL;
foreach(speccell, partition->intervalTablespaces) {
tablespacename = ((Value*)lfirst(speccell))->val.str;
CheckSegmentIsInLimitTablespace(tablespacename, NULL);
}
continue;
} else if (IsA((lfirst(cell)), RangePartitionDefState) || IsA((lfirst(cell)), HashPartitionDefState) || IsA((lfirst(cell)), ListPartitionDefState)) {
PartitionDefState* partition = (PartitionDefState*)lfirst(cell);
tablespacename = partition->tablespacename;
partitionName = partition->partitionName;
} else if (IsA((lfirst(cell)), RangePartitionStartEndDefState)) {
RangePartitionStartEndDefState* partition = (RangePartitionStartEndDefState*)lfirst(cell);
tablespacename = partition->tableSpaceName;
partitionName = partition->partitionName;
} else if (IsA((lfirst(cell)), RangePartitionindexDefState)) {
RangePartitionindexDefState* partition = (RangePartitionindexDefState*)lfirst(cell);
tablespacename = partition->tablespace;
partitionName = partition->name;
} else {
Assert(false);
}
CheckSegmentIsInLimitTablespace(tablespacename, partitionName);
}
}
}
if (ENABLE_DMS && !u_sess->attr.attr_common.IsInplaceUpgrade) {