qii/src/Driver/Base.php

<?php

namespace Qii\Driver;

class Base
{
    const VERSION = '1.2';
    public $cache;
    public $language;
    protected $_query = array(
        "INSERT" => "INSERT INTO %s(%s) VALUES('%s')",
        "REPLACE" => "REPLACE %s (%s) VALUES('%s')",
        "SELECT" => "SELECT %s FROM %s",
        "LEFT_JOIN" => " LEFT JOIN %s ON %s",
        "RIGHT_JOIN" => " RIGHT JOIN %s ON %s",
        "UPDATE" => "UPDATE %s SET ",
        "DELETE" => "DELETE FROM %s %s",
        "WHERE" => " WHERE %s",
        "LIKE" => " `%s` LIKE '%s'",
        "ORDER" => " ORDER BY %s %s",
        "GROUP" => " GROUP BY %s",
        "LIMIT" => " LIMIT %d, %d"
    );
    private $query;
    private $setArray = array();
    public $modelSQL = "";
    protected $fields;
    protected $groupBy;
    protected $limit;
    protected $orderBy;
    public $load;
    public $where = null;
    public $join = null;
    /**
     * @var string $response Response对象
     */
    public $response;

    //方法对应的别名
    protected $_modelAlias = array('selectRows' => 'selectAll', 'select' => 'selectRow', 'getOne' => 'selectOne', 'getRow' => 'selectRow', 'getAll' => 'selectAll', 'remove' => 'deleteRows');

    public function __construct()
    {
        $this->language = \Qii\Autoloader\Psr4::getInstance()->loadClass('Qii\Language\Loader');
        $this->load = \Qii\Autoloader\Psr4::getInstance()->loadClass('\Qii\Autoloader\Loader');
        $this->response = new \Qii\Driver\Response();
    }

    /**
     * 获取数据库中所有的数据表
     * @return array
     */
    public function getAllDatabases()
    {
        $sql = "SHOW DATABASES";
        $rs = $this->setQuery($sql);

        $database = array();
        while ($row = $rs->fetch()) {
            $database[] = $row['Database'];
        }
        return $database;
    }

    /**
     * 数据库中是否包含指定库
     * @param string $database 数据库名
     * @return bool
     */
    public function hasDatabase($database)
    {
        if (!$database) return false;
        $sql = "SHOW DATABASES LIKE '" . $database . "'";
        $rs = $this->setQuery($sql);
        while ($row = $rs->fetch()) {
            $val = array_values($row);
            if (in_array($database, $val)) {
                return true;
            }
        }
        return false;
    }

    /**
     * 获取当前数据库中所有的表
     * @param null|string $database 数据库
     * @return array
     */
    public function getAllTables($database = null)
    {
        if ($database) {
            $this->setQuery('USE ' . $database);
        }
        $sql = "SHOW TABLES";
        $rs = $this->setQuery($sql);
        $tables = array();
        while ($row = $rs->fetch()) {
            if (is_array($row)) {
                foreach ($row AS $val) {
                    $tables[] = $val;
                }
            }
        }
        return $tables;
    }

