Add duplicate column check for add column to encrypt table

apache · Oct 12, 2023 · 5d2658b · 5d2658b
1 parent 864b2cd
commit 5d2658b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...pache/shardingsphere/encrypt/rewrite/token/generator/EncryptAlterTableTokenGenerator.java b/...pache/shardingsphere/encrypt/rewrite/token/generator/EncryptAlterTableTokenGenerator.java
@@ -121,7 +121,10 @@ private Optional<SQLToken> getAddColumnPositionToken(final EncryptTable encryptT
         if (columnPositionSegment.isPresent()) {
             String columnName = columnPositionSegment.get().getColumnName().getIdentifier().getValue();
             if (encryptTable.isEncryptColumn(columnName)) {
-                return Optional.of(getPositionColumnToken(encryptTable.getEncryptColumn(columnName), segment.getColumnPosition().get()));
+                EncryptColumn encryptColumn = encryptTable.getEncryptColumn(columnName);
+                ShardingSpherePreconditions.checkState(encryptColumn.getName().equals(encryptColumn.getCipher().getName()),
+                        () -> new UnsupportedOperationException(String.format("Column %s is already exists", columnName)));
+                return Optional.of(getPositionColumnToken(encryptColumn, segment.getColumnPosition().get()));
             }
         }
         return Optional.empty();