<?php
# CmsEasy Enterprise Content Management System
# Copyright (C) CmsEasy Co.,Ltd (https://www.CmsEasy.cn). All rights reserved.
class dbmysql {

    public $connection_id="";
    public $pconnect=0;
    public $shutdown_queries=array();
    public $queries=array();
    public $query_id="";
    public $query_count=0;
    public $record_row=array();
    public $failed=0;
    public $halt="";
    public $sql='';
    public static $me;

    function __construct() {
        load_custom_admin_lang('cn');   //选默认语言包  cn
        $config=config::get('database');
        if (!isset($this->prefix))
            $this->prefix=isset($config['prefix']) ?$config['prefix'] : '';
        if (config::get('test_data'))
            $this->prefix='test_';
        if (!isset($this->name))
            $this->name=$this->prefix.get_class($this);
        else
            $this->name=$this->prefix.$this->name;
        //$this->connect();
    }


    public static function getInstance($host,$user,$pass,$dbname) {
        if (!self::$me) {
            $class = new dbmysql();
            self::$me = $class;
        }
        self::$me->connect($host,$user,$pass,$dbname);
        return self::$me;
    }

    public function connect($host,$user,$pass,$dbname) {

        static $connection_id;
        if ($connection_id) {
            $this->connection_id = $connection_id;
            return true;
        }
        $db_config = config::get('database');
        if($db_config['type'] == 'mysqli'){

        }else{

        }
        if ($this->pconnect) {
            $this->connection_id = mysql_pconnect($db_config["hostname"],$db_config["user"],$db_config["password"]);
        }
        else {
            $this->connection_id = mysql_connect($db_config["hostname"],$db_config["user"],$db_config["password"]);
        }
        if (!$this->connection_id) {
            var_dump(mysql_error());
            if ($_GET['case'] != 'install' && file_exists(ROOT.'/install/locked'))
                exit(lang_custom_admin('database_connection').lang_custom_admin('failure'));
        }
        $connection_id = $this->connection_id;
        if (!@mysql_select_db($db_config["database"],$this->connection_id)) {
            $this->halt("Can not connect MySQL Database");
        }
        if ($db_config["encoding"]) {
            @mysql_unbuffered_query("SET NAMES '".$db_config["encoding"]."'");
        }
        @mysql_query("SET sql_mode=''");
        return true;
    }

