Class yii\mongodb\console\controllers\MigrateController

                protected function addMigrationHistory($version)
{
    $this->db->getCollection($this->migrationCollection)->insert([
        'version' => $version,
        'apply_time' => time(),
    ]);
}

            

                public function beforeAction($action)
{
    if (parent::beforeAction($action)) {
        if ($action->id !== 'create') {
            if (is_string($this->db)) {
                $this->db = Yii::$app->get($this->db);
            }
            if (!$this->db instanceof Connection) {
                throw new Exception("The 'db' option must refer to the application component ID of a MongoDB connection.");
            }
        }
        return true;
    }
    return false;
}

            

                protected function createMigration($class)
{
    // since Yii 2.0.12 includeMigrationFile() exists, which replaced the code below
    // remove this construct when composer requirement raises above 2.0.12
    if (method_exists($this, 'includeMigrationFile')) {
        $this->includeMigrationFile($class);
    } else {
        $class = trim($class, '\\');
        if (strpos($class, '\\') === false) {
            $file = $this->migrationPath . DIRECTORY_SEPARATOR . $class . '.php';
            require_once($file);
        }
    }
    return new $class(['db' => $this->db, 'compact' => isset($this->compact) ? $this->compact : false]);
}

            

                protected function ensureBaseMigrationHistory()
{
    if (!$this->baseMigrationEnsured) {
        $query = new Query;
        $row = $query->select(['version'])
            ->from($this->migrationCollection)
            ->andWhere(['version' => self::BASE_MIGRATION])
            ->limit(1)
            ->one($this->db);
        if (empty($row)) {
            $this->addMigrationHistory(self::BASE_MIGRATION);
        }
        $this->baseMigrationEnsured = true;
    }
}

            

                protected function getMigrationHistory($limit)
{
    $this->ensureBaseMigrationHistory();
    $query = (new Query())
        ->select(['version', 'apply_time'])
        ->from($this->migrationCollection)
        ->orderBy(['apply_time' => SORT_DESC, 'version' => SORT_DESC]);
    if (empty($this->migrationNamespaces)) {
        $query->limit($limit);
        $rows = $query->all($this->db);
        $history = ArrayHelper::map($rows, 'version', 'apply_time');
        unset($history[self::BASE_MIGRATION]);
        return $history;
    }
    $rows = $query->all($this->db);
    $history = [];
    foreach ($rows as $key => $row) {
        if ($row['version'] === self::BASE_MIGRATION) {
            continue;
        }
        if (preg_match('/m?(\d{6}_?\d{6})(\D.*)?$/is', $row['version'], $matches)) {
            $time = str_replace('_', '', $matches[1]);
            $row['canonicalVersion'] = $time;
        } else {
            $row['canonicalVersion'] = $row['version'];
        }
        $row['apply_time'] = (int)$row['apply_time'];
        $history[] = $row;
    }
    usort($history, function ($a, $b) {
        if ($a['apply_time'] === $b['apply_time']) {
            if (($compareResult = strcasecmp($b['canonicalVersion'], $a['canonicalVersion'])) !== 0) {
                return $compareResult;
            }
            return strcasecmp($b['version'], $a['version']);
        }
        return ($a['apply_time'] > $b['apply_time']) ? -1 : +1;
    });
    $history = array_slice($history, 0, $limit);
    $history = ArrayHelper::map($history, 'version', 'apply_time');
    return $history;
}

            

                public function options($actionID)
{
    return array_merge(
        parent::options($actionID),
        ['migrationCollection', 'db'] // global for all actions
    );
}

            

                protected function removeMigrationHistory($version)
{
    $this->db->getCollection($this->migrationCollection)->remove([
        'version' => $version,
    ]);
}

            

                protected function truncateDatabase()
{
    $collections = $this->db->getDatabase()->createCommand()->listCollections();
    foreach ($collections as $collection) {
        if (in_array($collection['name'], ['system.roles', 'system.users', 'system.indexes'])) {
            // prevent deleting database auth data
            // access to 'system.indexes' is more likely to be restricted, thus indexes will be dropped manually per collection
            $this->stdout("System collection {$collection['name']} skipped.\n");
            continue;
        }
        if (in_array($collection['name'], ['system.profile', 'system.js'])) {
            // dropping of system collection is unlikely to be permitted, attempt to clear them out instead
            $this->db->getDatabase()->createCommand()->delete($collection['name'], []);
            $this->stdout("System collection {$collection['name']} truncated.\n");
            continue;
        }
        $this->db->getDatabase()->createCommand()->dropIndexes($collection['name'], '*');
        $this->db->getDatabase()->dropCollection($collection['name']);
        $this->stdout("Collection {$collection['name']} dropped.\n");
    }
}