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

add Mysql Feature ON UPDATE Syntax. It supports CREATE TABLE/ALTER TABLE DDL, and tools which include pg_dump and gsql adaptiving.

Browse Source 
根据社区评审意见，对代码进行修改和优化。
This commit is contained in:
lvhui
2022-06-27 16:31:37 +08:00
parent b07c959bd0
commit d5a9c5ff35
37 changed files with 1388 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/common/backend/utils/cache/relcache.cpp vendored
View File

@ -1717,11 +1717,14 @@ static void RelationBuildTupleDesc(Relation relation, bool onlyLoadInitDefVal)
constr->num_defval = ndef;
constr->generatedCols = (char *)MemoryContextAllocZero(LocalMyDBCacheMemCxt(),
RelationGetNumberOfAttributes(relation) * sizeof(char));
constr->has_on_update = (bool *)MemoryContextAllocZero(LocalMyDBCacheMemCxt(),
RelationGetNumberOfAttributes(relation) * sizeof(bool));
AttrDefaultFetch(relation);
} else {
constr->num_defval = 0;
constr->defval = NULL;
constr->generatedCols = NULL;
constr->has_on_update = NULL;
}
if (relation->rd_rel->relchecks > 0) /* CHECKs */
@ -5527,6 +5530,28 @@ static void GeneratedColFetch(TupleConstr *constr, HeapTuple htup, Relation adre
}
}
/*
* Load updated column attribute value definitions for the relation.
*/
static void UpdatedColFetch(TupleConstr *constr, HeapTuple htup, Relation adrel, int attrdefIndex)
{
bool *on_update = constr->has_on_update;
AttrDefault *attrdef = constr->defval;
bool updatedCol = false;
if (HeapTupleHeaderGetNatts(htup->t_data, adrel->rd_att) >= Anum_pg_attrdef_adsrc_on_update) {
bool isnull = false;
Datum val;
val = fastgetattr(htup, Anum_pg_attrdef_adsrc_on_update, adrel->rd_att, &isnull);
if (val && pg_strcasecmp(TextDatumGetCString(val), "") == 0) {
updatedCol = false;
} else {
updatedCol = true;
}
}
attrdef[attrdefIndex].has_on_update = updatedCol;
on_update[attrdef[attrdefIndex].adnum - 1] = updatedCol;
}
/*
* Load any default attribute value definitions for the relation.
*/
@ -5563,12 +5588,18 @@ static void AttrDefaultFetch(Relation relation)
GeneratedColFetch(relation->rd_att->constr, htup, adrel, i);
}
UpdatedColFetch(relation->rd_att->constr, htup, adrel, i);
val = fastgetattr(htup, Anum_pg_attrdef_adbin, adrel->rd_att, &isnull);
if (isnull)
ereport(WARNING, (errmsg("null adbin for attr %s of rel %s",
NameStr(relation->rd_att->attrs[adform->adnum - 1]->attname), RelationGetRelationName(relation))));
else
attrdef[i].adbin = MemoryContextStrdup(LocalMyDBCacheMemCxt(), TextDatumGetCString(val));
val = fastgetattr(htup, Anum_pg_attrdef_adbin_on_update, adrel->rd_att, &isnull);
if (!isnull)
attrdef[i].adbin_on_update = MemoryContextStrdup(LocalMyDBCacheMemCxt(), TextDatumGetCString(val));
break;
}