@@ -572,30 +572,30 @@ public function createTable(string $table, bool $ifNotExists = false, array $att
572572 */
573573 protected function _createTable (string $ table , bool $ ifNotExists , array $ attributes )
574574 {
575- $ columns = $ this ->_processFields (true );
575+ $ processedFields = $ this ->_processFields (true );
576576
577- for ($ i = 0 , $ c = count ($ columns ); $ i < $ c ; $ i ++) {
578- $ columns [$ i ] = ($ columns [$ i ]['_literal ' ] !== false ) ? "\n\t" . $ columns [$ i ]['_literal ' ]
579- : "\n\t" . $ this ->_processColumn ($ columns [$ i ]);
577+ for ($ i = 0 , $ c = count ($ processedFields ); $ i < $ c ; $ i ++) {
578+ $ processedFields [$ i ] = ($ processedFields [$ i ]['_literal ' ] !== false ) ? "\n\t" . $ processedFields [$ i ]['_literal ' ]
579+ : "\n\t" . $ this ->_processColumn ($ processedFields [$ i ]);
580580 }
581581
582- $ columns = implode (', ' , $ columns );
582+ $ processedFields = implode (', ' , $ processedFields );
583583
584- $ columns .= $ this ->_processPrimaryKeys ($ table );
585- $ columns .= current ($ this ->_processForeignKeys ($ table ));
584+ $ processedFields .= $ this ->_processPrimaryKeys ($ table );
585+ $ processedFields .= current ($ this ->_processForeignKeys ($ table ));
586586
587587 if ($ this ->createTableKeys === true ) {
588588 $ indexes = current ($ this ->_processIndexes ($ table ));
589589 if (is_string ($ indexes )) {
590- $ columns .= $ indexes ;
590+ $ processedFields .= $ indexes ;
591591 }
592592 }
593593
594594 return sprintf (
595595 $ this ->createTableStr . '%s ' ,
596596 'CREATE TABLE ' ,
597597 $ this ->db ->escapeIdentifiers ($ table ),
598- $ columns ,
598+ $ processedFields ,
599599 $ this ->_createTableAttributes ($ attributes )
600600 );
601601 }
@@ -817,30 +817,31 @@ public function modifyColumn(string $table, $field): bool
817817 }
818818
819819 /**
820- * @param array|string $fields
820+ * @param 'ADD'|'CHANGE'|'DROP' $alterType
821+ * @param array|string $processedFields Processed column definitions
821822 *
822823 * @return false|string|string[]
823824 */
824- protected function _alterTable (string $ alterType , string $ table , $ fields )
825+ protected function _alterTable (string $ alterType , string $ table , $ processedFields )
825826 {
826827 $ sql = 'ALTER TABLE ' . $ this ->db ->escapeIdentifiers ($ table ) . ' ' ;
827828
828829 // DROP has everything it needs now.
829830 if ($ alterType === 'DROP ' ) {
830- if (is_string ($ fields )) {
831- $ fields = explode (', ' , $ fields );
831+ if (is_string ($ processedFields )) {
832+ $ processedFields = explode (', ' , $ processedFields );
832833 }
833834
834- $ fields = array_map (fn ($ field ) => 'DROP COLUMN ' . $ this ->db ->escapeIdentifiers (trim ($ field )), $ fields );
835+ $ processedFields = array_map (fn ($ field ) => 'DROP COLUMN ' . $ this ->db ->escapeIdentifiers (trim ($ field )), $ processedFields );
835836
836- return $ sql . implode (', ' , $ fields );
837+ return $ sql . implode (', ' , $ processedFields );
837838 }
838839
839840 $ sql .= ($ alterType === 'ADD ' ) ? 'ADD ' : $ alterType . ' COLUMN ' ;
840841
841842 $ sqls = [];
842843
843- foreach ($ fields as $ data ) {
844+ foreach ($ processedFields as $ data ) {
844845 $ sqls [] = $ sql . ($ data ['_literal ' ] !== false
845846 ? $ data ['_literal ' ]
846847 : $ this ->_processColumn ($ data ));
@@ -850,15 +851,15 @@ protected function _alterTable(string $alterType, string $table, $fields)
850851 }
851852
852853 /**
853- * Process fields
854+ * Returns $processedFields array from $this-> fields data.
854855 */
855856 protected function _processFields (bool $ createTable = false ): array
856857 {
857- $ fields = [];
858+ $ processedFields = [];
858859
859860 foreach ($ this ->fields as $ name => $ attributes ) {
860861 if (! is_array ($ attributes )) {
861- $ fields [] = ['_literal ' => $ attributes ];
862+ $ processedFields [] = ['_literal ' => $ attributes ];
862863
863864 continue ;
864865 }
@@ -932,24 +933,24 @@ protected function _processFields(bool $createTable = false): array
932933 $ field ['length ' ] = '( ' . $ attributes ['CONSTRAINT ' ] . ') ' ;
933934 }
934935
935- $ fields [] = $ field ;
936+ $ processedFields [] = $ field ;
936937 }
937938
938- return $ fields ;
939+ return $ processedFields ;
939940 }
940941
941942 /**
942- * Process column
943+ * Converts $processedField array to field definition string.
943944 */
944- protected function _processColumn (array $ field ): string
945+ protected function _processColumn (array $ processedField ): string
945946 {
946- return $ this ->db ->escapeIdentifiers ($ field ['name ' ])
947- . ' ' . $ field ['type ' ] . $ field ['length ' ]
948- . $ field ['unsigned ' ]
949- . $ field ['default ' ]
950- . $ field ['null ' ]
951- . $ field ['auto_increment ' ]
952- . $ field ['unique ' ];
947+ return $ this ->db ->escapeIdentifiers ($ processedField ['name ' ])
948+ . ' ' . $ processedField ['type ' ] . $ processedField ['length ' ]
949+ . $ processedField ['unsigned ' ]
950+ . $ processedField ['default ' ]
951+ . $ processedField ['null ' ]
952+ . $ processedField ['auto_increment ' ]
953+ . $ processedField ['unique ' ];
953954 }
954955
955956 /**
0 commit comments