Function generateMigrationSQL

src/utils/migrations/diffToSQL.js:241–948

(
  diff,
  database = DB.POSTGRES,
  diagrams,
)

}

export const generateMigrationSQL = (
  diff,
  database = DB.POSTGRES,
  diagrams,
) => {
  const q = getQuote(database);
  let up = [];
  let down = [];

  for (const [path, change] of Object.entries(diff)) {
    const keys = path.split("#");
    const bracketStart = keys[0].indexOf("[");
    const element =
      bracketStart >= 0 ? keys[0].substring(0, bracketStart) : keys[0];
    const nameStart = keys[0].indexOf("name=");
    const name =
      nameStart >= 0
        ? keys[0].substring(nameStart + 5, keys[0].indexOf("]", nameStart))
        : "";

    switch (element) {
      case "tables": {
        if (keys.length === 1 && change.from && !change.to) {
          up.push(`DROP TABLE ${q(change.from.name)};`);
          down.push(toTable(change.from, database));
        }
        if (keys.length === 1 && change.to && !change.from) {
          up.push(toTable(change.to, database));
          down.push(`DROP TABLE ${q(change.to.name)};`);
        }

        if (keys.length > 1) {
          const childPart = keys[1];

          if (childPart.startsWith("fields")) {
            const columnName = childPart.substring(
              childPart.indexOf("name=") + 5,
              childPart.indexOf(",type="),
            );
            const columnType = childPart.substring(
              childPart.indexOf("type=") + 5,
              childPart.indexOf("]"),
            );

            const property = keys[2];

            if (!property) {
              if (change.from && !change.to) {
                up.push(`ALTER TABLE ${q(name)} DROP COLUMN ${q(columnName)};`);
                const addCol =
                  database === DB.MSSQL
                    ? `ADD ${q(columnName)} ${columnDefinition(change.from, database)}`
                    : database === DB.ORACLESQL
                      ? `ADD (${q(columnName)} ${columnDefinition(change.from, database)})`
                      : `ADD COLUMN ${q(columnName)} ${columnDefinition(change.from, database)}`;
                down.push(`ALTER TABLE ${q(name)} ${addCol};`);
              }
              if (change.to && !change.from) {