Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- include(class_dbmanager.php)
- $this->DBMANAGER = new Class_DbManager();
- $Query['DatabaseName'] = "SELECT user FROM table_user WHERE unsername='" . $username . "';";
- $BDResult = $this->DBMANAGER->GetData($Query);
- $Query['DatabaseName'][] = "INSERT INTO Tbl_Sys_Usuarios(IdTUser, Username, Password, Email) VALUES ('$IdTUser', '$Username', '$Password', '$Email');";
- $BDResult = $this->DBMANAGER->InsertData($Query);
- <?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>';
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement