3

Preciso fazer uma consulta usando 2 bancos diferentes e simultaneamente. Um é mysql e outro firebird. Já está funcionando separado, gostaria de fazer a conexão sem precisar fechar um para abrir o outro.

Exemplo

$sql_bd1 = connection::selectMysql('SELECT * FROM tabela_mysql');
$sql_bd2 = connection::selectIbase('SELECT * FROM tabela_firebird');

Classe connection

<?php

class connection {

    public static $conn;

    public static function open($name) {
        if (file_exists("config/{$name}.ini")) {
            $db = parse_ini_file("config/{$name}.ini");
        } else {
            throw new exception("Arquivo '$name' nao encontrado");
        }

        $user = isset($db['user']) ? $db['user'] : NULL;
        $pass = isset($db['pass']) ? $db['pass'] : NULL;
        $name = isset($db['name']) ? $db['name'] : NULL;
        $host = isset($db['host']) ? $db['host'] : NULL;
        $type = isset($db['type']) ? $db['type'] : NULL;
        $port = isset($db['port']) ? $db['port'] : NULL;


        switch ($type) {
            case 'pgsql':
                $port = $port ? $port : '5432';
                $conn = new PDO("pgsql:dbname={$name}; user={$user}; password={$pass};host=$host;port={$port};");
                break;
            case 'mysql':
                $port = $port ? $port : '3306';
                $conn = new PDO("mysql:host={$host};port={$port};dbname={$name}", $user, $pass);
                break;
            case 'sqlite':
                $conn = new PDO("sqlite:{$name}");
                break;
            case 'ibase':
                $conn = new PDO("firebird:dbname={$name}", $user, $pass);
                break;
            case 'oci8':
                $conn = new PDO("oci:dbname={$name}", $user, $pass);
                break;
            case 'mssql':
                $conn = new PDO("mssql:host={$host},1433;dbname={$name}", $user, $pass);
                break;
        }

        $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

        self::$conn = $conn;
    }

    public static function select($sql) {
        return self::$conn->query($sql);
    }

    public static function exec($sql, $ret_id = false) {
        $retorno = self::$conn->exec($sql);
        if ($ret_id)
            $retorno = self::$conn->lastInsertId();
        return $retorno;
    }

    public static function close() {
        self::$conn = null;
    }

}

1 Resposta 1

3

Sua class esta quase pronta para isso, basta um pequeno ajuste:

<?php

class connection {

    public static $conn;
    private static $last; // <--- parametro novo para controle da ultima conexão criada

    public static function open($basename) {
        if (file_exists("config/{$basename}.ini")) {
            $db = parse_ini_file("config/{$basename}.ini");
        } else {
            throw new exception("Arquivo '$basename' nao encontrado");
        }

        $user = isset($db['user']) ? $db['user'] : NULL;
        $pass = isset($db['pass']) ? $db['pass'] : NULL;
        $name = isset($db['name']) ? $db['name'] : NULL;
        $host = isset($db['host']) ? $db['host'] : NULL;
        $type = isset($db['type']) ? $db['type'] : NULL;
        $port = isset($db['port']) ? $db['port'] : NULL;


        switch ($type) {
            case 'pgsql':
                $port = $port ? $port : '5432';
                $conn = new PDO("pgsql:dbname={$name}; user={$user}; password={$pass};host=$host;port={$port};");
                break;
            case 'mysql':
                $port = $port ? $port : '3306';
                $conn = new PDO("mysql:host={$host};port={$port};dbname={$name}", $user, $pass);
                break;
            case 'sqlite':
                $conn = new PDO("sqlite:{$name}");
                break;
            case 'ibase':
                $conn = new PDO("firebird:dbname={$name}", $user, $pass);
                break;
            case 'oci8':
                $conn = new PDO("oci:dbname={$name}", $user, $pass);
                break;
            case 'mssql':
                $conn = new PDO("mssql:host={$host},1433;dbname={$name}", $user, $pass);
                break;
        }

        $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

                   // |-----  torna $conn um array de conexões
        self::$conn[$basename] = $conn;
        self::$last = $basename;
    }

                                        // |-- parametro para recuperar a conexao desejada
    public static function select($sql, $base = null) {

            // |---- Se null retoma a ultima conexao criada
        if(!$base) $base = self::$last;

        return self::$conn[$base]->query($sql);
    }

    public static function exec($sql, $ret_id = false, $base = null) {

        if(!$base) $base = self::$last;

        $retorno = self::$conn[$base]->exec($sql);
        if ($ret_id)
            $retorno = self::$conn[$base]->lastInsertId();
        return $retorno;
    }

    public static function close($base = null) {

        if(!$base) $base = self::$last;

        self::$conn[$base] = null;
    }
}

Para realizar a troca de conexões basta adicionar o parâmetro da conexão :

connection::select('SELECT * FROM tabela_mysql', 'mysql'); connection::select('SELECT * FROM tabela_firebird', 'oci8');

5
  • Opa blz, deu esse erro Notice: Undefined index: ibase in /var/www/site/controller/connection.class.php on line 61 Commented 25/04/2017 às 18:01
  • @EduardoSantos eu não seu qual é a linha 61 para você, mas você iniciou das duas conexões? tanto do mysql como ibase? Commented 25/04/2017 às 19:01
  • Sim, a linha é que tem isso return self::$conn[$base]->query($sql); Commented 25/04/2017 às 19:11
  • @EduardoSantos Editado, a variavel $name foi sobrescrita com o conteúdo no arquivo, não havia notado isso. Commented 25/04/2017 às 19:18
  • Agora funcionou. Obrigado amigo. Commented 25/04/2017 às 20:05

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .