vendor/davedevelopment/phpmig/src/Phpmig/Adapter/Mongo.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Phpmig\Adapter;

use Phpmig\Migration\Migration,
    Phpmig\Adapter\AdapterInterface;

/**
 * @author Samuel Laulhau https://github.com/lalop
 */

class Mongo implements AdapterInterface
{

    /**
     * @var \MongoDb
     */
    protected $connection    = null;

    /**
     * @var string
     */
    protected $tableName     = null;

    /**
     * Constructor
     *
     * @param \MongoDb $connection
     * @param string $tableName
     */
    public function __construct(\MongoDb $connection, $tableName)
    {
        $this->connection    = $connection;
        $this->tableName     = $tableName;
    }

    /**
     * Fetch all
     *
     * @return array
     */
    public function fetchAll()
    {
        $cursor = $this->connection->selectCollection($this->tableName)->find();
        $versions = array();
        foreach($cursor as $version) $versions[] = $version['version'];
        return $versions;
    }

    /**
     * Up
     *
     * @param Migration $migration
     * @return self
     */
    public function up(Migration $migration)
    {
        $document = array('version' => $migration->getVersion());
        $this->connection->selectCollection($this->tableName)->insert($document);