Abstract.php

浏览该文件的文档。

<?php
// FleaPHP Framework
//
// Copyright (c) 2005 - 2008 QeeYuan China Inc. (http://www.qeeyuan.com)
//
// 许可协议，请查看源代码中附带的 LICENSE.txt 文件，
// 或者访问 http://www.fleaphp.org/ 获得详细信息。

// {{{ constants
define('DBO_PARAM_QM',          '?');
define('DBO_PARAM_CL_NAMED',    ':');
define('DBO_PARAM_DL_SEQUENCE', '$');
define('DBO_PARAM_AT_NAMED',    '@');

class FLEA_Db_Driver_Abstract
{
    var $TRUE_VALUE  = 1;
    var $FALSE_VALUE = 0;
    var $NULL_VALUE = 'NULL';

    var $NEXT_ID_SQL    = null;
    var $CREATE_SEQ_SQL = null;
    var $INIT_SEQ_SQL   = null;
    var $DROP_SEQ_SQL   = null;

    var $META_COLUMNS_SQL = null;

    var $PARAM_STYLE = DBO_PARAM_QM;

    var $HAS_INSERT_ID  = false;

    var $HAS_AFFECTED_ROWS = false;

    var $HAS_TRANSACTION = false;

    var $HAS_SAVEPOINT = false;

    var $RESULT_FIELD_NAME_LOWER = false;

    var $dsn = null;

    var $conn = null;

    var $log = array();

    var $querycount = 0;

    var $lasterr = null;

    var $lasterrcode = null;

    var $_insertId = null;

    var $_transCount = 0;

    var $_hasFailedQuery = false;

    var $_savepointStack = array();

    function FLEA_Db_Driver_Abstract($dsn = null)
    {
        $tmp = (array)$dsn;
        unset($tmp['password']);
        $this->dsn = $dsn;
        $this->enableLog = FLEA::getAppInf('logEnabled');
        if (!function_exists('log_message')) {
            $this->enableLog = false;
        }
    }

    function connect($dsn = false)
    {
    }

    function close()
    {
        $this->conn = null;
        $this->lasterr = null;
        $this->lasterrcode = null;
        $this->_insertId = null;
        $this->_transCount = 0;
        $this->_transCommit = true;
    }

    function selectDb($database)
    {
    }

    function execute($sql, $inputarr = null, $throw = true)
    {
    }

    function qstr($value)
    {
    }

    function setValueByType($value, $type)
    {
        switch (strtoupper($type)) {
        case 'I':
            return (int)$value;
        case 'N':
            return (float)$value;
        case 'L':
            return (bool)$value;
        default:
            return $value;
        }
    }

    function qtable($tableName, $schema = null)
    {
    }

    function qfield($fieldName, $tableName = null, $schema = null)
    {
    }

    function qfields($fields, $tableName = null, $schema = null, $returnArray = false)
    {
        if (!is_array($fields)) {
            $fields = explode(',', $fields);
            $fields = array_map('trim', $fields);
        }
        $return = array();
        foreach ($fields as $fieldName) {
            $return[] = $this->qfield($fieldName, $tableName, $schema);
        }
        return $returnArray ? $return : implode(', ', $return);
    }

    function nextId($seqName = 'sdbo_seq', $startValue = 1)
    {
        $getNextIdSql = sprintf($this->NEXT_ID_SQL, $seqName);
        $result = $this->execute($getNextIdSql, null, false);
        if (!$result) {
            if (!$this->createSeq($seqName, $startValue)) { return false; }
            $result = $this->execute($getNextIdSql);
            if (!$result) { return false; }
        }

        if ($this->HAS_INSERT_ID) {
            return $this->_insertId();
        } else {
            $row = $this->fetchRow($result);
            $this->freeRes($result);
            $nextId = reset($row);
            $this->_insertId = $nextId;
            return $nextId;
        }
    }

    function createSeq($seqName = 'sdbo_seq', $startValue = 1)
    {
        if ($this->execute(sprintf($this->CREATE_SEQ_SQL, $seqName))) {
            return $this->execute(sprintf($this->INIT_SEQ_SQL, $seqName, $startValue - 1));
        } else {
            return false;
        }
    }

    function dropSeq($seqName = 'sdbo_seq')
    {
        return $this->execute(sprintf($this->DROP_SEQ_SQL, $seqName));
    }

    function insertId()
    {
        return $this->HAS_INSERT_ID ? $this->_insertId() : $this->_insertId;
    }

    function affectedRows()
    {
        return $this->HAS_AFFECTED_ROWS ? $this->_affectedRows() : false;
    }

    function fetchRow($res)
    {
    }

    function fetchAssoc($res)
    {
    }

    function freeRes($res)
    {
    }

    function selectLimit($sql, $length = null, $offset = null)
    {
    }

    function getAllWithFieldRefs($sql, $field, & $fieldValues, & $reference)
    {
        $res = is_resource($sql) ? $sql : $this->execute($sql);
        $fieldValues = array();
        $reference = array();
        $offset = 0;
        $data = array();

        while ($row = $this->fetchAssoc($res)) {
            $fieldValue = $row[$field];
            unset($row[$field]);
            $data[$offset] = $row;
            $fieldValues[$offset] = $fieldValue;
            $reference[$fieldValue] =& $data[$offset];
            $offset++;
        }
        $this->freeRes($res);
        return $data;
    }

    function assemble($sql, & $assocRowset, $mappingName, $oneToOne, $refKeyName, $limit = null)
    {
        if (is_resource($sql)) {
            $res = $sql;
        } else {
            if (!is_null($limit)) {
                if (is_array($limit)) {
                    list($length, $offset) = $limit;
                } else {
                    $length = $limit;
                    $offset = 0;
                }
                $res = $this->selectLimit($sql, $length, $offset);
            } else {
                $res = $this->execute($sql);
            }
        }

        if ($oneToOne) {
            // 一对一组装数据
            while ($row = $this->fetchAssoc($res)) {
                $rkv = $row[$refKeyName];
                unset($row[$refKeyName]);
                $assocRowset[$rkv][$mappingName] = $row;
            }
        } else {
            // 一对多组装数据
            while ($row = $this->fetchAssoc($res)) {
                $rkv = $row[$refKeyName];
                unset($row[$refKeyName]);
                $assocRowset[$rkv][$mappingName][] = $row;
            }
        }
        $this->freeRes($res);
    }

    function & getAll($sql)
    {
        $res = is_resource($sql) ? $sql : $this->execute($sql);
        $rowset = array();
        while ($row = $this->fetchAssoc($res)) {
            $rowset[] = $row;
        }
        $this->freeRes($res);
        return $rowset;
    }

    function getOne($sql)
    {
        $res = is_resource($sql) ? $sql : $this->execute($sql);
        $row = $this->fetchRow($res);
        $this->freeRes($res);
        return isset($row[0]) ? $row[0] : null;
    }

    function & getRow($sql)
    {
        $res = is_resource($sql) ? $sql : $this->execute($sql);
        $row = $this->fetchAssoc($res);
        $this->freeRes($res);
        return $row;
    }

    function & getCol($sql, $col = 0)
    {
        $res = is_resource($sql) ? $sql : $this->execute($sql);
        $data = array();
        while ($row = $this->fetchRow($res)) {
            $data[] = $row[$col];
        }
        $this->freeRes($res);
        return $data;
    }

    function & getAllGroupBy($sql, & $groupBy)
    {
        if (is_resource($sql)) {
            $res = $sql;
        } else {
            $res = $this->execute($sql);
        }
        $data = array();
        $row = $this->fetchAssoc($res);
        if ($row != false) {
            if ($groupBy === true) {
                $groupBy = key($row);
            }
            do {
                $rkv = $row[$groupBy];
                unset($row[$groupBy]);
                $data[$rkv][] = $row;
            } while ($row = $this->fetchAssoc($res));
        }
        $this->freeRes($res);
        return $data;
    }

    function & metaColumns($table)
    {
    }

    function metaTables($pattern = null, $schema = null)
    {
    }

    function dbTimeStamp($timestamp)
    {
        return date('Y-m-d H:i:s', $timestamp);
    }

    function startTrans()
    {
        if (!$this->HAS_TRANSACTION) { return false; }
        if ($this->_transCount == 0) {
            $this->_startTrans();
            $this->_hasFailedQuery = false;
        }
        $this->_transCount++;
        if ($this->_transCount > 1 && $this->HAS_SAVEPOINT) {
            $savepoint = 'savepoint_' . $this->_transCount;
            $this->execute("SAVEPOINT {$savepoint}");
            array_push($this->_savepointStack, $savepoint);
        }
    }

