MySql-Entwicklung einer automatischen Synchronisierungstabellenstruktur

Tabelle von rd_db anzeigen;
Tabelle anzeigen, erstellen, hinzugefügter_Tabellenname;

wählen 
 SPALTENNAME, SPALTENTYP, IS_NULLABLE, SPALTENSTANDARD, SPALTENKOMMENTAR, EXTRA 
aus 
 information_schema.columns
Wo 
  TABLE_SCHEMA='rd_db'
  und TABLE_NAME = 'rd_table';

        für (Spalte Spalte: sourceTable.getColumns().values()) {
            wenn (targetTable.getColumns().get(column.getName()) == null) {
                // Wenn das entsprechende Ziel dieses Feld nicht hat, ändern Sie es direkt
                String sql = "Tabelle ändern " + target.getSchema() + "." + targetTable.getTableName() + " hinzufügen " + Spalte
                        .getName() + " ";
                sql += Spalte.getType() + " ";
                wenn (Spalte.getIsNull().equals("NEIN")) {
                    sql += "NICHT NULL ";
                } anders {
                    sql += "NULL";
                }
                wenn (Spalte.getDefaultValue() != null) {
                    sql += "DEFAULT " + SqlUtil.getDbString(column.getDefaultValue()) + " ";
                }
                if (column.getComment() != null) {
                    sql += "KOMMENTAR " + SqlUtil.getDbString(column.getComment()) + " ";
                }
                wenn (nach != null) {
                    sql += "nach " + nach;
                }
                ändereSql.add(sql+";");
            } anders {
                //Überprüfen Sie die entsprechenden Quell- und Zielattribute String sql =
                        "Tabelle ändern " + target.getSchema() + "." + targetTable.getTableName() + " ändern " + Spalte
                                .getName() + " ";
                Spalte Quellspalte = Spalte;
                Spalte Zielspalte = Zieltabelle.getColumns().get(Quellspalte.getName());
                // Vergleichen Sie die beiden Felder. Wenn null zurückgegeben wird, weist dies auf Konsistenz hin. String sqlExtend = compareSingleColumn(sourceColumn, targetColumn);
                if (sqlExtend != null) {
                    changeSql.add(sql + sqlExtend+";");
                }
            }
            nach = Spalte.getName();
        }

sourceHost=127.0.0.1:3306
Quellbenutzer=root
Quellpasswort = 123123123
Quellschema = mystique_db
Quellzeichensatz = utf8

Zielhost = 127.0.0.1:3306
Zielbenutzer=root
ZielPass=123123123
Zielschema = Mystique_Test
ZielZeichensatz=utf8

autoExecute=YES //Dies zeigt die automatische Synchronisierung an

alchemystar.runner.ShellRunner 

alter table mystique_test.t_test_3 change id id bigint(20) NOT NULL AUTO_INCREMENT COMMENT ''
Tabelle mystique_test.t_test_3 ändern, Index hinzufügen (Name)
alter table mystique_test.t_test_3 drop index name_id
alter table mystique_test.t_test_3 add id_2 varchar(50) NULL DEFAULT '' COMMENT '' nach Name