    /**
     * 获取指定数据表的所有字段
     * @param string $table 表名
     * @param string $database 数据库名
     * @param string $autoIncr 自动增长的序号
     * @return array
     */
    public function getTableInfo($table, $database = null, $autoIncr = null)
    {
        if (!$database) $database = $this->currentDB;
        $sql = "SELECT * from information_schema.COLUMNS where table_name = '" . $table . "' and table_schema = '" . $database . "'";
        $data = ['fields' => [],
            'rules' => [
                'pri' => [], 'required' => []
            ]
        ];

        $rs = $this->setQuery($sql);
        while ($row = $rs->fetch()) {
            $data['fields'][] = $row['COLUMN_NAME'];
            if ($row['EXTRA']) {
                $data['rules']['extra'][$row['EXTRA']][] = $row['COLUMN_NAME'];
            }
            if ($row['COLUMN_KEY'] == 'PRI') {
                $data['rules']['pri'][] = $row['COLUMN_NAME'];
                $data['rules']['required'][] = $row['COLUMN_NAME'];
            }
            if ($row['IS_NULLABLE'] == 'NO') {
                $data['rules']['required'][] = $row['COLUMN_NAME'];
            }
            if (in_array($row['DATA_TYPE'], ['varchar', 'char'])) {
                $data['rules']['maxlength'][$row['COLUMN_NAME']] = $row['CHARACTER_MAXIMUM_LENGTH'];
            }
            if (in_array($row['DATA_TYPE'], ['mediumtext', 'TINYTEXT', 'text', 'longtext'])) {
                $data['rules']['text'][] = $row['COLUMN_NAME'];
            }
            if (in_array($row['DATA_TYPE'], ['bigint', 'int', 'smallint', 'tinyint', 'integer'])) {
                preg_match('/[\d]{1,}/', $row['COLUMN_TYPE'], $matches);
                $data['rules']['int'][$row['COLUMN_NAME']] = $matches[0];
                $data['rules']['number'][] = $row['COLUMN_NAME'];
            }
            if (in_array($row['DATA_TYPE'], ['float', 'double', 'decimal'])) {
                $data['rules']['float'][$row['COLUMN_NAME']] = $this->getValueFromBrackets($row['COLUMN_TYPE']);
            }
            if (in_array($row['DATA_TYPE'], ['timestamp', 'datatime'])) {
                $data['rules']['timestamp'][] = $row['COLUMN_NAME'];
            }
            if (in_array($row['DATA_TYPE'], ['enum', 'set'])) {
                $data['rules']['sets'][$row['COLUMN_NAME']] = $this->getValueFromBrackets($row['COLUMN_TYPE']);
            }
            if (isset($row['COLUMN_DEFAULT'])) {
                $data['rules']['default'][$row['COLUMN_NAME']] = $row['COLUMN_DEFAULT'];
            }
        }
        $data['sql'] = $this->getTableSQL($table, $database, $autoIncr);
        return $data;
    }

    /**
     * 从括号中获取指定的值
     * @param string $str 需要获取的内容
     * @return array
     */
    public function getValueFromBrackets($str)
    {
        preg_match("/(?:\()(.*)(?:\))/i", $str, $matches);
        $str = $matches[1];
        $a = explode(",", $str);
        for ($i = 0; $i < count($a); $i++) {
            $this->removeQuote($a[$i]);//从字符串中去除单引号
        }
        return $a;
    }

    /**
     * 去除双引号
     * @param string $str 去除双引号
     */
    public function removeQuote(&$str)
    {
        if (preg_match("/^\'/", $str)) {
            $str = substr($str, 1, strlen($str) - 1);
        }
        if (preg_match("/\'$/", $str)) {
            $str = substr($str, 0, strlen($str) - 1);
        }
        return $str;
    }

    /**
     * 查询数据库中是否有指定的表
     * @param string $tableName 表名
     * @param null|string $database 数据库
     * @return bool
     */
    public function hasTable($tableName, $database = null)
    {
        if ($database) {
            $this->setQuery('USE ' . $database);
        }
        $sql = "SHOW TABLES LIKE '" . $tableName . "'";
        $rs = $this->setQuery($sql);

        $tables = array();
        while ($row = $this->fetch($rs)) {
            if (is_array($row)) {
                foreach ($row AS $val) {
                    if ($val == $tableName) return true;
                }
            }
        }
        return false;
    }

    /**
     * 获取创建表的SQL语句
     * @param string $tableName 表名
     * @param null|string $database 数据库
     * @param int|null $autoIncr 自增长的值，null的话就不使用
     * @return string
     */
    public function getTableSQL($tableName, $database = null, $autoIncr = null)
    {
        if ($database) {
            $this->setQuery('USE ' . $database);
        }
        $row = $this->getRow("SHOW CREATE TABLE `" . $tableName . "`");
        if (!$row) {
            throw new \Exception('数据表不存在', __LINE__);
        }
        $sql = $row['Create Table'];
        if ($autoIncr === null) {
            return $sql;
        }
        return preg_replace("/AUTO_INCREMENT=[\d]{1,}/", "AUTO_INCREMENT=" . intval($autoIncr), $sql);
    }

