/**
* 类名: 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();