Untitled

<?php
class Class_DbManager {
    //for select
    //$Query is array with database index and query string
    //$Conf is secundary conection data
    public function GetData($Query, $Conf = '') {
        try {
            $DB_R   = [];
            $DB     = [];
            $val    = [];
            $prefix = '';
            $count  = 0;
            if (USEPREFIX == True) {
                $prefix = DB_PRE; //prefix DB
            }
            reset($Query);
            $DB_2USE = key($Query);
            //Conecction. i use defined const...
            $conn    = new PDO("mysql:host=" . DB_HOST . ";dbname=" . $prefix . "" . DBSYS . "", DB_USER, DB_PASS);
            //secundary Connection
            if (isset($Conf['CONF']['ChangeServ'])) {
                if ($Conf['CONF']['ChangeServ'] == true) {
                    $conn = new PDO("mysql:host=" . $Conf['CONF']['DB_HOST'] . ";dbname=" . $Conf['CONF']['PREFIX2USE'] . "" . $Conf['CONF']['DB2USE'] . "", $Query['CONF']['DB_USER'], $Query['CONF']['DB_PASS']);
                }
            }
            $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $conn->exec("set names utf8");
            $conn->exec('USE ' . $DB_2USE);
            //execution query.
            $DB_R['r'] = $conn->query($Query[$DB_2USE], PDO::FETCH_ASSOC);
            $count     = $DB_R['r']->rowCount();
            $DB_R['c'] = $count;
            if ($count == 0) {
                $DB_R['r'] = null;
            } elseif ($count == 1) {
                $DB_R['r'] = $DB_R['r']->fetch(); //Fetch result i f result is 1 if not resturn the result unfetch
            }
            $conn = null;
            return $DB_R;
        } catch (PDOException $e) {
            echo '<pre>';
            echo var_dump($e);
            echo '<pre>';
        }
    }
    //for Update and Insert
    //$Query is array with database index and query string
    //$Conf is secundary conection data
    public function UpdateData($Query, $Conf = '') {
        try {
            $DB_R   = [];
            $DB     = [];
            $val    = [];
            $prefix = '';
            $cT     = 0;
            if (USEPREFIX == True) {
                $prefix = DB_PRE;
            }
            $conn = new PDO("mysql:host=" . DB_HOST . ";dbname=" . $prefix . "" . DBSYS . "", DB_USER, DB_PASS);
            if (isset($Conf['CONF']['ChangeServ'])) {
                if ($Conf['CONF']['ChangeServ'] == true) {
                    $conn = new PDO("mysql:host=" . $Conf['CONF']['DB_HOST'] . ";dbname=" . $Conf['CONF']['PREFIX2USE'] . "" . $Conf['CONF']['DB2USE'] . "", $Query['CONF']['DB_USER'], $Query['CONF']['DB_PASS']);
                }
            }
            $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    $conn->exec($QString);
                    $cT++;
                }
            }
            $conn->commit();
            $conn      = null;
            $DB_R['r'] = true;
            return $DB_R;
        } catch (PDOException $e) {
            #rollback al autoincrement
            $conn->rollback();
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    preg_match('/bintobs*(w+)/i', $QString, $tables);
                    $conn->exec("ALTER TABLE " . $tables[1] . " AUTO_INCREMENT=1;");
                }
            }
            $conn->commit();
            echo '<pre>';
            echo var_dump($e);
            echo '<pre>';
        }
    }
    //for Insert
    //$Query is array with database index and query string
    //$Conf is secundary conection data
    public function InsertData($Query, $Conf = '') {
        try {
            $DB_R   = [];
            $DB     = [];
            $val    = [];
            $prefix = '';
            $cT     = 0;
            if (USEPREFIX == True) {
                $prefix = DB_PRE;
            }
            $conn = new PDO("mysql:host=" . DB_HOST . ";dbname=" . $prefix . "" . DBSYS . "", DB_USER, DB_PASS);
            if (isset($Conf['CONF']['ChangeServ'])) {
                if ($Conf['CONF']['ChangeServ'] == true) {
                    $conn = new PDO("mysql:host=" . $Conf['CONF']['DB_HOST'] . ";dbname=" . $Conf['CONF']['PREFIX2USE'] . "" . $Conf['CONF']['DB2USE'] . "", $Query['CONF']['DB_USER'], $Query['CONF']['DB_PASS']);
                }
            }
            $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    $conn->exec($QString);
                    $cT++;
                }
            }
            $conn->commit();
            $conn      = null;
            $DB_R['r'] = true;
            return $DB_R;
        } catch (PDOException $e) {
            #rollback al autoincrement
            $conn->rollback();
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    preg_match('/bintobs*(w+)/i', $QString, $tables);
                    $conn->exec("ALTER TABLE " . $tables[1] . " AUTO_INCREMENT=1;");
                }
            }
            $conn->commit();
            echo '<pre>';
            echo var_dump($e);
            echo '<pre>';
        }
    }
    //for delete
    //$Query is array with database index and query string
    //$Conf is secundary conection data
    public function DeleteData($Query, $Conf = '') {
        try {
            $DB_R   = [];
            $DB     = [];
            $val    = [];
            $prefix = '';
            $cT     = 0;
            if (USEPREFIX == True) {
                $prefix = DB_PRE;
            }
            $conn = new PDO("mysql:host=" . DB_HOST . ";dbname=" . $prefix . "" . DBSYS . "", DB_USER, DB_PASS);
            if (isset($Conf['CONF']['ChangeServ'])) {
                if ($Conf['CONF']['ChangeServ'] == true) {
                    $conn = new PDO("mysql:host=" . $Conf['CONF']['DB_HOST'] . ";dbname=" . $Conf['CONF']['PREFIX2USE'] . "" . $Conf['CONF']['DB2USE'] . "", $Query['CONF']['DB_USER'], $Query['CONF']['DB_PASS']);
                }
            }
            $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    $conn->exec($QString);
                    $cT++;
                }
            }
            $conn->commit();
            $conn      = null;
            $DB_R['r'] = true;
            return $DB_R;
        } catch (PDOException $e) {
            #rollback al autoincrement
            $conn->rollback();
            $conn->beginTransaction();
            $conn->exec("set names utf8");
            foreach ($Query as $DB_2USE => $QArr) {
                $conn->exec('USE ' . $DB_2USE);
                foreach ($QArr as $key => $QString) {
                    preg_match('/bintobs*(w+)/i', $QString, $tables);
                    $conn->exec("ALTER TABLE " . $tables[1] . " AUTO_INCREMENT=1;");
                }
            }
            $conn->commit();
            echo '<pre>';
            echo var_dump($e);
            echo '<pre>';
        }
    }
}