    /**
     * 通过数据表名称获取规则
     * @param string $table 表名
     * @param string $database 数据库名
     */
    public function buildRulesForTable($table, $database = null)
    {
        if (!$database) $database = $this->currentDB;
        $tableInfo = $this->getTableInfo($table, $database);
        $rules = new \Qii\Base\Rules();
        $rules->addFields($tableInfo['fields']);
        if ($tableInfo['rules']['required']) {
            $rules->addForceValidKey($tableInfo['rules']['required']);
        }
        if (isset($tableInfo['rules']['number'])) {
            foreach ($tableInfo['rules']['number'] as $key => $value) {
                $rules->addRules($value, 'number', true, $value . '字段必须是数字');
            }
        }
        if (isset($tableInfo['rules']['maxlength'])) {
            foreach ($tableInfo['rules']['maxlength'] as $key => $value) {
                $rules->addRules($key, 'maxlength', $value, $key . '字段内容长度不能大于' . $value . '个字符');
            }
        }
        if (isset($tableInfo['rules']['timestamp'])) {
            foreach ($tableInfo['rules']['timestamp'] as $key => $value) {
                $rules->addRules($value, 'datetime', true, $value . '字段必须为日期格式');
            }
        }
        return $rules;
    }

    final public function getAlias($alias)
    {
        return isset($this->_modelAlias[$alias]) ? $this->_modelAlias[$alias] : null;
    }

    /**
     * 设置Cache
     *
     * @param String $cache
     * @param Array $policy
     */
    final public function setCache($cache, $policy)
    {
        \Qii\Autoloader\Import::requires(Qii_DIR . DS . 'Qii' . DS . 'Cache.php');
        $this->cache = \Qii\Autoloader\Psr4::loadClass('\Qii\Cache', $cache)->initialization($policy);//载入cache类文件
    }

    /**
     * 缓存内容
     *
     * @param String $id
     * @param Array $value
     * @return Bool
     */
    final public function cache($id, $value)
    {
        return $this->cache->set($id, $value);
    }

    /**
     * 获取缓存的类
     */
    final public function getCache()
    {
        return $this->cache;
    }

    /**
     * 获取缓存内容
     *
     * @param String $id
     * @return Array
     */
    final public function getCacheData($id)
    {
        return $this->cache->get($id);
    }

    /**
     * 获取表的名称
     * @param String $table
     * @return String
     */
    public function getTable($table)
    {
        list($database, $tableName) = array_pad(explode('.', $table), 2, '');

        if ($tableName) {
            $tableName = stristr($tableName, '`') ? $tableName : '`'. $tableName .'`';
            return "`{$database}`.`{$tableName}`";
        }
        $table = stristr($table, '`') ? $table : '`'. $table .'`';
        return $table;
    }

    public function setLanguage()
    {
        $this->language = \Qii\Autoloader\Psr4::loadClass('Qii\Language\Loader');
    }

    /**
     *
     * Insert Object
     * @param String $table
     * @param Array|Object $dataArray
     */
    final function insertObject($table, $dataArray)
    {
        if (empty($table)) {
            return -1;
        }
        if (sizeof($dataArray) > 0 || (is_object($dataArray) && get_object_vars($dataArray)) > 0) {
            $keys = array();
            $values = array();
            foreach ($dataArray AS $key => $value) {
                $keys[] = $key;
                if (is_array($value)) {
                    throw new \Qii\Exceptions\InvalidFormat(_i('Invalid %s format', $key), __LINE__);
                }
                $values[] = $this->setQuote($value);
            }

            $this->modelSQL = $sql = "INSERT INTO " . $this->getTable($table) . "(`" . join("`, `", $keys) . "`) VALUES('" . join("', '", $values) . "')";
            $this->setQuery($sql);
            $this->cleanData();
            $this->setError();
            return $this->lastInsertId();
        }
        return -2;
    }

    /**
     * 左连表
     *
     * @param string $table 表名
     * @param string $on on条件
     * @return $this
     */
    final function leftJoinObject($table, $on)
    {
        if(empty($table) || empty($on)) return $this;

        $this->join .= sprintf($this->_query['LEFT_JOIN'], $table, $on);
        return $this;
    }

    /**
     * 右连表
     *
     * @param string $table 表名
     * @param string $on on条件
     * @return $this
     */
    final function rightJoinObject($table, $on)
    {
        if(empty($table) || empty($on)) return $this;

        $this->join .= sprintf($this->_query['RIGHT_JOIN'], $table, $on);
        return $this;
    }

    /**
     *
     * Replace Object
     * @param String $table
     * @param Array|Object $dataArray
     */
    final function replaceObject($table, $dataArray)
    {
        if (empty($table)) {
            return -1;
        }
        if (sizeof($dataArray) > 0 || get_object_vars($dataArray) > 0) {
            $keys = array();
            $values = array();
            foreach ($dataArray AS $key => $value) {
                $keys[] = $key;
                if (is_array($value)) {
                    throw new \Qii\Exceptions\InvalidFormat(_i('Invalid %s format', $key), __LINE__);
                }
                $values[] = $this->setQuote($value);
            }
            $this->modelSQL = $sql = "REPLACE INTO " . $this->getTable($table) . "(`" . join("`, `", $keys) . "`) VALUES('" . join("', '", $values) . "')";
            $rs = $this->setQuery($sql);
            $this->cleanData();
            $this->setError();
            return $this->AffectedRows($rs);
        }
        return -2;
    }

    /**
     *
     * Update data
     * @param String $table
     * @param Array|Objct $dataArray
     * @param Array $keys
     */
    final function updateObject($table, $dataArray, $keys = array())
    {
        if (empty($table) || !is_array($keys)) {
            return -1;
        }
        if (sizeof($dataArray) > 0 || get_object_vars($dataArray) > 0) {
            $values = array();
            $where = array();
            foreach ($dataArray AS $key => $value) {
                if (is_array($value)) {
                    throw new \Qii\Exceptions\InvalidFormat(_i('Invalid %s format', $key), __LINE__);
                }
                $value = $this->setQuote($value);
                if (in_array($key, $keys)) {
                    $where[] = "`{$key}` = '" . $value . "'";
                } else {
                    $values[] = "`{$key}` = '" . $value . "'";
                }
            }
            //$keys为key => value的方式，就直接用keys
            if (empty($where) && count($keys) > 0) {
                foreach ($keys as $key => $value) {
                    $value = $this->setQuote($value);
                    $where[] = "`{$key}` = '" . $value . "'";
                }
            }
            $whereSQL = $this->where;
            if (sizeof($where) > 0) {
                $whereSQL = $this->where ? $this->where . " AND (" . join(" AND ", $where) . ")" : " WHERE " . join(" AND ", $where);
            }
            $this->modelSQL = $sql = "UPDATE " . $this->getTable($table) . " SET " . join(", ", $values) . $whereSQL;
            $rs = $this->setQuery($sql);
            $this->cleanData();
            $this->setError();
            return $this->AffectedRows($rs);
        }
        return 0;
    }

    /**
     *
     * 删除数据
     * @param String $table
     * @param Array $keys
     */
    final function deleteObject($table, $keys = array())
    {
        if (empty($table)) {
            return -1;
        }
        $where = array();
        if (sizeof($keys) > 0 || (is_a($keys, 'stdclass') && get_object_vars($keys))) {
            foreach ($keys AS $k => $v) {
                $where[] = "`{$k}` = '" . $this->setQuote($v) . "'";
            }
        }
        $whereSQL = $this->where;
        if (sizeof($where) > 0) {
            $whereSQL = $this->where ? $this->where . " AND (" . join(" AND ", $where) . ")" : " WHERE " . join(" AND ", $where);
        }
        $this->modelSQL = $sql = "DELETE FROM " . $this->getTable($table) . " " . $whereSQL;
        $rs = $this->query($sql);
        $this->cleanData();
        $this->setError();
        return $this->AffectedRows($rs);
    }

    /**
     * 需要清除的数据
     *
     * @return array
     */
    final function cleanOptions()
    {
        return array('fields', 'where', 'groupBy', 'orderBy', 'limit', 'setArray', 'join');
    }

