vendor/davedevelopment/phpmig/src/Phpmig/Adapter/PDO/SqlPgsql.php

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

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

<?php

namespace Phpmig\Adapter\PDO;

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

/**
 * Simple PDO adapter to work with Postgres SQL database in particular.
 * @author Theodson https://github.com/theodson
 */
class SqlPgsql extends Sql
{
    private $quote = "\"";
    private $schemaName = "public";

    /**
     * Constructor
     *
     * @param \PDO $connection
     * @param string $tableName
     */
    public function __construct(\PDO $connection, $tableName, $schemaName = 'public')
    {
        parent::__construct($connection, $tableName);
        $driver = $this->connection->getAttribute(PDO::ATTR_DRIVER_NAME);
        $this->quote = in_array($driver, array('mysql', 'pgsql')) ? '"' : '`';
        $this->schemaName = $schemaName;
    }

    private function quotedTableName()
    {
        $sql = "{$this->quote}{$this->schemaName}{$this->quote}.{$this->quote}{$this->tableName}{$this->quote}";
        return $sql;
    }

    /**
     * Fetch all
     *
     * @return array
     */
    public function fetchAll()
    {
        $sql = "SELECT {$this->quote}version{$this->quote} FROM {$this->quotedTableName()} ORDER BY {$this->quote}version{$this->quote} ASC";
        return $this->connection->query($sql, PDO::FETCH_COLUMN, 0)->fetchAll();
    }

    /**
     * Up
     *
     * @param Migration $migration
     * @return self
     */
    public function up(Migration $migration)
    {
        $sql = "INSERT into {$this->quotedTableName()} (version) VALUES (:version);";
        $this->connection->prepare($sql)
            ->execute(array(':version' => $migration->getVersion()));
        return $this;