    function query($query_id,$query_type='mysql_query') {
        front::$query[]=$query_id;
        $this->query_id=@$query_type($query_id,$this->connection_id);
        $this->queries[]=$query_id;
        if (!$this->query_id) {
            $this->halt(lang_custom_admin('query').lang_custom_admin('failure').":\n$query_id");
        }
        $this->query_count++;
        return $this->query_id;
    }
    function query_unbuffered($sql="") {
        return $this->query($sql,'mysql_unbuffered_query');
    }
    function fetch_array($sql = "") {
        if ($sql == "")
            $sql=$this->query_id;
        //var_dump($sql);
        $this->record_row=@mysql_fetch_array($sql,MYSQL_ASSOC);
        return $this->record_row;
    }
    function shutdown_query($query_id = "") {
        $this->shutdown_queries[]=$query_id;
    }
    function affected_rows() {
        return @mysql_affected_rows($this->connection_id);
    }
    function num_rows($query_id="") {
        if ($query_id == "")
            $query_id=$this->query_id;
        return @mysql_num_rows($query_id);
    }
    function get_errno() {
        $this->errno=@mysql_errno($this->connection_id);
        return $this->errno;
    }
    function insert_id() {
        return @mysql_insert_id($this->connection_id);
    }
    function query_count() {
        return $this->query_count;
    }
    function free_result($query_id="") {
        if ($query_id == "")
            $query_id=$this->query_id;
        @mysql_free_result($query_id);
    }
    function close_db() {
        if ($this->connection_id){
            //return @mysql_close($this->connection_id);
        }
    }
    function get_table_names() {
        global $db_config;
        $result=mysql_list_tables($db_config["database"]);
        $num_tables=@mysql_numrows($result);
        for ($i=0;$i <$num_tables;$i++) {
            $tables[]=mysql_tablename($result,$i);
        }
        mysql_free_result($result);
        return $tables;
    }
    function halt($the_error="") {
        //return;
        if (!config::get('debug'))
            return;
        $message='sql-error: '.$sql."<br/>\r\n";
        $message=$the_error."<br/>\r\n";
        $message.= $this->get_errno()."<br/>\r\n";
        exit($message);
        @mysql_unbuffered_query($sql);
    }
    function __destruct() {
        $this->shutdown_queries=array();
        $this->close_db();
    }
    function sql_select($tbname,$where="",$limit=0,$fields="*",$order='') {
        $sql="SELECT ".$fields." FROM `".$tbname."` ".($where ?" WHERE ".$where : "")." ORDER BY ".$order.($limit ?" limit ".$limit : "");
        //echo $sql."<br>";
        return $sql;
    }
    function sql_insert($tbname,$row) {
        $sqlfield='';
        $sqlvalue='';
        foreach ($row as $key=>$value) {
            if (in_array($key,explode(',',$this->getcolslist()))) {
                $value=$value;
                $sqlfield .= $key.",";
                $sqlvalue .= "'".$value."',";
            }
        }
        return "INSERT INTO `".$tbname."`(".substr($sqlfield,0,-1).") VALUES (".substr($sqlvalue,0,-1).")";
    }
    function sql_update($tbname,$row,$where) {
        //var_dump($row);
        $sqlud='';
        if (is_string($row))
            $sqlud = $row.' ';
        else
            foreach ($row as $key=>$value) {
                if (in_array($key,explode(',',$this->getcolslist()))) {
                    $value=$value;
                    /*if (preg_match('/^\[(.*)\]$/',$value,$match))
                        $sqlud .= "`$key`"."= '".$match[1]."',";
                    else*/if ($value === "")
                        $sqlud .= "`$key`= NULL, ";
                    else
                        $sqlud .= "`$key`"."= '".$value."',";
                }
            }
        $sqlud=rtrim($sqlud);
        $sqlud=rtrim($sqlud,',');
        $this->condition($where);
        $sql="UPDATE `".$tbname."` SET ".$sqlud." WHERE ".$where;
        //echo $sql;
        return $sql;
    }
    function sql_replace($tbname,$row) {
        $sqlud='';
        if (is_string($row))
            $sqlud=$row.' ';
        else
            foreach ($row as $key=>$value) {
                if (in_array($key,explode(',',$this->getcolslist()))) {
                    $value=$value;
                    $sqlud .= $key."= '".$value."',";
                }
            }
        return "REPLACE INTO `".$tbname."` SET ".substr($sqlud,0,-1);
    }
    function sql_delete($tbname,$where) {
        $this->condition($where);
        return "DELETE FROM `".$tbname."` WHERE ".$where;
    }
    function rec_insert($row) {
        $tbname=$this->name;
        $sql=$this->sql_insert($tbname,$row);
        return $this->query_unbuffered($sql);
    }
    function rec_update($row,$where) {
        $tbname=$this->name;
        $sql=$this->sql_update($tbname,$row,$where);
        //echo $sql."<br>";exit;
        return $this->query_unbuffered($sql);
    }
    function rec_replace($row) {
        $tbname=$this->name;
        $sql=$this->sql_replace($tbname,$row);
        //echo $sql."\n";
        return $this->query_unbuffered($sql);
    }
    function rec_delete($where) {
        $tbname=$this->name;
        $sql=$this->sql_delete($tbname,$where);
        //echo $sql;exit;
        return $this->query_unbuffered($sql);
    }
    function rec_select($where="",$limit=0,$fields="*",$order='') {
        $tbname=$this->name;
        $sql=$this->sql_select($tbname,$where,$limit,$fields,$order);
        //echo $sql."<br>";
        $res=$this->rec_query($sql);
        return $res;
    }
    function rec_select_one($where,$fields="*",$order="id") {
        $tbname=$this->name;
        $sql=$this->sql_select($tbname,$where,1,$fields,$order);
        //echo $sql."<br>";
        return $this->rec_query_one($sql);
    }
    function rec_query($sql) {
        $this->sql=$sql;
        $rs=$this->query($sql);
        $rs_num=$this->num_rows($rs);
        $rows=array();
        for ($i=0;$i <$rs_num;$i++) {
            $rows[]=$this->fetch_array($rs);
        }
        $this->free_result($rs);
        return $rows;
    }
    function rec_query_one($sql) {
        $rs=$this->query($sql);
        $row=$this->fetch_array($rs);
        $this->free_result($rs);
        return $row;
    }
    function rec_count($where="") {
        $tbname=$this->name;
        if (preg_match('/_category$/',$tbname))
            $sql="SELECT count(catid) as rec_sum FROM `".$tbname."` ".($where ?" WHERE ".$where : "");
        else
            $sql="SELECT count(1) as rec_sum FROM `".$tbname."` ".($where ?" WHERE ".$where : "");
        //echo $sql;//exit;
        $row=$this->rec_query_one($sql);
        return $row["rec_sum"];
    }

