App\Db\Importer::updateTables()

Complexity

Conditions	48
Paths	> 20000

Size

Total Lines	156
Code Lines	121

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2352

Importance

Changes

0

<?php
	public function updateTables(Base $importer)
	{
		$this->logs .= "> start update tables ({$importer->dbType})\n";
		$startMain = microtime(true);
		$schema = $importer->db->getSchema();
		$queryBuilder = $schema->getQueryBuilder();
		$dbCommand = $importer->db->createCommand();
		foreach ($importer->tables as $tableName => $table) {
			try {
				if (!$importer->db->isTableExists($tableName)) {
					$this->logs .= "  > add table: $tableName ... ";
					$start = microtime(true);
					$dbCommand->createTable($tableName, $this->getColumns($importer, $table), $this->getOptions($importer, $table))->execute();
					$time = round((microtime(true) - $start), 1);
					$this->logs .= "done    ({$time}s)\n";
				} else {
					$tableSchema = $schema->getTableSchema($tableName);
					foreach ($this->getColumns($importer, $table) as $columnName => $column) {
						$renameFrom = $mode = null;
						if (\is_array($column)) {
							$renameFrom = $column['renameFrom'] ?? '';
							$mode = $column['mode'] ?? $mode; // 0,null - create/update, 1 - update only
							$column = $column['type'] ?? '';
						}
						$columnExists = isset($tableSchema->columns[$columnName]);
						if ($renameFrom && !$columnExists && isset($tableSchema->columns[$renameFrom])) {
							$this->logs .= "  > rename column: {$tableName}:{$renameFrom} -> {$columnName}... ";
							$start = microtime(true);
							$dbCommand->renameColumn($tableName, $renameFrom, $columnName)->execute();
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "done    ({$time}s)\n";
							$tableSchema = $schema->getTableSchema($tableName, true);
							$columnExists = isset($tableSchema->columns[$columnName]);
						}elseif (!$columnExists && 1 !== $mode) {
							$this->logs .= "  > add column: $tableName:$columnName ... ";
							$start = microtime(true);
							$dbCommand->addColumn($tableName, $columnName, $column)->execute();
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "done    ({$time}s)\n";
						}
						if ($columnExists && $column instanceof \yii\db\ColumnSchemaBuilder && $this->compareColumns($queryBuilder, $tableSchema->columns[$columnName], $column)) {
							$primaryKey = false;
							if ($column instanceof \yii\db\ColumnSchemaBuilder && (\in_array($column->get('type'), ['upk', 'pk', 'ubigpk', 'bigpk']))) {
								$primaryKey = true;
								$column->set('type', \in_array($column->get('type'), ['ubigpk', 'bigpk']) ? \yii\db\Schema::TYPE_BIGINT : \yii\db\Schema::TYPE_INTEGER);
							}
							if ($tableSchema->foreignKeys) {

The expression $tableSchema->foreignKeys of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

								foreach ($tableSchema->foreignKeys as $keyName => $value) {
									if (isset($value[$columnName])) {
										$this->logs .= "  > foreign key must be removed and added in postUpdate: $tableName:$columnName <> {$value[0]}:{$value[$columnName]} FK:{$keyName}\n";
										$importer->foreignKey[] = [$keyName, $tableName, $columnName, $value[0], $value[$columnName], 'CASCADE', null];
										$dbCommand->dropForeignKey($keyName, $tableName)->execute();
									}
								}
							}
							foreach ($schema->findForeignKeyToColumn($tableName, $columnName) as $sourceTableName => $fks) {
								foreach ($fks as $keyName => $fk) {
									$this->logs .= "  > foreign key must be removed and added in postUpdate: $tableName:$columnName <> $sourceTableName:{$fk['sourceColumn']} FK:{$keyName}\n";
									$importer->foreignKey[] = [$keyName, $sourceTableName, $fk['sourceColumn'], $tableName, $columnName, 'CASCADE', null];
									$dbCommand->dropForeignKey($keyName, $sourceTableName)->execute();
								}
							}
							$this->logs .= "  > alter column: $tableName:$columnName ... ";
							$start = microtime(true);
							$dbCommand->alterColumn($tableName, $columnName, $column)->execute();
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "done    ({$time}s)\n";
							if ($primaryKey) {
								if (!isset($table['primaryKeys'])) {
									$table['primaryKeys'] = [];
								}
								$table['primaryKeys'][] = [$tableSchema->fullName . '_pk', [$columnName]];
							}
						} elseif (!($column instanceof \yii\db\ColumnSchemaBuilder)) {
							$this->logs .= "  > Warning: column ({$tableName}:{$columnName}) is not verified\n";
						}
					}
				}
			} catch (\Throwable $e) {
				$this->logs .= " | Error(7) {$tableName} [{$e->getMessage()}] in  \n{$e->getTraceAsString()} !!!\n";
				if ($this->dieOnError) {
					throw new \App\Exceptions\AppException('Importer error: ' . $e->getMessage(), (int) $e->getCode(), $e);
				}
			}
			if ($indexes = $this->getIndexes($importer, $table)) {
				$dbIndexes = $importer->db->getTableKeys($tableName);
				foreach ($indexes as $index) {
					try {
						if (isset($dbIndexes[$index[0]])) {
							$update = false;
							if (\is_string($index[1]) ? !isset($dbIndexes[$index[0]][$index[1]]) : array_diff($index[1], array_keys($dbIndexes[$index[0]]))) {
								$update = true;
							} else {
								foreach ($dbIndexes[$index[0]] as $dbIndex) {
									if (empty($index[2]) !== empty($dbIndex['unique'])) {
										$update = true;
									}
								}
							}
							if ($update) {
								$this->logs .= "  > update index: {$index[0]} ... ";
								$start = microtime(true);
								$dbCommand->dropIndex($index[0], $tableName)->execute();
								$dbCommand->createIndex($index[0], $tableName, $index[1], !empty($index[2]))->execute();
								$time = round((microtime(true) - $start), 1);
								$this->logs .= "done    ({$time}s)\n";
							}
						} else {
							$this->logs .= "  > create index: {$index[0]} ... ";
							$start = microtime(true);
							$dbCommand->createIndex($index[0], $tableName, $index[1], !empty($index[2]))->execute();
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "done    ({$time}s)\n";
						}
					} catch (\Throwable $e) {
						$this->logs .= " | Error(8) [{$e->getMessage()}] in  \n{$e->getTraceAsString()} !!!\n";
						if ($this->dieOnError) {
							throw new \App\Exceptions\AppException('Importer error: ' . $e->getMessage(), (int) $e->getCode(), $e);
						}
					}
				}
			}
			if (isset($table['primaryKeys'])) {
				$dbPrimaryKeys = $importer->db->getPrimaryKey($tableName);
				foreach ($table['primaryKeys'] as $primaryKey) {
					$status = true;
					foreach ($dbPrimaryKeys as $dbPrimaryKey) {
						if (\is_string($primaryKey[1]) ? !(1 !== \count($dbPrimaryKey) && $primaryKey[1] !== $dbPrimaryKey[0]) : !array_diff($primaryKey[1], $dbPrimaryKey)) {
							$status = false;
						}
					}
					if ($status) {
						$this->logs .= "  > update primary key: {$primaryKey[0]} , table: $tableName , column: " . (\is_array($primaryKey[1]) ? implode(',', $primaryKey[1]) : $primaryKey[1]) . ' ... ';
						$start = microtime(true);
						try {
							if (isset($dbPrimaryKeys[$primaryKey[0]])) {
								$dbCommand->dropPrimaryKey($primaryKey[0], $tableName)->execute();
							} elseif ($dbPrimaryKeys) {
								$dbCommand->dropPrimaryKey(key($dbPrimaryKeys), $tableName)->execute();
							}
							$dbCommand->addPrimaryKey($primaryKey[0], $tableName, $primaryKey[1])->execute();
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "done    ({$time}s)\n";
						} catch (\Throwable $e) {
							$time = round((microtime(true) - $start), 1);
							$this->logs .= "    ({$time}s) | Error(10) [{$e->getMessage()}] in \n{$e->getTraceAsString()} !!!\n";
							if ($this->dieOnError) {
								throw new \App\Exceptions\AppException('Importer error: ' . $e->getMessage(), (int) $e->getCode(), $e);
							}
						}
					}
				}
			}
		}
		$time = round((microtime(true) - $startMain) / 60, 2);
		$this->logs .= "# end update tables    ({$time}s)\n";
	}