    function completeTrans($commitOnNoErrors = true)
    {
        if (!$this->HAS_TRANSACTION) { return false; }
        if ($this->_transCount == 0) { return; }
        $this->_transCount--;
        if ($this->_transCount > 0 && $this->HAS_SAVEPOINT) {
            $savepoint = array_pop($this->_savepointStack);
            if ($this->_hasFailedQuery || $commitOnNoErrors == false) {
                $this->execute("ROLLBACK TO SAVEPOINT {$savepoint}");
            }
        } else {
            $this->_completeTrans($commitOnNoErrors);
        }
    }

    function failTrans()
    {
        $this->_hasFailedQuery = true;
    }

    function hasFailedTrans()
    {
        return $this->HAS_TRANSACTION ? $this->_hasFailedQuery : false;
    }

    function bind($sql, & $inputarr)
    {
        $arr = explode('?', $sql);
        $sql = array_shift($arr);
        foreach ($inputarr as $value) {
            if (isset($arr[0])) {
                $sql .= $this->qstr($value) . array_shift($arr);
            }
        }
        return $sql;
    }

    function getInsertSQL(& $row, $table, $schema = null)
    {
        list($holders, $values) = $this->getPlaceholder($row);
        $holders = implode(',', $holders);
        $fields = $this->qfields(array_keys($values));
        $table = $this->qtable($table, $schema);
        $sql = "INSERT INTO {$table} ({$fields}) VALUES ({$holders})";
        return $sql;
    }

    function getUpdateSQL(& $row, $pk, $table, $schema = null)
    {
        $pkv = $row[$pk];
        unset($row[$pk]);
        list($pairs, $values) = $this->getPlaceholderPair($row);
        $row[$pk] = $pkv;
        $pairs = implode(',', $pairs);
        $table = $this->qtable($table, $schema);
        $pk = $this->qfield($pk);
        $sql = "UPDATE {$table} SET {$pairs} WHERE {$pk} = " . $this->qstr($pkv);
        return $sql;
    }

    function getPlaceholder(& $inputarr, $fields = null)
    {
        $holders = array();
        $values = array();
        if (is_array($fields)) {
            $fields = array_change_key_case(array_flip($fields), CASE_LOWER);
            foreach (array_keys($inputarr) as $key) {
                if (!isset($fields[strtolower($key)])) { continue; }
                if ($this->PARAM_STYLE == DBO_PARAM_QM) {
                    $holders[] = $this->PARAM_STYLE;
                } else {
                    $holders[] = $this->PARAM_STYLE . $key;
                }
                $values[$key] =& $inputarr[$key];
            }
        } else {
            foreach (array_keys($inputarr) as $key) {
                if ($this->PARAM_STYLE == DBO_PARAM_QM) {
                    $holders[] = $this->PARAM_STYLE;
                } else {
                    $holders[] = $this->PARAM_STYLE . $key;
                }
                $values[$key] =& $inputarr[$key];
            }
        }
        return array($holders, $values);
    }

    function getPlaceholderPair(& $inputarr, $fields = null)
    {
        $pairs = array();
        $values = array();
        if (is_array($fields)) {
            $fields = array_change_key_case(array_flip($fields), CASE_LOWER);
            foreach (array_keys($inputarr) as $key) {
                if (!isset($fields[strtolower($key)])) { continue; }
                $qkey = $this->qfield($key);
                if ($this->PARAM_STYLE == DBO_PARAM_QM) {
                    $pairs[] = "{$qkey}={$this->PARAM_STYLE}";
                } else {
                    $pairs[] = "{$qkey}={$this->PARAM_STYLE}{$key}";
                }
                $values[$key] =& $inputarr[$key];
            }
        } else {
            foreach (array_keys($inputarr) as $key) {
                $qkey = $this->qfield($key);
                if ($this->PARAM_STYLE == DBO_PARAM_QM) {
                    $pairs[] = "{$qkey}={$this->PARAM_STYLE}";
                } else {
                    $pairs[] = "{$qkey}={$this->PARAM_STYLE}{$key}";
                }
                $values[$key] =& $inputarr[$key];
            }
        }
        return array($pairs, $values);
    }
}

---