php Session保存到数据库的类

3. //用数据库保存session信息

4. class SessionToDB
5. {
6. private $_path = null;
7. private $_name = null;
8. private $_pdo = null;
9. private $_ip = null;
10. private $_maxLifeTime = 0;

11. public function __construct(PDO $pdo)

12. {
13. session_set_save_handler(
14. array(&$this, 'open'),
15. array(&$this, 'close'),
16. array(&$this, 'read'),
17. array(&$this, 'write'),
18. array(&$this, 'destroy'),
19. array(&$this, 'gc')
20. );

21. $this->_pdo = $pdo;

22. $this->_ip = !empty($_SERVER['REMOTE_ADDR']) ? $_SERVER['REMOTE_ADDR'] : null;
23. $this->_maxLifeTime = ini_get('session.gc_maxlifetime');
24. }

25. public function open($path,$name)

26. {
27. return true;
28. }

29. public function close()

30. {
31. return true;
32. }

33. public function read($id)

34. {
35. $sql = 'SELECT * FROM session where PHPSESSID = ?';
36. $stmt = $this->_pdo->prepare($sql);
37. $stmt->execute(array($id));

38. if (!$result = $stmt->fetch(PDO::FETCH_ASSOC)) {

39. return null;
40. } elseif ($this->_ip != $result['client_ip']) {
41. return null;
42. } elseif ($result['update_time']+$this->_maxLifeTime $this->destroy($id);
43. return null;
44. } else {
45. return $result['data'];
46. }
47. } //by bbs.it-home.org

48. public function write($id,$data)

49. {
50. $sql = 'SELECT * FROM session where PHPSESSID = ?';
51. $stmt = $this->_pdo->prepare($sql);
52. $stmt->execute(array($id));

53. if ($result = $stmt->fetch(PDO::FETCH_ASSOC)) {

54. if ($result['data'] != $data) {
55. $sql = 'UPDATE session SET update_time =? , date = ? WHERE PHPSESSID = ?';

56. $stmt = $this->_pdo->prepare($sql);

57. $stmt->execute(array(time(), $data, $id));
58. }
59. } else {
60. if (!empty($data)) {
61. $sql = 'INSERT INTO session (PHPSESSID, update_time, client_ip, data) VALUES (?,?,?,?)';
62. $stmt = $this->_pdo->prepare($sql);
63. $stmt->execute(array($id, time(), $this->_ip, $data));
64. }
65. }

66. return true;

67. }

68. public function destroy($id)

69. {
70. $sql = 'DELETE FROM session WHERE PHPSESSID = ?';
71. $stmt = $this->_pdo->prepare($sql);
72. $stmt->execute(array($id));

73. return true;

74. }

75. public function gc($maxLifeTime)

76. {
77. $sql = 'DELETE FROM session WHERE update_time $stmt = $this->_pdo->prepare($sql);
78. $stmt->execute(array(time() - $maxLifeTime));

79. return true;

80. }
81. }

82. try{

83. $pdo = new PDO('mysql:host=localhost;dbname=rphp4zf', 'root','rickyfeng');
84. $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

85. new SessionToDB($pdo);

86. } catch(PDOException $e) {
87. echo 'Error: '.$e->getMessage();
88. }

复制代码