diff --git a/src/connections/mysql.ts b/src/connections/mysql.ts index c181e2b..db63453 100644 --- a/src/connections/mysql.ts +++ b/src/connections/mysql.ts @@ -304,10 +304,13 @@ export class MySQLConnection extends SqlConnection { ); if (!columnLine) return; - const [columnNamePart, ...columnDefinitions] = - columnLine.split(' '); + const [columnNamePart, ...columnDefinitions] = columnLine + .trim() + .replace(/,$/, '') + .split(' '); - const query = `ALTER TABLE ${fullTableName} CHANGE ${columnNamePart} ${this.dialect.escapeId(newColumnName)} ${columnDefinitions.join(' ')}`; + const query = `ALTER TABLE ${fullTableName} CHANGE COLUMN ${columnNamePart} ${this.dialect.escapeId(newColumnName)} ${columnDefinitions.join(' ')}`; + console.log(query); await this.query({ query }); }