uchome源码解读之数据库

一月 6, 2010
掌握uchome必然要搞清楚他的数据库,我们可以通过mysql的管理器看到表的结构,也可以通过data/install.sql直接查看构建数据库的sql语句,在了解字段类型时比较方便.对于各个表的介绍,可以看看官方论坛里有人发的帖子:
http://www.discuz.net/thread-976448-1-1.html
要完全掌握各个表各个字段的关系就还需要更深入的学习。

再来看看数据库访问的调用代码:

在space_index.php文件中,我们看到这样的查询代码:
$query = $_SGLOBAL['db']->query(”SELECT * FROM “.tname(’friend’).” WHERE uid=’$space[uid]‘ AND status=’1′ LIMIT 0,6″);

$_SGLOBAL['db']是怎样的一个对象呢?在function_common.php文件中找到答案:
function dbconnect() {
    global $_SGLOBAL, $_SC;

    include_once(S_ROOT.’./source/class_mysql.php’);

    $_SGLOBAL['db'] = new dbstuff;
    $_SGLOBAL['db']->charset = $_SC['dbcharset'];
    $_SGLOBAL['db']->connect($_SC['dbhost'], $_SC['dbuser'], $_SC['dbpw'], $_SC['dbname'], $_SC['pconnect']);
}

原来是class_mysql.php文件中的dbstuff对象
dbstuff类中最重要的方法就是connect()和query()方法,connect负责开启数据库连接,具体取数据就靠query了,query的核心代码如下:
$func = $type == ‘UNBUFFERED’ && @function_exists(’mysql_unbuffered_query’) ?
            ‘mysql_unbuffered_query’ : ‘mysql_query’;
        if(!($query = $func($sql, $this->link)) && $type != ‘SILENT’) {
            $this->halt(’MySQL Query Error’, $sql);
        }

刚看的时候没找到查询语句怎么执行的,后来发现是个小技巧,声明了一个变量$func,进行type判断后,赋值为“mysql_query”,然后$func(),就等于mysql_query(),这个技巧熟悉ror的同志肯定不会陌生。

query并不仅仅负责查询,数据的插入和更新都是通过query来完成的,在function_common.php中:
//添加数据
function inserttable($tablename, $insertsqlarr, $returnid=0, $replace = false) {
    global $_SGLOBAL;

    $insertkeysql = $insertvaluesql = $comma = ”;
    foreach ($insertsqlarr as $insert_key => $insert_value) {
        $insertkeysql .= $comma.’`’.$insert_key.’`';
        $insertvaluesql .= $comma.’\”.$insert_value.’\”;
        $comma = ‘, ‘;
    }
    $method = $replace?’REPLACE’:'INSERT’;
    $_SGLOBAL['db']->query($method.’ INTO ‘.tname($tablename).’ (’.$insertkeysql.’) VALUES (’.$insertvaluesql.’) ‘);
    if($returnid && !$replace) {
        return $_SGLOBAL['db']->insert_id();
    }
}

//更新数据
function updatetable($tablename, $setsqlarr, $wheresqlarr) {
    global $_SGLOBAL;

    $setsql = $comma = ”;
    foreach ($setsqlarr as $set_key => $set_value) {
        $setsql .= $comma.’`’.$set_key.’`’.’=\”.$set_value.’\”;
        $comma = ‘, ‘;
    }
    $where = $comma = ”;
    if(empty($wheresqlarr)) {
        $where = ‘1′;
    } elseif(is_array($wheresqlarr)) {
        foreach ($wheresqlarr as $key => $value) {
            $where .= $comma.’`’.$key.’`’.’=\”.$value.’\”;
            $comma = ‘ AND ‘;
        }
    } else {
        $where = $wheresqlarr;
    }
    $_SGLOBAL['db']->query(’UPDATE ‘.tname($tablename).’ SET ‘.$setsql.’ WHERE ‘.$where);
}

Leave a Reply