diff --git a/chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/builder/MysqlSqlBuilder.java b/chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/builder/MysqlSqlBuilder.java index 1a97c843..7a2c3830 100644 --- a/chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/builder/MysqlSqlBuilder.java +++ b/chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/builder/MysqlSqlBuilder.java @@ -11,9 +11,7 @@ import ai.chat2db.spi.model.TableIndex; import cn.hutool.core.util.ArrayUtil; import org.apache.commons.lang3.StringUtils; -import java.util.Arrays; -import java.util.HashMap; -import java.util.Map; +import java.util.*; public class MysqlSqlBuilder extends DefaultSqlBuilder implements SqlBuilder { @@ -163,6 +161,12 @@ public class MysqlSqlBuilder extends DefaultSqlBuilder implements SqlBuilder { String[] oldColumnArray = oldTable.getColumnList().stream().map(TableColumn::getName).toArray(String[]::new); String[] newColumnArray = newTable.getColumnList().stream().map(TableColumn::getName).toArray(String[]::new); + Set oldColumnSet = new HashSet<>(Arrays.asList(oldColumnArray)); + Set newColumnSet = new HashSet<>(Arrays.asList(newColumnArray)); + if (!oldColumnSet.equals(newColumnSet)) { + return ""; + } + buildSql(oldColumnArray, newColumnArray, sql, oldTable, newTable, n); return sql.toString();