php使用mysql数据库存储session的例子

2. CREATE TABLE `db_session` (
3. `sesskey` char(32) NOT NULL,
4. `expiry` int(11) unsigned NOT NULL,
5. `value` text NOT NULL,
6. PRIMARY KEY (`sesskey`)
7. ) ENGINE=InnoDB DEFAULT CHARSET=latin1;

复制代码

数据库表明：db_session 列名：sesskey，expiry，value　其中：sesskey为主键。 Value里面存放着session里面的值。

3.建立session_mysql.php文件。这个文件是用来构造保存session的方法的。修改一下参数直接使用就可以了。 session_mysql.php php代码:

2. $gb_DBname="db_myBBS";//数据库名称
3. $gb_DBuser="root";//数据库用户名称
4. $gb_DBpass="23928484";//数据库密码
5. $gb_DBHOSTname="localhost";//主机的名称或是IP地址
6. $SESS_DBH="";
7. $SESS_LIFE=get_cfg_var("session.gc_maxlifetime");//得到session的最大有效期。
8. function sess_open($save_path,$session_name){
9. global $gb_DBHOSTname,$gb_DBname,$gb_DBuser,$gb_DBpass,$SESS_DBH;
10. if(!$SESS_DBH=mysql_pconnect($gb_DBHOSTname,$gb_DBuser,$gb_DBpass)){
11. echo "
12. MySql Error:".mysql_error()."
13. ";
14. die();
15. }
16. if(!mysql_select_db($gb_DBname,$SESS_DBH)){
17. echo "
18. MySql Error:".mysql_error()."
19. ";
20. die();
21. }
22. return true;
23. }
24. function sess_close(){
25. return true;
26. }
27. function sess_read($key){
28. global $SESS_DBH,$SESS_LIFE;
29. $qry="select value from db_session where sesskey = '$key' and expiry > ".time();
30. $qid=mysql_query($qry,$SESS_DBH);
31. if(list($value)=mysql_fetch_row($qid)){
32. return $value;
33. }
34. return false;
35. }
36. function sess_write($key,$val){
37. global $SESS_DBH,$SESS_LIFE;
38. $expiry=time()+$SESS_LIFE;
39. $value=$val;
40. $qry="insert into db_session values('$key',$expiry,'$value')";
41. $qid=mysql_query($qry,$SESS_DBH);
42. if(!$qid){
43. $qry="update db_session set expiry=$expiry, value='$value' where sesskey='$key' and expiry >".time();
44. $qid=mysql_query($qry,$SESS_DBH);
45. }
46. return $qid;
47. }
48. function sess_destroy($key){
49. global $SESS_DBH;
50. $qry="delete from db_session where sesskey = '$key'";
51. $qid=mysql_query($qry,$SESS_DBH);
52. return $qid;
53. }
54. function sess_gc($maxlifetime){
55. global $SESS_DBH;
56. $qry="delete from db_session where expiry $qid=mysql_query($qry,$SESS_DBH);
57. return mysql_affected_rows($SESS_DBH);
58. }
59. session_module_name();
60. session_set_save_handler("sess_open","sess_close","sess_read","sess_write","sess_destroy","sess_gc");
61. ?>

复制代码

4.建立测试文件。 在使用之前必须引用刚刚建立的session_mysql.php文件。 文件：session_test.php

2. include ("session_mysql.php");
3. session_start();
4. $_SESSION['abc']= "A: I will be back!";
5. $_SESSION['meto']= "B: Me too ";
6. $_SESSION['name']= "louis ";
7. echo "click me";
8. ?>

复制代码

文件：get_session_test.php

2. include ("session_mysql.php");
3. session_start();
4. echo $_SESSION['abc'];
5. echo "
   ";
6. echo $_SESSION['meto'];
7. echo "
   ";
8. echo $_SESSION['name'];
9. $_SESSION['wq']="12e";
10. echo "
    click again";
11. ?>

复制代码

文件：get_session_test2.php

2. include ("session_mysql.php");
3. session_start();
4. echo $_SESSION['abc'];
5. echo "
   ";
6. echo $_SESSION['meto'];
7. echo "
   ";
8. echo $_SESSION['name'];
9. echo "
   ";
10. echo $_SESSION['wq'];
11. //session_destroy();//用来销毁所有session的函数。
12. ?>

复制代码