Db.php

浏览该文件的文档。

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

class FLEA_Session_Db
{
    var $dbo = null;

    var $tableName = null;

    var $fieldId = null;

    var $fieldData = null;

    var $fieldActivity = null;

    var $lifeTime = 0;

    function FLEA_Session_Db()
    {
        $this->tableName = FLEA::getAppInf('sessionDbTableName');
        $this->fieldId = FLEA::getAppInf('sessionDbFieldId');
        $this->fieldData = FLEA::getAppInf('sessionDbFieldData');
        $this->fieldActivity = FLEA::getAppInf('sessionDbFieldActivity');
        $this->lifeTime = (int)FLEA::getAppInf('sessionDbLifeTime');

        if (PHP4) {
            register_shutdown_function('session_write_close');
        }

        session_set_save_handler(
            array(& $this, 'sessionOpen'),
            array(& $this, 'sessionClose'),
            array(& $this, 'sessionRead'),
            array(& $this, 'sessionWrite'),
            array(& $this, 'sessionDestroy'),
            array(& $this, 'sessionGc')
        );
    }

    function __destruct()
    {
        session_write_close();
    }

    function sessionOpen($savePath, $sessionName)
    {
        $dsnName = FLEA::getAppInf('sessionDbDSN');
        $dsn = FLEA::getAppInf($dsnName);
        $this->dbo =& FLEA::getDBO($dsn);
        if (!$this->dbo) { return false; }

        if (!empty($this->dbo->dsn['dbTablePrefix'])) {
            $this->tableName = $this->dbo->dsn['dbTablePrefix'] . $this->tableName;
        }
        $this->tableName = $this->dbo->qtable($this->tableName);
        $this->fieldId = $this->dbo->qfield($this->fieldId);
        $this->fieldData = $this->dbo->qfield($this->fieldData);
        $this->fieldActivity = $this->dbo->qfield($this->fieldActivity);

        $this->sessionGc(FLEA::getAppInf('sessionDbLifeTime'));

        return true;
    }

    function sessionClose()
    {
        return true;
    }

    function sessionRead($sessid)
    {
        $sessid = $this->dbo->qstr($sessid);
        $sql = "SELECT {$this->fieldData} FROM {$this->tableName} WHERE {$this->fieldId} = {$sessid}";
        if ($this->lifeTime > 0) {
            $time = time() - $this->lifeTime;
            $sql .= " AND {$this->fieldActivity} >= {$time}";
        }

        return $this->dbo->getOne($sql);
    }

    function sessionWrite($sessid, $data)
    {
        $sessid = $this->dbo->qstr($sessid);
        $sql = "SELECT COUNT(*) FROM {$this->tableName} WHERE {$this->fieldId} = {$sessid}";
        $data = $this->dbo->qstr($data);
        $activity = time();

        $fields = (array)$this->_beforeWrite($sessid);
        if ((int)$this->dbo->getOne($sql) > 0) {
            $sql = "UPDATE {$this->tableName} SET {$this->fieldData} = {$data}, {$this->fieldActivity} = {$activity}";
            if (!empty($fields)) {
                $arr = array();
                foreach ($fields as $field => $value) {
                    $arr[] = $this->dbo->qfield($field) . ' = ' . $this->dbo->qstr($value);
                }
                $sql .= ', ' . implode(', ', $arr);
            }
            $sql .= " WHERE {$this->fieldId} = {$sessid}";
        } else {
            $extraFields = '';
            $extraValues = '';
            if (!empty($fields)) {
                foreach ($fields as $field => $value) {
                    $extraFields .= ', ' . $this->dbo->qfield($field);
                    $extraValues .= ', ' . $this->dbo->qstr($value);
                }
            }

            $sql = "INSERT INTO {$this->tableName} ({$this->fieldId}, {$this->fieldData}, {$this->fieldActivity}{$extraFields}) VALUES ({$sessid}, {$data}, {$activity}{$extraValues})";
        }

        __TRY();
        $this->dbo->execute($sql);
        $ex = __CATCH();
        return !__IS_EXCEPTION($ex);
    }

    function sessionDestroy($sessid)
    {
        $sessid = $this->dbo->qstr($sessid);
        $sql = "DELETE FROM {$this->tableName} WHERE {$this->fieldId} = {$sessid}";
        return $this->dbo->execute($sql);
    }

    function sessionGc($maxlifetime)
    {
        if ($this->lifeTime > 0) {
            $maxlifetime = $this->lifeTime;
        }
        $time = time() - $maxlifetime;
        $sql = "DELETE FROM {$this->tableName} WHERE {$this->fieldActivity} < {$time}";
        $this->dbo->execute($sql);
        return true;
    }

    function getOnlineCount($lifetime = -1)
    {
        if ($this->lifeTime > 0) {
            $lifetime = $this->lifeTime;
        } else if ($lifetime <= 0) {
            $lifetime = (int)ini_get('session.gc_maxlifetime');
            if ($lifetime <= 0) {
                $lifetime = 1440;
            }
        }
        $sql = "SELECT COUNT(*) FROM {$this->tableName}";
        if ($this->lifeTime > 0) {
            $time = time() - $lifetime;
            $sql .= " WHERE {$this->fieldActivity} >= {$time}";
        }
        return (int)$this->dbo->getOne($sql);
    }

    function _beforeWrite($sessid)
    {
        return array();
    }
}

---