@@ -133,7 +133,7 @@ struct SchemaStatementGenerator {
133133 // MARK: - Column Operations
134134
135135 private func generateAddColumn( _ column: EditableColumnDefinition ) -> SchemaStatement ? {
136- guard let sql = pluginDriver. generateAddColumnSQL ( table: tableName, column: toPluginColumnDefinition ( column) ) else {
136+ guard let sql = pluginDriver. generateAddColumnSQL ( table: tableName, column: column. toPlugin ( ) ) else {
137137 return nil
138138 }
139139 return SchemaStatement ( sql: sql, description: " Add column ' \( column. name) ' " , isDestructive: false )
@@ -142,8 +142,8 @@ struct SchemaStatementGenerator {
142142 private func generateModifyColumn( old: EditableColumnDefinition , new: EditableColumnDefinition ) -> SchemaStatement ? {
143143 guard let sql = pluginDriver. generateModifyColumnSQL (
144144 table: tableName,
145- oldColumn: toPluginColumnDefinition ( old) ,
146- newColumn: toPluginColumnDefinition ( new)
145+ oldColumn: old. toPlugin ( ) ,
146+ newColumn: new. toPlugin ( )
147147 ) else {
148148 return nil
149149 }
@@ -164,15 +164,15 @@ struct SchemaStatementGenerator {
164164 // MARK: - Index Operations
165165
166166 private func generateAddIndex( _ index: EditableIndexDefinition ) -> SchemaStatement ? {
167- guard let sql = pluginDriver. generateAddIndexSQL ( table: tableName, index: toPluginIndexDefinition ( index) ) else {
167+ guard let sql = pluginDriver. generateAddIndexSQL ( table: tableName, index: index. toPlugin ( ) ) else {
168168 return nil
169169 }
170170 return SchemaStatement ( sql: sql, description: " Add index ' \( index. name) ' " , isDestructive: false )
171171 }
172172
173173 private func generateModifyIndex( old: EditableIndexDefinition , new: EditableIndexDefinition ) -> SchemaStatement ? {
174174 guard let dropSql = pluginDriver. generateDropIndexSQL ( table: tableName, indexName: old. name) ,
175- let addSql = pluginDriver. generateAddIndexSQL ( table: tableName, index: toPluginIndexDefinition ( new) ) else {
175+ let addSql = pluginDriver. generateAddIndexSQL ( table: tableName, index: new. toPlugin ( ) ) else {
176176 return nil
177177 }
178178 let sql = " \( dropSql) ; \n \( addSql) ; "
@@ -195,7 +195,7 @@ struct SchemaStatementGenerator {
195195 private func generateAddForeignKey( _ fk: EditableForeignKeyDefinition ) -> SchemaStatement ? {
196196 guard let sql = pluginDriver. generateAddForeignKeySQL (
197197 table: tableName,
198- fk: toPluginForeignKeyDefinition ( fk )
198+ fk: fk . toPlugin ( )
199199 ) else {
200200 return nil
201201 }
@@ -204,7 +204,7 @@ struct SchemaStatementGenerator {
204204
205205 private func generateModifyForeignKey( old: EditableForeignKeyDefinition , new: EditableForeignKeyDefinition ) -> SchemaStatement ? {
206206 guard let dropSql = pluginDriver. generateDropForeignKeySQL ( table: tableName, constraintName: old. name) ,
207- let addSql = pluginDriver. generateAddForeignKeySQL ( table: tableName, fk: toPluginForeignKeyDefinition ( new) ) else {
207+ let addSql = pluginDriver. generateAddForeignKeySQL ( table: tableName, fk: new. toPlugin ( ) ) else {
208208 return nil
209209 }
210210 let sql = " \( dropSql) ; \n \( addSql) ; "
@@ -238,39 +238,4 @@ struct SchemaStatementGenerator {
238238 )
239239 }
240240
241- // MARK: - Plugin Type Converters
242-
243- private func toPluginColumnDefinition( _ col: EditableColumnDefinition ) -> PluginColumnDefinition {
244- PluginColumnDefinition (
245- name: col. name,
246- dataType: col. dataType,
247- isNullable: col. isNullable,
248- defaultValue: col. defaultValue,
249- isPrimaryKey: col. isPrimaryKey,
250- autoIncrement: col. autoIncrement,
251- comment: col. comment,
252- unsigned: col. unsigned,
253- onUpdate: col. onUpdate
254- )
255- }
256-
257- private func toPluginIndexDefinition( _ index: EditableIndexDefinition ) -> PluginIndexDefinition {
258- PluginIndexDefinition (
259- name: index. name,
260- columns: index. columns,
261- isUnique: index. isUnique,
262- indexType: index. type. rawValue
263- )
264- }
265-
266- private func toPluginForeignKeyDefinition( _ fk: EditableForeignKeyDefinition ) -> PluginForeignKeyDefinition {
267- PluginForeignKeyDefinition (
268- name: fk. name,
269- columns: fk. columns,
270- referencedTable: fk. referencedTable,
271- referencedColumns: fk. referencedColumns,
272- onDelete: fk. onDelete. rawValue,
273- onUpdate: fk. onUpdate. rawValue
274- )
275- }
276241}
0 commit comments