php实现将Session写入数据库

这篇文章主要介绍了php实现将Session写入数据库的相关资料,需要的朋友可以参考下

使用session_set_save_handler()函数，将Session的内容写入数据库

1. <?php 
2. /* 
3. *@author Fahy 
4. *数据库为mysql， 
5. *数据库名为session，表名为session， 
6. *表中字段包括PHPSESSID,update_time,client_ip,data 
7. */ 
8. class Session{ 
9. private static $handler = null; 
10. private static $ip = null; 
11. private static $lifetime = null; 
12. private static $time = null; 
13.  
14. //配置静态变量 
15. private static function init($handler){ 
16. self::$handler = $handler; //获取数据库资源 
17. self::$ip = !empty($_SERVER["REMOTE_ADDR"])? $_SERVER["REMOTE_ADDR"]:'unkonw'; //获取客户端ip 
18. self::$lifetime = ini_get('session.gc_maxlifetime'); //获取session生命周期 
19. self::$time = time(); //获取当前时间 
20. } 
21. //调用session_set_save_handler()函数并开启session 
22. static function start($pdo){ 
23. self::init($pdo); 
24. session_set_save_handler( 
25. array(__CLASS__,'open'), 
26. array(__CLASS__,'close'), 
27. array(__CLASS__,'read'), 
28. array(__CLASS__,'write'), 
29. array(__CLASS__,'destroy'), 
30. array(__CLASS__,'gc') 
31. ); 
32. session_start(); 
33. } 
34.  
35. public static function open($path,$name){ 
36. return true; 
37. } 
38. public static function close(){ 
39. return true; 
40. } 
41.  
42. //查询数据库中的数据 
43. public static function read($PHPSESSID){ 
44. $sql = "select PHPSESSID,update_time,client_ip,data from session where PHPSESSID=?"; 
45. $stmt = self::$handler->prepare($sql); 
46. $stmt->execute(array($PHPSESSID)); 
47. if(!$result = $stmt->fetch(PDO::FETCH_ASSOC)){ 
48. return ''; 
49. } 
50. if(self::$ip == $result['client_ip']){ 
51. self::destroy($PHPSESSID); 
52. return ''; 
53. } 
54. if(($result['update_time']+self::$lifetime)<self::$time){ 
55. self::destroy($PHPSESSID); 
56. return ''; 
57. } 
58. return $result['data']; 
59. } 
60. /* 
61. *首先查询该session是否存在数据，如果存在，则更新数据，如果不存在，则插入数据 
62. */ 
63. //将session写入数据库中，$data传入session中的keys和values数组 
64. public static function write($PHPSESSID,$data){ 
65. $sql = "select PHPSESSID,update_time,client_ip,data from session where PHPSESSID=?"; 
66. $stmt = self::$handler->prepare($sql); 
67. $stmt->execute(array($PHPSESSID)); 
68.  
69. if($result=$stmt->fetch(PDO::FETCH_ASSOC)){  
70. if($result['data'] != $data || self::$time > ($result['update_time']+30)){ 
71. $sql = "update session set update_time=?,data=? where PHPSESSID = ?"; 
72. $stmt = self::$handler->prepare($sql); 
73. $stmt->execute(array($self::$time,$data,$PHPSESSID)); 
74. } 
75. }else{ 
76. if(!empty($data)){ 
77. try{ 
78. $sql = "insert into session(PHPSESSID,update_time,client_ip,data) values(?,?,?,?)"; 
79. }catch(PDOException $e){ 
80. echo $e->getMessage(); 
81. } 
82. $sth = self::$handler->prepare($sql); 
83. $sth->execute(array($PHPSESSID,self::$time,self::$ip,$data)); 
84. } 
85. } 
86. return true; 
87. } 
88.  
89. public static function destroy($PHPSESSID){ 
90. $sql = "delete from session where PHPSESSID = ?"; 
91. $stmt = self::$handler->prepare($sql); 
92. $stmt->execute(array($PHPSESSID)); 
93. return true; 
94. } 
95. public static function gc($lifetime){ 
96. $sql = "delete from session where update_time<?"; 
97. $stmt = self::$handler->prepare($sql); 
98. $stmt->execute(array(self::$time-$lifetime)); 
99. return true; 
100. } 
101. } 
102. //使用PDO连接数据库 
103. try{ 
104. $pdo = new PDO("mysql:host=localhost;dbname=session","root","hwj193"); 
105. }catch(PDOException $e){ 
106. echo $e->getMessage(); 
107. } 
108. //传递数据库资源 
109. Session::start($pdo); 

以上所述就是本文的全部内容了，希望大家能够喜欢。