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

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

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

PHP代码如下：
复制代码 代码如下:

class MySessionHandler implements SessionHandlerInterface {
   
    private $_dblink;
   
    Private $_sessionTable;
   
    private $_sessionName;
   
    const SESSION_EXPIRE = 10;
    public function __construct($dblink, $sessionTable) {
        if(!is_object($dblink)) {
            return false;
        }
        $this->_dblink = $dblink;
        $this->_sessionTable = $sessionTable;
    }
   
    public function open($session_save_path, $session_name) {
        $this->_sessionName = $session_name;
        return 0;
    }
   
    public function close() {
        return 0;
    }
   
    public function read($session_id) {
        $query = "SELECt value FROM {$this->_sessionTable} WHERe sid = {$session_id} AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";
        $result = $this->_dblink->query($query);
        if(!isset($value) || empty($value)) {
            $value = "";
            return $value;
        }
        $this->_dblink->query("UPDATe {$this->_sessionTable} SET expiration = CURRENT_TIMESTAMP() WHERe sid = {$session_id}");
        $value = $result->fetch_array();
        $result->free();
        return $value['value'];
    }
   
    public function write($session_id, $session_data) {
        $query = "SELECT value FROM {$this->_sessionTable} WHERe sid = '{$session_id}' AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())";
        $result = $this->_dblink->query($query);
        $result = $result->fetch_array();
        if(!empty($result)) {
            $result = $this->_dblink->query("UPDATe {$this->_sessionTable} SET value = {$session_data} WHERe sid = {$session_id}");
        }
        else{
            $result = $this->_dblink->query("INSERT INTO {$this->_sessionTable} (sid, value) VALUES ('{$session_id}', '{$session_data}')");
        }
        if($result){
            return 0;
        }
        else{
            return 1;
        }      
    }
   
    public function destroy($session_id) {
        $result = $this->_dblink->query("DELETE FROM {$this->_sessionTable} WHERe sid = '{$session_id}'");
        if($result){
            return 0;
        }
        else{
            return 1;
        }
    }
   
    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程序设计有所帮助。