    /**
     * 清除数据
     *
     */
    final function cleanData()
    {
        $array = $this->cleanOptions();
        foreach ($array AS $k) {
            if (is_array($this->$k)) {
                $this->$k = array();
            } else {
                $this->$k = null;
            }
        }
    }

    /**
     *
     * 查询的字段
     * @param String $fileds
     */
    final function fields($fileds = "*")
    {
        $this->fields = null;
        if (empty($fileds)) $fileds = "*";
        if (is_array($fileds)) $fileds = join(',', $fileds);
        $this->fields = $fileds;
        return $this;
    }

    /**
     *
     * GROUP BY方法
     * @param String $fields
     */
    final function groupBy($fields)
    {
        $this->groupBy = null;
        if (!empty($fields)) {
            $fileds = is_array($fields) ? join(', ', $fields) : $fields;
            $this->groupBy = sprintf($this->_query['GROUP'], $fields);
        }
        return $this;
    }

    /**
     *
     * 插入数据用
     * @param Array $array
     */
    final function dataArray($array)
    {
        $this->fileds = null;
        if (is_array($array)) {
            $tmpArray = array();
            foreach ($array AS $k => $v) {
                $tmpArray['k'][] = $this->setQuote($k);
                $tmpArray['v'][] = $this->setQuote($v);
            }
            $this->fileds = $tmpArray;
        }
        return $this;
    }

    /**
     *
     * Order By函数
     * @param String $field
     * @param String $orderBy
     */
    final function orderBy($field, $orderBy)
    {
        if (!empty($field)) return $this;

        if ($this->orderBy != '') {
            $this->orderBy .= $field . ' ' . $orderBy;
        } else {
            $this->orderBy = sprintf($this->_query['ORDER'], $field, $orderBy);
        }
    }

    /**
     * 多个order by条件
     */
    final function orderByArr($map)
    {
        if (empty($map)) return $this;
        foreach ($map AS $val) {
            $this->orderBy($val['field'], $val['orderBy']);
        }
        return $this;
    }

    /**
     * order by
     * @param string order by
     */
    final function orderByStr($orderBy)
    {
        if (!$orderBy) return $this;
        $this->orderBy = $orderBy;
        return $this;
    }

    /**
     *
     * Limit函数，如果省略第二个参数则第一个为0，第二个参数值取第一个
     * @param Int $limit
     * @param Int $offset
     */
    final function limit($limit, $offset = 0)
    {
        $this->limit = null;
        if ($limit !== '') {
            if (!$offset) {
                $this->limit = sprintf($this->_query["LIMIT"], 0, $limit);
            } else {
                $this->limit = sprintf($this->_query["LIMIT"], $limit, $offset);
            }
        }
        return $this;
    }

    /**
     * 创建Like查询条件
     * @param string | array $like like的条件
     */
    final function like($like)
    {
        if (empty($like)) return $this;
        $likeArray = array();
        if ($like && !is_array($like)) {
            $likeArray[] = $like;
        } else {
            foreach ($like AS $key => $val) {
                if(stristr($key, '.')) {
                    $likeArray[] = sprintf("%s LIKE '%s'", $key, "%" . $this->setQuote($val) . "%");
                }else{
                    $likeArray[] = sprintf($this->_query['LIKE'], $key, "%" . $this->setQuote($val) . "%");
                }
            }
        }
        if (count($likeArray) > 0) {
            $likeSQL = join(" OR ", $likeArray);
            if (!$this->where) {
                $this->where = sprintf($this->_query["WHERE"], $likeSQL);
            } else {
                $this->where .= ' AND (' . $likeSQL . ')';
            }
        }
        return $this;
    }
    /**
     * 不包含的条件
     * @param array $where 条件
     * @return $this
     */
    final function exclude($where)
    {
        if (empty($where)) return $this;
        $whereArray = array();
        if ($where && !is_array($where)) {
            $whereArray[] = $where;
        } else {
            foreach ($where AS $key => $val) {
            	$whereArray[] = sprintf("%s != '%s'", $key, $this->setQuote($val));
            }
        }
        if (count($whereArray) > 0) {
            $whereSQL = join(" AND ", $whereArray);
            if (!$this->where) {
                $this->where = sprintf($this->_query["WHERE"], $whereSQL);
            } else {
                $this->where .= ' AND (' . $whereSQL . ')';
            }
        }
        return $this;
    }