    function getrows($condition='',$limit=1,$order='1 desc',$cols='*') {
        $this->condition($condition);
        $this->record_count=$this->rec_count($condition);
        $res=$this->rec_select($condition,$limit,'*',$order);
        return $res;
    }
    function getrows1($condition='',$limit=1,$order='1 desc',$cols='*') {
        $this->condition($condition);
        $this->record_count=$this->rec_count($condition);
        return $this->rec_select($condition,$limit,'*',$order,'');
    }
    function getrow($condition,$order='1 desc',$cols='*') {
        $this->condition($condition);
        //var_dump($condition);
        return $this->rec_select_one($condition,'*',$order);
    }
    function condition(&$condition) {
        if (isset($condition) &&is_array($condition)) {
            $_condition=array();
            foreach ($condition as $key=>$value) {
                //$value=str_replace("'","\'",$value);
                if (inject_check($value)) {
                    //echo $condition;
                    event::log('inject',$value);
                    exit('sql inject');
                }
                if (inject_check($key)) {
                    event::log('inject',$key);
                    exit('sql inject');
                }
                $_condition[]="`$key`='$value'";
            }
            $condition=implode(' and ',$_condition);
        }
        else if (is_numeric($condition)) {
            $this->getFields();
            $condition="`$this->primary_key`='$condition'";
        }else if(true === $condition){
            $condition = 'true';
        }else{
            if (inject_check($condition)) {
                event::log('inject',$condition);
                //echo $condition;
                exit('sql inject');
            }
        }

        if (get_class($this) == 'archive') {
            if (!front::get('deletestate')) {
                if ($condition)
                    $condition.=' and (state IS NULL or state<>\'-1\') ';
                else
                    $condition='state IS NULL or state<>\'-1\' ';
            }
            else {
                if ($condition)
                    $condition.=' and state=\'-1\' ';
                else
                    $condition=' state=\'-1\' ';
            }
        }
    }
    function getFields() {
        static $fields;
        static $primary_key;
        if (!isset($fields)) {
            $fields=array();
            $query=$this->query('Describe '.$this->name);
            $_field=array();
            while ($field=$this->fetch_array($query)) {
                preg_match('/([\w\x7f-\xff]+)(\(([\w\x7f-\xff]+)\))?/i',$field['Type'],$result);
                $_field['name']=$field['Field'];
                $_field['type']=$result[1];
                $_field['len']=isset($result[3]) ?$result[3] : 0;
                $_field['primary_key']=$field['Key'] == 'PRI';
                $_field['notnull']=$field['Null'] == 'NO';
                $_field['selecttype']=isset($this->_form[$_field['name']]['selecttype']) ?$this->_form[$_field['name']]['selecttype'] : '';
                $_field['select']=isset($this->_form[$_field['name']]['select']) ?$this->_form[$_field['name']]['select'] : '';
                $_field['tips']=isset($this->_form[$_field['name']]['tips']) ?$this->_form[$_field['name']]['tips'] : '';
                $fields[$field['Field']]=$_field;
                if ($field['Key'] == 'PRI') {
                    $this->primary_key=$field['Field'];
                    $primary_key=$this->primary_key;
                }
            }
        }
        $this->primary_key=$primary_key;
        //var_dump($fields);
        return $fields;
    }
    function getFiledsList() {
        $list='';
        foreach ($this->getFields() as $field) $list.=$field['name'].' ';
        return $list;
    }
    function getcolslist() {
        $list=array();
        foreach ($this->getFields() as $field) $list[]=$field['name'];
        return implode(',',$list);
    }
    function getcols($act='') {
        return implode(',',array_slice(array_keys($this->getFields()),0,2));
    }
    function mycols() {
        $_cols=array_keys($this->getFields());
        $cols='';
        foreach ($_cols as $col) {
            if (preg_match('/my_/',$col))
                $cols.=','.$col;
        }
        return $cols;
    }
    function get_form() {
    }
    final function getname() {
        return $this->name;
    }
    function rec_query_one1($sql) {
        $rs=mysql_query($sql);
        $row=mysql_fetch_array($rs);
        $this->free_result($rs);
        return $row;
    }
    function _rec_query1($sql) {
        $rs=mysql_query($sql);
        $rs_num=mysql_num_rows($rs);
        $rows=array();
        for ($i=0;$i <$rs_num;$i++) {
            $rows[]=mysql_fetch_array($rs);
        }
        return $rows;
    }
    function _rec_select1($tbname,$where="",$limit=0,$fields="*",$order='') {
        $sql=$this->sql_select($tbname,$where,$limit,$fields,$orde);
        return $this->_rec_query1($sql);
    }
    function verison() {
        return mysql_get_server_info($this->connection_id);
    }
}
# This program is an open source system, commercial use, please consciously to purchase commercial license.
# Copyright (C) CmsEasy Co., Ltd. (https://www.CmsEasy.cn). All rights reserved.
