php代码
<?php   
/* vim: set expandtab tabstop=4 shiftwidth=4 foldmethod=marker: */  
//===========================================   
// 程序：   MySQL-Based session Class   
// 功能：   基于mysql存储的 Session 功能类   
// 作者:    yejr   
// 网站:    http://imysql.cn   
// 时间:    2007-01-05   
//===========================================   
  
/**  
 * 类名:    MySQL Session Class  
 * 功能:    自主实现基于MySQL HEAP表存储的 Session 功能  
 * 描述:    这个类就是实现Session的功能，基本上是通过设置客户端的Cookie来保存SessionID，  
 *          然后把用户的数据保存在服务器端，最后通过Cookie中的Session Id来确定一个数据是否是用户的，  
 *          然后进行相应的数据操作  
 *  
 * 注意: 本类调用了PEAR::DB类,如果有自己的DB类,则可以稍微修改一下代码  
 *  
 * 备注：数据表初始化SQL语句:  
 * CREATE TABLE `sessions` (  
 * `sid` varchar(32) NOT NULL default '',  
 * `session` longtext,  
 * `flush_dt` int unsigned NOT NULL default '0',  
 * PRIMARY KEY  (`sid`),  
 * KEY `last` (`flush_dt`)  
 * ) ENGINE=HEAP;  
 */  
  
//设定 SESSION 有效时间，单位是 秒   
define('SESS_LIFTTIME', 3600);   
define('DB_DSN', 'mysql://root:@localhost/test');   
define('DB_NAME','test');   
  
require_once('DB.php');   
  
$gDb    = new DB;   
$gDb    = DB::connect(DB_DSN, TRUE);   
  
if (PEAR::isError($gDb))   
{   
    die($gDb->getMessage());   
}   
  
