Session保存到数据库

1. <?php 
2. class SessionToDB 
3. { 
4.     private $_path         = null; 
5.     private $_name         = null; 
6.     private $_pdo          = null; 
7.     private $_ip           = null; 
8.     private $_maxLifeTime  = 0; 
9.      
10.     public function __construct(PDO $pdo) 
11.     { 
12.         session_set_save_handler( 
13.             array(&$this, 'open'), 
14.             array(&$this, 'close'), 
15.             array(&$this, 'read'), 
16.             array(&$this, 'write'), 
17.             array(&$this, 'destroy'), 
18.             array(&$this, 'gc')                                                             
19.         ); 
20.          
21.         $this->_pdo   = $pdo; 
22.         $this->_ip    = !emptyempty($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : null; 
23.         $this->_maxLifeTime = ini_get('session.gc_maxlifetime'); 
24.     } 
25.      
26.     public function open($path,$name) 
27.     { 
28.         return true;     
29.     } 
30.      
31.     public function close() 
32.     { 
33.         return true; 
34.     } 
35.      
36.     public function read($id) 
37.     { 
38.         $sql = 'SELECT * FROM session where PHPSESSID = ?'; 
39.         $stmt = $this->_pdo->prepare($sql); 
40.         $stmt->execute(array($id)); 
41.          
42.         if (!$result = $stmt->fetch(PDO::FETCH_ASSOC)) { 
43.             return null; 
44.         } elseif ($this->_ip != $result['client_ip']) { 
45.             return null; 
46.         } elseif ($result['update_time']+$this->_maxLifeTime < time()){ 
47.             $this->destroy($id); 
48.             return null; 
49.         } else { 
50.             return $result['data'];     
51.         } 
52.     } 
53.      
54.     public function write($id,$data) 
55.     { 
56.         $sql = 'SELECT * FROM session where PHPSESSID = ?'; 
57.         $stmt = $this->_pdo->prepare($sql); 
58.         $stmt->execute(array($id)); 
59.          
60.         if ($result = $stmt->fetch(PDO::FETCH_ASSOC)) { 
61.             if ($result['data'] != $data) { 
62.                 $sql = 'UPDATE session SET update_time =? , date = ? WHERE PHPSESSID = ?'; 
63.                  
64.                 $stmt = $this->_pdo->prepare($sql); 
65.                 $stmt->execute(array(time(), $data, $id)); 
66.             } 
67.         } else { 
68.             if (!emptyempty($data)) { 
69.                 $sql = 'INSERT INTO session (PHPSESSID, update_time, client_ip, data) VALUES (?,?,?,?)'; 
70.                 $stmt = $this->_pdo->prepare($sql); 
71.                 $stmt->execute(array($id, time(), $this->_ip, $data)); 
72.             } 
73.         } 
74.          
75.         return true; 
76.     } 
77.      
78.     public function destroy($id) 
79.     { 
80.         $sql = 'DELETE FROM session WHERE PHPSESSID = ?'; 
81.         $stmt = $this->_pdo->prepare($sql); 
82.         $stmt->execute(array($id)); 
83.          
84.         return true;         
85.     } 
86.      
87.     public function gc($maxLifeTime) 
88.     { 
89.         $sql = 'DELETE FROM session WHERE update_time < ?'; 
90.         $stmt = $this->_pdo->prepare($sql); 
91.         $stmt->execute(array(time() - $maxLifeTime)); 
92.          
93.         return true; 
94.     } 
95. } 
96.  
97. try{ 
98.     $pdo = new PDO('mysql:host=localhost;dbname=rphp4zf', 'root','rickyfeng'); 
99.     $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); 
100.      
101.     new SessionToDB($pdo);     
102. } catch(PDOException $e) { 
103.     echo 'Error: '.$e->getMessage(); 
104. } 

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索数据库
session
php session 存数据库、java session 数据库、session存到数据库、数据库保存session、pdo数据库保存session，以便于您获取更多的相关知识。