YII 类库手册

protected function createSessionTable($db,$tableName)
{
    $sql="
CREATE TABLE $tableName
(
id CHAR(32) PRIMARY KEY,
expire INTEGER,
data TEXT
)";
    $db->createCommand($sql)->execute();
}

public function destroySession($id)
{
    $sql="DELETE FROM {$this->sessionTableName} WHERE id=:id";
    $this->getDbConnection()->createCommand($sql)->bindValue(':id',$id)->execute();
    return true;
}

public function gcSession($maxLifetime)
{
    $sql="DELETE FROM {$this->sessionTableName} WHERE expire<".time();
    $this->getDbConnection()->createCommand($sql)->execute();
    return true;
}

protected function getDbConnection()
{
    if($this->_db!==null)
        return $this->_db;
    else if(($id=$this->connectionID)!==null)
    {
        if(($this->_db=Yii::app()->getComponent($id)) instanceof CDbConnection)
            return $this->_db;
        else
            throw new CException(Yii::t('yii','CDbHttpSession.connectionID "{id}" is invalid. Please make sure it refers to the ID of a CDbConnection application component.',
                array('{id}'=>$id)));
    }
    else
    {
        $dbFile=Yii::app()->getRuntimePath().DIRECTORY_SEPARATOR.'session-'.Yii::getVersion().'.db';
        return $this->_db=new CDbConnection('sqlite:'.$dbFile);
    }
}

public function getUseCustomStorage()
{
    return true;
}

public function openSession($savePath,$sessionName)
{
    if($this->autoCreateSessionTable)
    {
        $db=$this->getDbConnection();
        $db->setActive(true);
        $sql="DELETE FROM {$this->sessionTableName} WHERE expire<".time();
        try
        {
            $db->createCommand($sql)->execute();
        }
        catch(Exception $e)
        {
            $this->createSessionTable($db,$this->sessionTableName);
        }
    }
    return true;
}

public function readSession($id)
{
    $now=time();
    $sql="
SELECT data FROM {$this->sessionTableName}
WHERE expire>$now AND id=:id
";
    $data=$this->getDbConnection()->createCommand($sql)->bindValue(':id',$id)->queryScalar();
    return $data===false?'':$data;
}

public function regenerateID($deleteOldSession=false)
{
    $oldID=session_id();

    // if no session is started, there is nothing to regenerate
    if(empty($oldID))
        return;

    parent::regenerateID(false);
    $newID=session_id();
    $db=$this->getDbConnection();

    $sql="SELECT * FROM {$this->sessionTableName} WHERE id=:id";
    $row=$db->createCommand($sql)->bindValue(':id',$oldID)->queryRow();
    if($row!==false)
    {
        if($deleteOldSession)
        {
            $sql="UPDATE {$this->sessionTableName} SET id=:newID WHERE id=:oldID";
            $db->createCommand($sql)->bindValue(':newID',$newID)->bindValue(':oldID',$oldID)->execute();
        }
        else
        {
            $row['id']=$newID;
            $db->createCommand()->insert($this->sessionTableName, $row);
        }
    }
    else
    {
        // shouldn't reach here normally
        $db->createCommand()->insert($this->sessionTableName, array(
            'id'=>$newID,
            'expire'=>time()+$this->getTimeout(),
        ));
    }
}

public function writeSession($id,$data)
{
    // exception must be caught in session write handler
    // http://us.php.net/manual/en/function.session-set-save-handler.php
    try
    {
        $expire=time()+$this->getTimeout();
        $db=$this->getDbConnection();
        $sql="SELECT id FROM {$this->sessionTableName} WHERE id=:id";
        if($db->createCommand($sql)->bindValue(':id',$id)->queryScalar()===false)
            $sql="INSERT INTO {$this->sessionTableName} (id, data, expire) VALUES (:id, :data, $expire)";
        else
            $sql="UPDATE {$this->sessionTableName} SET expire=$expire, data=:data WHERE id=:id";
        $db->createCommand($sql)->bindValue(':id',$id)->bindValue(':data',$data)->execute();
    }
    catch(Exception $e)
    {
        if(YII_DEBUG)
            echo $e->getMessage();
        // it is too late to log an error message here
        return false;
    }
    return true;
}