这篇文章主要介绍了PHP将session信息存储到数据库的类,实例分析了php封装的session信息存储到数据库的类,具有一定参考借鉴价值,需要的朋友可以参考下。

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

SessionHandlerInterface接口是PHP内置的接口，直接实现就行了

具体可以看php手册关于session_set_save_handler函数的解释！

PHP代码如下：

1. /** 
2. * session信息存储到数据库的类 
3. * 表结构： 
4. * CREATE TABLE IF NOT EXISTS `sessioninfo` ( 
5. *  `sid` varchar(255) NOT NULL, 
6. *  `value` text NOT NULL, 
7. *  `expiration` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, 
8. *  PRIMARY KEY (`sid`) 
9. * ) ENGINE=InnoDB DEFAULT CHARSET=utf8; 
10. */ 
11. class MySessionHandler implements SessionHandlerInterface { 
12.     /** 
13.     * @access private 
14.     * @var object 数据库连接 
15.     */ 
16.     private $_dbLink; 
17.     /** 
18.     * @access private 
19.     * @var string 保存session的表名 
20.     */ 
21.     Private $_sessionTable; 
22.     /** 
23.     * @access private 
24.     * @var string session名 
25.     */ 
26.     private $_sessionName; 
27.     /** 
28.     * @const 过期时间 
29.     */ 
30.     const SESSION_EXPIRE = 10; 
31.     public function __construct($dbLink, $sessionTable) { 
32.         if(!is_object($dbLink)) { 
33.             return false; 
34.         } 
35.         $this->_dbLink = $dbLink; 
36.         $this->_sessionTable = $sessionTable; 
37.     } 
38.     /** 
39.     * 打开 
40.     * @access public 
41.     * @param string $session_save_path 保存session的路径 
42.     * @param string $session_name session名 
43.     * @return integer 
44.     */ 
45.     public function open($session_save_path, $session_name) { 
46.         $this->_sessionName = $session_name; 
47.         return 0; 
48.     } 
49.     /** 
50.     * 关闭 
51.     * @access public 
52.     * @return integer 
53.     */ 
54.     public function close() { 
55.         return 0; 
56.     } 
57.     /** 
58.     * 关闭session 
59.     * @access public 
60.     * @param string $session_id session ID 
61.     * @return string 
62.     */ 
63.     public function read($session_id) { 
64.         $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = {$session_id} AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())"; 
65.         $result = $this->_dbLink->query($query); 
66.         if(!isset($value) || emptyempty($value)) { 
67.             $value = ""; 
68.             return $value; 
69.         } 
70.         $this->_dbLink->query("UPDATE {$this->_sessionTable} SET expiration = CURRENT_TIMESTAMP() WHERE sid = {$session_id}"); 
71.         $value = $result->fetch_array(); 
72.         $result->free(); 
73.         return $value['value']; 
74.     } 
75.     /** 
76.     * 写入session 
77.     * @access public 
78.     * @param string $session_id session ID 
79.     * @param string $session_data session data 
80.     * @return integer 
81.     */ 
82.     public function write($session_id, $session_data) { 
83.         $query = "SELECT value FROM {$this->_sessionTable} WHERE sid = '{$session_id}' AND UNIX_TIMESTAMP(expiration) + " . self::SESSION_EXPIRE . " > UNIX_TIMESTAMP(NOW())"; 
84.         $result = $this->_dbLink->query($query); 
85.         $result = $result->fetch_array(); 
86.         if(!emptyempty($result)) { 
87.             $result = $this->_dbLink->query("UPDATE {$this->_sessionTable} SET value = {$session_data} WHERE sid = {$session_id}"); 
88.         } 
89.         else{ 
90.             $result = $this->_dbLink->query("INSERT INTO {$this->_sessionTable} (sid, value) VALUES ('{$session_id}', '{$session_data}')"); 
91.         } 
92.         if($result){ 
93.             return 0; 
94.         } 
95.         else{ 
96.             return 1; 
97.         }       
98.     } 
99.     /** 
100.     * 销魂session 
101.     * @access public 
102.     * @param string $session_id session ID 
103.     * @return integer 
104.     */ 
105.     public function destroy($session_id) { 
106.         $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE sid = '{$session_id}'"); 
107.         if($result){ 
108.             return 0; 
109.         } 
110.         else{ 
111.             return 1; 
112.         } 
113.     } 
114.     /** 
115.     * 垃圾回收 
116.     * @access public 
117.     * @param string $maxlifetime session 最长生存时间 
118.     * @return integer 
119.     */ 
120.     public function gc($maxlifetime) { 
121.         $result = $this->_dbLink->query("DELETE FROM {$this->_sessionTable} WHERE UNIX_TIMESTAMP(expiration) < UNIX_TIMESTAMP(NOW()) - " . self::SESSION_EXPIRE); 
122.         if($result){ 
123.             return 0; 
124.         } 
125.         else{ 
126.             return 1; 
127.         } 
128.     } 
129. } 
130. $dbLink = new mysqli("localhost", "root", "root", "test"); 
131. $sessionTable = "sessioninfo"; 
132. $handler = new MySessionHandler($dbLink, $sessionTable); 
133. session_set_save_handler($handler); 
134. session_start(); 
135. $_SESSION['name'] = "test"; 
136. echo $_SESSION["name"]; 
137. //session_destroy();

Tags: session存储数据库

分享到：