minerva-sistemas / silk-orm

src/Silk/Database/TableGateway.php

<?php

namespace Silk\Database;

use PhpDocReader\Reader;
use Silk\Exceptions\NoTableFoundException;
use Zend\Db\TableGateway\AbstractTableGateway;
use Zend\Db\TableGateway\Feature\GlobalAdapterFeature;
use Silk\Database\AdapterPool;

/**
 * Class TableGateway
 * @author  Lucas A. de Araújo <lucas@minervasistemas.com.br>
 * @package Silk\Database
 */
class TableGateway extends AbstractTableGateway
{
    private $config;

    public function __construct($object)
    {
        $this->config = Reader::getConfig($object);

        if (!array_key_exists('table', $this->config))
            throw new NoTableFoundException();

        $this->table = $this->config['table'];
       
        if(!isset($this->config['adapter']))
            $this->config['adapter'] = 'Default';
        
        $adapterPool = new AdapterPool();
        $this->adapter = $adapterPool->get($this->config['adapter']);

        $this->updateContext();
    }

    protected function updateContext()
    {
        $platform = $this->adapter->getPlatform()->getName();
        
        if(isset($this->config['schema']) && $platform == 'MySQL'){

This code seems to be duplicated across your project.

            $sql = 'USE ' . $this->config['schema'] . ';';
            $this->adapter->getDriver()->getConnection()->execute($sql);
        }
        
        if(isset($this->config['schema']) && $platform == 'PostgreSQL'){

This code seems to be duplicated across your project.

            $sql = 'SET SCHEMA \'' . $this->config['schema'] . '\';';
            $this->adapter->getDriver()->getConnection()->execute($sql);
        }
    }
}