PHP将session信息存储到数据库的类实例_php技巧

本文实例讲述了PHP将session信息存储到数据库的类。分享给大家供大家参考。具体分析如下：

SessionHandlerInterface接口是PHP内置的接口，直接实现就行了
具体可以看php手册关于session_set_save_handler函数的解释！

PHP代码如下：

<br />/**<br />* session信息存储到数据库的类<br />* 表结构：<br />* CREATE TABLE IF NOT EXISTS `sessioninfo` (<br />*  `sid` varchar(255) NOT NULL,<br />*  `value` text NOT NULL,<br />*  `expiration` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,<br />*  PRIMARY KEY (`sid`)<br />* ) ENGINE=InnoDB DEFAULT CHARSET=utf8;<br />*/<br />class MySessionHandler implements SessionHandlerInterface {<br />    /**<br />    * @access private<br />    * @var object 数据库连接<br />    */<br />    private $_dbLink;<br />    /**<br />    * @access private<br />    * @var string 保存session的表名<br />    */<br />    Private $_sessionTable;<br />    /**<br />    * @access private<br />    * @var string session名<br />    */<br />    private $_sessionName;<br />    /**<br />    * @const 过期时间<br />    */<br />    const SESSION_EXPIRE = 10;<br />    public function __construct($dbLink, $sessionTable) {<br />        if(!is_object($dbLink)) {<br />            return false;<br />        }<br />        $this->_dbLink = $dbLink;<br />        $this->_sessionTable = $sessionTable;<br />    }<br />    /**<br />    * 打开<br />    * @access public<br />    * @param string $session_save_path 保存session的路径<br />    * @param string $session_name session名<br />    * @return integer<br />    */<br />    public function open($session_save_path, $session_name) {<br />        $this->_sessionName = $session_name;<br />        return 0;<br />    }<br />    /**<br />    * 关闭<br />    * @access public<br />    * @return integer<br />    */<br />    public function close() {<br />        return 0;<br />    }<br />    /**<br />    * 关闭session<br />    * @access public<br />    * @param string $session_id session ID<br />    * @return string<br />    */<br />    public function read($session_id) {<br />        $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = {$session_id} AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";<br />        $result = $this->_dbLink->query($query);<br />        if(!isset($value) || empty($value)) {<br />            $value = "";<br />            return $value;<br />        }<br />        $this->_dbLink->query("UPDATE {$this->_sessionTable} SET expiration = CURRENT_TIMESTAMP() WHERE sid = {$session_id}");<br />        $value = $result->fetch_array();<br />        $result->free();<br />        return $value['value'];<br />    }<br />    /**<br />    * 写入session<br />    * @access public<br />    * @param string $session_id session ID<br />    * @param string $session_data session data<br />    * @return integer<br />    */<br />    public function write($session_id, $session_data) {<br />        $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = '{$session_id}' AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";<br />        $result = $this->_dbLink->query($query);<br />        $result = $result->fetch_array();<br />        if(!empty($result)) {<br />            $result = $this->_dbLink->query("UPDATE {$this->_sessionTable} SET value = {$session_data} WHERE sid = {$session_id}");<br />        }<br />        else{<br />            $result = $this->_dbLink->query("INSERT INTO {$this->_sessionTable} (<em>8本文来源gao.dai.ma.com搞@代*码(网$</em><pre>搞代gaodaima码

sid, value) VALUES (‘{$session_id}’, ‘{$session_data}’)”);
}
if($result){
return 0;
}
else{
return 1;
}
}
/**
* 销魂session
* @access public
* @param string $session_id session ID
* @return integer
*/
public function destroy($session_id) {
$result = $this->_dbLink->query(“DELETE FROM {$this->_sessionTable} WHERE sid = ‘{$session_id}'”);
if($result){
return 0;
}
else{
return 1;
}
}
/**
* 垃圾回收
* @access public
* @param string $maxlifetime session 最长生存时间
* @return integer
*/
public function gc($maxlifetime) {
$result = $this->_dbLink->query(“DELETE FROM {$this->_sessionTable} WHERE UNIX_TIMESTAMP(expiration) < UNIX_TIMESTAMP(NOW()) – " . self::SESSION_EXPIRE);
if($result){
return 0;
}
else{
return 1;
}
}
}
$dbLink = new mysqli(“localhost”, “root”, “root”, “test”);
$sessionTable = “sessioninfo”;
$handler = new MySessionHandler($dbLink, $sessionTable);
session_set_save_handler($handler);
session_start();
$_SESSION[‘name’] = “test”;
echo $_SESSION[“name”];
//session_destroy();

希望本文所述对大家的php程序设计有所帮助。

喜欢 (0)赏

[搞代码]

分享 (0)