php把session写入数据库的类

3. class session_handler {

4. protected $maxlifetime = null;

5. protected $dbHandle = null;
6. public $config = null;

7. public static function init($args) {

8. return new self($args);
9. }

10. public function __construct($args) {

11. $this->config = $args;

12. $this->maxlifetime = get_cfg_var("session.gc_maxlifetime");
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. public function open() {

22. $this->link = mysqli_connect(
23. $this->config['host'],
24. $this->config['user'],
25. $this->config['password'],
26. $this->config['database']);
27. mysqli_set_charset($this->link, "utf8");
28. $sql = 'CREATE TABLE IF NOT EXISTS `%s` (
29. `session_id` varchar(255) NOT NULL,
30. `session_data` text,
31. `session_expires` char(10) NOT NULL,
32. PRIMARY KEY (`session_id`)
33. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;';
34. $sql = sprintf($sql, $this->config['table']);
35. mysqli_query($this->link, $sql);
36. return true;
37. }

38. public function close() {

39. return true;
40. }

41. public function read($session_id) {

42. if(empty($session_id)) return null;

43. $sql = 'SELECT `session_data` AS `data` FROM `%s` WHERE `session_id` = "%s" AND `session_expires` > "%u"';

44. $sql = sprintf($sql,
45. mysqli_real_escape_string($this->link, $this->config['table']),
46. mysqli_real_escape_string($this->link, $session_id),
47. time());

48. $result = mysqli_query($this->link, $sql);

49. $row = mysqli_fetch_assoc($result);
50. return $row['data'];
51. }

52. public function write($session_id, $session_data) {

53. if(empty($session_id)) return null;

54. $newExpires = time() + $this->maxlifetime;

55. $sql = 'REPLACE INTO `%s` SET `session_id` = "%s", `session_data` = "%s", `session_expires` = "%u"';
56. $sql = sprintf($sql,
57. mysqli_real_escape_string($this->link, $this->config['table']),
58. mysqli_real_escape_string($this->link, $session_id),
59. mysqli_real_escape_string($this->link, $session_data),
60. $newExpires);

61. $result = mysqli_query($this->link, $sql);

62. return mysqli_affected_rows($this->link);
63. }

64. public function destroy($session_id) {

65. $sql = 'DELETE FROM `%s` WHERE `session_id` = "%s"';
66. $sql = sprintf($sql,
67. mysqli_real_escape_string($this->link, $this->config['table']),
68. mysqli_real_escape_string($this->link, $session_id));
69. $result = mysqli_query($this->link, $sql);
70. return mysqli_affected_rows($this->link);
71. }

72. public function gc() {

73. $sql = 'DELETE FROM `%s` WHERE `session_expires` $sql = sprintf($sql,
74. mysqli_real_escape_string($this->link, $this->config['table']),
75. time());

76. $result = mysqli_query($this->link, $sql);

77. return mysqli_affected_rows($this->link);
78. }
79. }
80. class session {
81. public static $collection = null;

82. public static function open($clean = false, $token = false) {

83. if($clean) ob_end_clean();
84. if($token) session_id($token);
85. session_start();
86. self::$collection = $_SESSION;
87. }

88. public static function id() {

89. $num_args = func_num_args();
90. if($num_args) {
91. $args = func_get_arg(0);
92. return session_id($args);
93. }else{
94. return session_id();
95. }
96. }

97. public static function get($name) {

98. return isset($_SESSION[$name]) ? $_SESSION[$name] : null;
99. }

100. public static function set($name, $value) {

101. $_SESSION[$name] = $value;
102. return true;
103. }

104. public static function delete($name) {

105. if(!isset($_SESSION[$name])) return null;
106. unset($_SESSION[$name]);
107. return true;
108. }

109. public static function destroy() {

110. session_destroy();
111. }

112. }

113. $config = array(
114. "host"=> "127.0.0.1",
115. "user"=> "root",
116. "password"=> "123456",
117. "database"=> "test",
118. "charset"=> "utf8",
119. "table"=> "user_session");
120. session_handler::init($config);
121. session::open();
122. session::set("profile", array("id"=> 1, "user"=> "haowei", "vip-level"=> 6));

复制代码