    /**
     * 传的条件为数组
     * @param  Array $where 条件
     * @return Object       对象本身
     */
    final function whereArray($where)
    {
        $this->where = null;
        if (!empty($where)) {
            $whereArray = array();
            foreach ($where AS $k => $v) {
                $v = $this->setQuote($v);
                if(stristr($k, '.')) {
                    $whereArray[] = " {$k} = '{$v}'";
                }else{
                    $whereArray[] = " `{$k}` = '{$v}'";
                }
            }
            if (sizeof($whereArray) > 0) {
                $whereSQL = join(" AND ", $whereArray);
                if (!$this->where) {
                    $this->where = sprintf($this->_query["WHERE"], $whereSQL);
                } else {
                    $this->where .= " AND (" . $whereSQL . ")";
                }
            }
        }
        return $this;
    }

    /**
     *
     * WHERE 子句
     * @param String $where
     */
    final function where($where)
    {
        if (is_array($where)) return $this->whereArray($where);
        $this->where = null;
        if (!empty($where)) {
            $this->where = sprintf($this->_query["WHERE"], $where);
        }
        return $this;
    }

    /**
     * 创建插入表的SQL
     */
    final function createInsertSQL($table)
    {
        $sql = sprintf($this->_query['INSERT'], $table, join(",", $this->fileds['k']), join("', '", $this->fileds['v']));
        $this->cleanData();
        return $sql;
    }

    /**
     *
     * 插入数据到指定表中
     * @param String $table
     */
    final function insertRow($table)
    {
        $this->modelSQL = $sql = $this->createInsertSQL($table);
        $this->setQuery($sql);
        return $this->lastInsertId();
    }

    /**
     * 创建replace object SQL
     *
     * @param string $table 表名
     * @return string
     */
    final function createReplaceSQL($table)
    {
        $sql = sprintf($this->_query['REPLACE'], $table, join(",", $this->fileds['k']), join("', '", $this->fileds['v']));
        $this->cleanData();
        return $sql;
    }

    /**
     *
     * Replace方法
     * @param String $table
     */
    final function replaceRow($table)
    {
        $this->modelSQL = $sql = $this->createReplaceSQL($table);
        return $this->exec($sql);
    }

    /**
     *
     * 查询一行
     * @param String $table
     */
    final function selectRow($table)
    {
        $this->modelSQL = $sql = $this->createSelectSQL($table);
        $this->cleanData();
        return $this->getRow($sql);
    }


    /**
     *
     * 查询一行
     * @param String $table
     */
    final function selectOne($table)
    {
        $this->modelSQL = $sql = $this->createSelectSQL($table);
        return $this->getOne($sql);
    }

    /**
     * 创建SELECT SQL
     */
    final function createSelectSQL($table)
    {

        if(stristr($table, '.') == false && stristr($table, '`') == false) {
            $table = '`'. $table .'`';
        }
        $sql = sprintf($this->_query['SELECT'], ((trim($this->fields) != '') ? $this->fields : "*"), $table) . $this->join . $this->where . $this->groupBy . $this->orderBy . $this->limit;
        $this->cleanData();
        return $sql;
    }

    /**
     *
     * 查询所有
     * @param String $table 数据表名称
     * @return Array
     */
    final function selectAll($table)
    {
        $this->modelSQL = $sql = $this->createSelectSQL($table);
        return $this->getAll($sql);
    }

    /**
     * 返回resource资源
     * @param string $table 数据表名称
     */
    final function rs($table)
    {
        $this->modelSQL = $sql = sprintf($this->_query['SELECT'], ((trim($this->fields) != '') ? $this->fields : "*"), $table) . $this->join . $this->where . $this->groupBy . $this->orderBy . $this->limit;
        $this->cleanData();
        return $this->setQuery($sql);
    }

