database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Add schema change check for DUPLICATE KEY table (#1844)

Browse Source
This commit is contained in:
kangkaisen
2019-09-20 22:33:08 +08:00
committed by Mingyu Chen
parent cc36905aea
commit 9036014954
1 changed files with 10 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
fe/src/main/java/org/apache/doris/alter/SchemaChangeHandler.java
View File

@ -923,20 +923,17 @@ public class SchemaChangeHandler extends AlterHandler {
throw new DdlException("No key column left. index[" + olapTable.getIndexNameById(alterIndexId) + "]");
}
if (KeysType.AGG_KEYS == olapTable.getKeysType()
|| KeysType.UNIQUE_KEYS == olapTable.getKeysType()) {
// 2. check compatible
for (Column alterColumn : alterSchema) {
for (Column oriColumn : originSchema) {
if (alterColumn.nameEquals(oriColumn.getName(), true /* ignore prefix */)) {
if (!alterColumn.equals(oriColumn)) {
// 3.1 check type
oriColumn.checkSchemaChangeAllowed(alterColumn);
}
// 2. check compatible
for (Column alterColumn : alterSchema) {
for (Column oriColumn : originSchema) {
if (alterColumn.nameEquals(oriColumn.getName(), true /* ignore prefix */)) {
if (!alterColumn.equals(oriColumn)) {
// 3.1 check type
oriColumn.checkSchemaChangeAllowed(alterColumn);
}
} // end for ori
} // end for alter
}
}
} // end for ori
} // end for alter
// 3. check partition key
PartitionInfo partitionInfo = olapTable.getPartitionInfo();