urfat-orm/src/ORM/DBInstance.php

<?php

namespace ORM;

class DBInstance {

    private static function addPrefix($sql, $instance = 'default'){
        $con = Connections::getConnection($instance);
      	$sql =  preg_replace('/{(.*)}/', "$con->prefix$1", $sql);
      	$sql =  preg_replace( "/\r|\n/", "", $sql );
        return  $sql;
    }
    
    public static function execute($sql, $data = null, $instance = 'default') {
        $sql = self::addPrefix($sql, $instance);
        if ($data) {
            self::queryPrepare($sql, $data, $instance);
        } else {
            $con = Connections::getConnection($instance);
            $con->exec($sql);
        }
    }

    public static function lastInsert($instance = 'default') {
        $con = Connections::getConnection($instance);
        return $con->lastInsertId();
    }

    public static function query($sql, $data = null, $instance = 'default') {
        $sql = self::addPrefix($sql, $instance);
        if ($data) {
            return self::queryPrepare($sql, $data, $instance);
        } else {
            $con = Connections::getConnection($instance);
            return $con->query($sql, \PDO::FETCH_OBJ);
        }
    }

    public static function queryOne($sql, $data = null, $instance = 'default') {
        $sql = self::addPrefix($sql, $instance);
        if ($data) {
            return self::queryPrepare($sql, $data, $instance);
        } else {
            $con = Connections::getConnection($instance);
            return $con->query($sql, \PDO::FETCH_OBJ)->fetch();
        }
    }

    public static function queryPrepare($sql, $data = Array(), $instance = 'default') {
        $sql = self::addPrefix($sql, $instance);
        $con = Connections::getConnection($instance);
        $statement = $con->prepare($sql);
        $statement->execute($data);
        return $statement->fetchAll(\PDO::FETCH_OBJ);
    }

}