if (!defined('MySQLSession'))   
{   
    define('MySQLSession',    TRUE);   
  
class Usess   
{   
    static  $mSessSavePath;   
    static  $mSessName;   
    static  $mSessMaxTime;   
    static  $mTblSess   = 'sessions';   
    static  $mTblSessMap;   
    static  $mDb;   
  
    // {{{ 初始化构造函数   
    /**  
     * 构造函数  
     *  
     * @param string $login_user    登录用户  
     * @param int $login_type       用户类型  
     * @param string $login_sess    登录Session值  
     * @return Esession  
     */  
    public function __construct()   
    {   
        self::$mSessMaxTime = SESS_LIFTTIME;   
  
        self::$mTblSessMap  = array(   
                'sid'   => 'sid',   
                'data'  => 'session',   
                'last'  => 'flush_dt',   
                );   
    }   
    // }}}   
  
    /** {{{ sessOpen($pSavePath, $name)  
     *  
     * @param   String  $pSavePath  
     * @param   String  $pSessName  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessOpen($pSavePath = '', $pSessName = '')   
    {   
        global $gDb;   
  
        self::$mDb  = $gDb;   
        self::$mSessSavePath    = $pSavePath;   
        self::$mSessName        = $pSessName;   
  
        self::sessGc();   
  
        return TRUE;   
    }   
    // }}}   
  
    /** {{{ sessClose()  
     *  
     * @param   NULL  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessClose()   
    {   
        return TRUE;   
    }   
    // }}}   
  
    /** {{{ sessRead($wSid)  
     *  
     * @param   String  $wSid  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessRead($wSid = '')   
    {   
        global $db;   
  
        $wSql    = sprintf("SELECT * FROM `%s`.`%s` WHERE `%s` = '%s';",   
                        DB_NAME,   
                        self::$mTblSess,   
                        self::$mTblSessMap['sid'],   
                        $wSid  
                );   
  
        //这里一定要用 DB_FETCHMODE_ASSOC,否则取回的数组只能用数字做下标   
        if (!PEAR::isError($row = self::$mDb->getRow($wSql, null, DB_FETCHMODE_ASSOC)))   
        {   
            //session已经存在了   
            if (is_array($row) && 1 <= count($row))   
            {   
                return $row[self::$mTblSessMap['data']];   
            }   
            else  
            {   
                $wSql    = sprintf("INSERT INTO `%s`.`%s` VALUES ('%s', '', UNIX_TIMESTAMP(NOW()));",   
                                DB_NAME,   
                                self::$mTblSess,   
                                $wSid  
                        );   
  
                if (!PEAR::isError(self::$mDb->query($wSql)))   
                {   
                    return TRUE;   
                }   
            }   
        }   
  
        return FALSE;   
    }   
    // }}}   
  
    /** {{{ sessWrite($wSid, $wData)  
     *  
     * @param   String  $wSid  
     * @param   String  $wData  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessWrite($wSid = '', $wData = '')   
    {   
        $wData  = mysql_escape_string($wData);   
  
        $wSql    = sprintf("UPDATE `%s`.`%s` SET `%s` = '%s', `%s` = UNIX_TIMESTAMP(NOW()) WHERE `%s` = '%s';",   
                        DB_NAME,   
                        self::$mTblSess,   
                        self::$mTblSessMap['data'],   
                        $wData,   
                        self::$mTblSessMap['last'],   
                        self::$mTblSessMap['sid'],   
                        $wSid  
                );   
  
        if (!PEAR::isError(self::$mDb->query($wSql)))   
        {   
            return TRUE;   
        }   
  
        return FALSE;   
    }   
    // }}}   
  
    /** {{{ sessDestroy($wSid)  
     *  
     * @param   String  $wSid  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessDestroy($wSid = '')   
    {   
        $wSql    = sprintf("DELETE FROM `%s`.`%s` WHERE `%s` = '%s';",   
                        DB_NAME,   
                        self::$mTblSess,   
                        $wSid  
                );   
  
        if (!PEAR::isError(self::$mDb->query($wSql)))   
        {   
            return TRUE;   
        }   
  
        return FALSE;   
    }   
    // }}}   
  
    /** {{{ sessGc()  
     *  
     * @param   NULL  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function sessGc()   
    {   
        global $db;   
  
        //计算出过期时间   
        $last   = time() - self::$mSessMaxTime;   
  
        $wSql    = sprintf("DELETE FROM `%s`.`%s` WHERE `%s` < $last;", DB_NAME, self::$mTblSess, self::$mTblSessMap['last']);   
  
        if (!PEAR::isError(self::$mDb->query($wSql)))   
        {   
            return TRUE;   
        }   
  
        return FALSE;   
    }   
    // }}}   
  
    /** {{{ initSess()  
     *  
     * @param   NULL  
     *  
     * @return  Bool    TRUE/FALSE  
     */  
    public function initSess()   
    {   
        $domain = '';   
  
        //不使用 GET/POST 变量方式   
        ini_set('session.use_trans_sid',    0);   
  
        //设置垃圾回收最大生存时间   
        ini_set('session.gc_maxlifetime',   SESS_LIFTTIME);   
  
        //使用 COOKIE 保存 SESSION ID 的方式   
        ini_set('session.use_cookies',      1);   
        ini_set('session.cookie_path',      '/');   
  
        //多主机共享保存 SESSION ID 的 COOKIE   
        ini_set('session.cookie_domain',    $domain);   
  
        //将 session.save_handler 设置为 user，而不是默认的 files   
        session_module_name('user');   
  
        //定义 SESSION 各项操作所对应的方法名：   
        session_set_save_handler(   
                array('Usess', 'sessOpen'),   //对应于静态方法 My_Sess::open()，下同。   
                array('Usess', 'sessClose'),   
                array('Usess', 'sessRead'),   
                array('Usess', 'sessWrite'),   
                array('Usess', 'sessDestroy'),   
                array('Usess', 'sessGc')   
                );   
        session_start();   
  
        return TRUE;   
    }   
    // }}}   
  
}//end class   
  
}//end define   
  
$sess   = new Usess;   
$sess->initSess();   
?>