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

!5915 【bugfix】补充按需回放redo节点适配ddl，reindex database场景的适配

Browse Source 
Merge pull request !5915 from 周聪/bugfix_redo_phase_enable_ddl_reindex_database
This commit is contained in:
opengauss_bot
2024-08-02 01:41:56 +00:00
committed by Gitee
parent 53ff4ffa7c f9b28194eb
commit 51623ea917
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/gausskernel/process/tcop/utility.cpp
View File

@ -13908,13 +13908,15 @@ struct OndemandParseInfo {
NodeTag parseType;
ObjectType objectType;
RangeVar* relationRangeVar;
const char* dbName;
};
static List* AppendItemToOndemandParseList(List* ondemandParseList, NodeTag parseType, ObjectType objectType, RangeVar* relationRangeVar) {
static List* AppendItemToOndemandParseList(List* ondemandParseList, NodeTag parseType, ObjectType objectType, RangeVar* relationRangeVar, const char* dbName = NULL) {
OndemandParseInfo* info = (OndemandParseInfo*)palloc(sizeof(OndemandParseInfo));
info->parseType = parseType;
info->objectType = objectType;
info->relationRangeVar = relationRangeVar;
info->dbName = dbName;
ondemandParseList = lappend(ondemandParseList, info);
return ondemandParseList;
}
@ -14011,7 +14013,8 @@ static void PreRedoInOndemandRecovery(Node* parseTree) {
case T_ReindexStmt: {
ReindexStmt* reindexStmt = (ReindexStmt*) parseTree;
ondemandParseList = AppendItemToOndemandParseList(ondemandParseList, T_ReindexStmt,
reindexStmt->kind, reindexStmt->relation);
reindexStmt->kind, reindexStmt->relation,
reindexStmt->kind == OBJECT_DATABASE ? reindexStmt->name : NULL);
break;
}
/* ALTER TABLE/INDEX/PROCEDURE/ SET SCHEMA */
@ -14045,7 +14048,17 @@ static void PreRedoInOndemandRecovery(Node* parseTree) {
case T_AlterOwnerStmt: {
break;
}
case T_ReindexStmt:
case T_ReindexStmt: {
const char* dbName = ondemandParseInfo->dbName;
Oid dbOid = get_database_oid_by_name(dbName);
if (!OidIsValid(dbOid)) {
ereport(ERROR,
(errcode(ERRCODE_UNDEFINED_OBJECT), errmsg("Database \"%s\" does not exist.", dbName)));
break;
}
RedoDatabaseForOndemandExtremeRTO(dbOid);
break;
}
default: {
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("[On-demand] Not support this sql in ondemand redo phase, nodeType: %d, relKind: %d.",