Gelişmiş Yönetici

<?php
defined('PATH_LIB') or die("Restricted Access");

class MySqlDb
{
    //private variables
    private $dbCon; //connection
    private $db_host; //database host
    private $db_user; //database user
    private $db_pswd; //database password
    private $db_name; //database name

private $recSet; //recordset
    private $last_query; //last query
    private $msgEr; // error message
    private $magic_quotes_active; //boolean variable
    private $real_escape_string; //boolean variable
    private $aryErMsg = array(
        '1451' => 'The record is in use somewhere else'
    );

//construtor, needs 4 essential parameters to connect to DB
    function __construct($dbHost, $dbUser, $dbPswd, $dbName)
    {
        $this->setDbHost($dbHost);
        $this->setDbUser($dbUser, $dbPswd);
        $this->setDbName($dbName);

$this->connect();

$this->magic_quotes_active = get_magic_quotes_gpc();
        $this->real_escape_string = function_exists("mysqli_real_escape_string");
    }

//destructor
    function __destruct()
    {
        $this->disconnect();
    }

public function setErAry($aryEr)
    {
        $this->aryErMsg = $aryEr;
    }

public function setDbHost($host)
    {
        $this->db_host = $host;
    }

public function setDbUser($dbUser, $dbPswd)
    {
        $this->db_user = $dbUser;
        $this->db_pswd = $dbPswd;
    }

public function setDbName($dbName)
    {
        $this->db_name = $dbName;
    }

//funciton to close connection
    public function disconnect()
    {
        if (isset($this->dbCon) && $this->dbCon) {
            @mysqli_close($this->dbCon);
            unset($this->dbCon);
        }
    }

//database connection establish
    public function connect()
    {
        //check if any connection already exists, close that connection
        $this->disconnect();

$this->dbCon = mysqli_connect($this->db_host, $this->db_user, $this->db_pswd, $this->db_name);

if (!$this->dbCon) {
            die("Database Connection Failed : " . mysqli_error($this->dbCon));
        }
    }

//function to set Error Msg
    private function setErMsg($myErr, $myErrNo = 0)
    {
        if (isset($this->aryErMsg[$myErrNo])) $myErr = $this->aryErMsg[$myErrNo];

$this->msgEr = "Query Exceution Failed :" . $myErr;
        $this->msgEr .= "<br />Last Query : " . $this->last_query;
    }

//public funtion to send error to user
    public function getErMsg()
    {
        return $this->msgEr;
    }

public function getLastQuery()
    {
        return $this->last_query;
    }

//method to prepare string for various sql operation
    public function prepStr($sqlStr)
    {
        if ($this->real_escape_string) {
            if ($this->magic_quotes_active) {
                $sqlStr = stripslashes($sqlStr);
            }
            $sqlStr = mysqli_real_escape_string($this->dbCon, $sqlStr);
        } else {
            if (!$this->magic_quotes_active) {
                $sqlStr = addslashes($sqlStr);
            }
        }
        return $sqlStr;
    }

//function to execute query
    public function query($sql)
    {
        $this->last_query = $sql;
        $this->recSet = @mysqli_query($this->dbCon, $sql);
        if ($this->recSet) {
            return $this->recSet;
        } else {
            $this->setErMsg(mysqli_error($this->dbCon), mysqli_errno($this->dbCon));
            return NULL;
        }
    }

//method to get id of last inserted record
    public function getLastId()
    {
        return mysqli_insert_id($this->dbCon);
    }

//method to get number of affected rows
    public function getAffectedRows()
    {
        return mysqli_affected_rows($this->dbCon);
    }

//method to get number of affected rows
    public function getRowCount($sql = NULL)
    {
        if (!is_null($sql)) {
            $this->query($sql);
        }
        if ($this->recSet) {
            return mysqli_num_rows($this->recSet);
        } else {
            return NULL;
        }
    }

//function to insert records
    public function insert($sql)
    {

$rs = $this->query($sql);
        if ($rs) {
            return $this->getLastId();
        } else {
            return NULL;
        }
    }

//method to insert record from an associative array
    //array to contain field=>value
    public function insertAry($tblName, $aryVal)
    {
        $aryField = array();
        if (count($aryVal) > 0) {
            $strField = "";
            $strVal = "";
            foreach ($aryVal as $field => $val) {
                $strField .= $field . ",";
                if (is_null($val)) {
                    $strVal .= 'NULL,';
                } else {
                    $strVal .= "'" . $this->prepStr($val) . "',";
                }
            }
            $strField = rtrim($strField, ',');
            $strVal = rtrim($strVal, ',');

$sql = "insert into {$tblName}  ";
            $sql .= "(" . $strField . ") values ";
            $sql .= "(" . $strVal . ")";

return $this->insert($sql);
        } else {
            $this->setErMsg("No fields present in array");
            return NULL;
        }
    }

//method to update record
    public function update($sql)
    {
        $rs = $this->query($sql);
        if ($rs) {
            return $this->getAffectedRows();
        } else {
            return NULL;
        }
    }

//method to update record from an associative array
    //array to contain field=>value
    public function updateAry($tblName, $aryVal, $condition = NULL)
    {
        $strUpVal = '';
        if (count($aryVal) > 0) {
            foreach ($aryVal as $field => $val) {
                if (is_null($val)) {
                    $strUpVal .= "{$field}=NULL,";
                } else {
                    $strUpVal .= "{$field}='" . $this->prepStr($val) . "',";
                }
            }
            $strUpVal = rtrim($strUpVal, ',');
            $sql = "update {$tblName} set {$strUpVal}";
            if (!is_null($condition)) {
                $sql .= " " . $condition;
            }

return $this->update($sql);
        } else {
            $this->setErMsg("No fields present in array");
            return NULL;
        }
    }

//method to delete records
    public function delete($tblName, $condition = NULL)
    {
        $sql = "delete from {$tblName}";
        if (!is_null($condition)) {
            $sql .= " " . $condition;
        }
        $rs = $this->query($sql);
        if ($rs) {
            return $this->getAffectedRows();
        } else {
            return NULL;
        }
    }

//method to fetch all records
    public function getRows($sql)
    {
        $aryResult = array();

$result = $this->query($sql);

if (!is_null($result)) {
            while ($row = mysqli_fetch_array($result)) {
                $aryResult[] = $row;
            }
            return $aryResult;
        } else {
            return NULL;
        }
    }

//method to fetch just a single record
    public function getRow($sql)
    {
        $aryResult = $this->getRows($sql);
        if (is_array($aryResult)) {
            if (count($aryResult) == 0) {
                return array();
            } else {
                return $aryResult[0];
            }
        } else {
            return NULL;
        }
    }

//function to fetch just a single field
    public function getVal($sql, $erVal = NULL)
    {
        $aryResult = $this->getRow($sql);
        if (is_array($aryResult)) {
            return $aryResult[0];
        } else {
            return $erVal;
        }
    }

//function to fetch enum values
    public function getEnumVal($table, $field)
    {
        $sql = "SHOW COLUMNS FROM " . $table . " LIKE '" . $field . "' ";
        $aryEnum = $this->getRow($sql);
        if (is_array($aryEnum) && count($aryEnum) > 0) {
            $regex = "/'(.*?)'/";
            preg_match_all($regex, $aryEnum['Type'], $enum_array);
            return $enum_array[1];
        } else {
            return NULL;
        }
    }

public function getStatusImg($status)
    {
        $aryImg = array(
            '0' => "status_inactive.png",
            '1' => "status_active.png"
        );
        return '<img src="' . URL_ADMIN_IMG . $aryImg[$status] . '" title="' . getStatusStr($status) . '" />';
    }

public function login($table, $fields, $values)
    {
        $str = '';
        $temp_var = explode("~!", $fields);
        $temp_var1 = explode("~!", $values);
        foreach ($temp_var as $key => $value) {
            $str .= $value . " ='" . $temp_var1[$key] . "' and ";
        }

//$sql="select ".substr($str,0,-2)." from  $table where $withfield=$where and ";
        $sql = "select * from  $table where " . substr($str, 0, -4);

$query = mysqli_query($this->dbCon, $sql) or die(mysqli_error($this->dbCon));
        return $query;

}

Adı	Tipi	Boyut	İşlemler
📁 .. (Üst Dizin)
📄 class.database.php	Dosya	9.06 KB	Düzenle	Sil
📄 function.php	Dosya	31.72 KB	Düzenle	Sil
📄 functions.php	Dosya	33.55 KB	Düzenle	Sil
📄 validations.php	Dosya	2.48 KB	Düzenle	Sil

Aktif Dizin: /home/dltain/public_html/Backup/library

Dosya Düzenle: class.database.php

Yeni Dosya Yükle (Mevcut Dizine)

Sorun Giderme (Shell Erişimi)