    /**
     * 将指定字段减指定值
     *
     * @param array $data 数据
     * @return $this
     */
    final function downsetCounter($data)
    {
        if (is_array($data)) {
            foreach ($data AS $k => $value) {
                $this->setArray[] = $k . "=" . $k . '-' . $value;
            }
        }
        $this->set(null);
        return $this;
    }

    /**
     * 将指定字段加指定值
     *
     * @param $data
     * @return $this
     */
    final function upsetCounter($data)
    {
        if (is_array($data)) {
            foreach ($data AS $k => $value) {
                $this->setArray[] = $k . "=" . $k . '+' . $value;
            }
        }
        $this->set(null);
        return $this;
    }

    /**
     * 更新数据时候用，方法同setData
     * @param Array $data
     */
    final function set($data)
    {
        return $this->setData($data);
    }

    /**
     *
     * 更新数据时候用
     * @param Array $data
     * @return $this
     */
    final function setData($data)
    {
        if (is_array($data)) {
            $set = array();
            foreach ($data AS $k => $value) {
                $set[] = $k . "='" . $this->setQuote($value) . "'";
            }
            if (sizeof($this->setArray) > 0) {
                $this->set = " " . join(", ", $set) . ", " . join(",", $this->setArray);
            } else {
                $this->set = " " . join(", ", $set);
            }
        } else {
            if (sizeof($this->setArray) > 0) {
                $this->set = join(",", $this->setArray);
            } else {
                $this->set = "";
            }
        }
        return $this;
    }
    /**
     * 执行更新操作，updateRows的alias
     * @param String $table
     * @return number
     */
    /*
    final function update($table){
        return $this->updateRows($table);
    }
    */
    /**
     *
     * 执行更新操作
     * @param $table
     * @return Int 返回影响的行数
     */
    final function updateRows($table)
    {
        $this->modelSQL = $sql = sprintf($this->_query['UPDATE'], $table) . $this->set . $this->where . $this->limit;
        $this->cleanData();
        return $this->exec($sql);
    }

    /**
     *
     * 执行删除操作
     * @param String $table
     */
    final function deleteRows($table)
    {
        $this->modelSQL = $sql = sprintf($this->_query['DELETE'], $table, $this->where) . $this->limit;
        $this->cleanData();
        return $this->exec($sql);
    }

    /**
     * 执行Model过程中保存的相关信息
     *
     * @param String $option
     * @return Mix
     */
    final function querySQL($option = '')
    {
        $allow = array('_queryTimes', '_querySeconds', '_errorInfo', '_exeSQL');
        if (in_array($option, $allow)) {
            return $this->{$option};
        }
        return 0;
    }

    /**
     * 将结果编码一下
     * @param String $word
     * @return String|multitype:
     */
    public function setQuote($word)//过滤sql字符
    {
        if (ini_get("magic_quotes_gpc")) {
            return $word;
        }
        return is_array($word) ? array_map('addslashes', $word) : addslashes($word);
    }

    /**
     * 获取错误码
     */
    public function getCode()
    {
        return $this->response->getCode();
    }

    /**
     * 获取错误信息
     */
    public function getMessage()
    {
        if ($this->response->isError()) {
            return $this->response->getMessage();
        }
    }

    /**
     * 返回response对象
     *
     * @return Bool
     */
    public function getResponse()
    {
        return $this->response;
    }

    /**
     * 转换字符创
     *
     * @param $str
     * @return array|string
     */
    public function iconv($str)
    {
        if (is_array($str)) {
            return array_map(function ($n) {
                return toUtf8($n);
            }, $str);
        }

        return toUtf8($str);
    }

    /**
     * 如果不存在指定的方法则调用提示错误
     *
     * @param String $name
     * @param Mix $args
     * @return Mix
     */
    public function __call($method, $argvs)
    {
        if (isset($this->_modelAlias[$method])) {
            if (method_exists($this, $this->_modelAlias[$method])) {
                return call_user_func_array(array($this, $this->_modelAlias[$method]), $argvs);
            }
            \Qii::setError(false, __LINE__, 1506, 'Alias ' . get_called_class() . '->' . $method . '()');
        }

        \Qii::setError(false, __LINE__, 1506, get_called_class() . '->' . $method . '()');
    }
}