使用mysql保存session，并建立在线用户列表

作者 : admin 于 2008年08月15日, 23:02:21
2008
08-15

写OA，使用mysql存储session，这样，是为了获得在线用户的列表，为做一个web im做准备。

首先创建表,注，这里使用了adodb中数据字典的描述方法：

  1. $Session_Fields = "
  2. session_id VARCHAR(100) NOTNULL,
  3. session_value X DEFAULT '',
  4. session_expires I(10) DEFAULT NULL,
  5. userid I(5) DEFAULT NULL
  6. ";
  7. $Session_Tables = array('mysql' => "ENGINE = MYISAM CHARACTER SET utf8 COLLATE utf8_unicode_ci COMMENT = 'session表'");
  8. $dict = NewDataDictionary(GetDB());
  9. $sqlarray = $dict->CreateTableSQL($_CFG['table']['session'], $Session_Fields, $Session_Tables);
  10. $dict->ExecuteSQLArray($sqlarray);

然后session类:

  1. <?php
  2. /*  Session.Class.php
  3.  *  Session Manager
  4.  *  @link        http://www.sunboyu.cn
  5.  *  @package     OA
  6.  *  @version     V1.0
  7.  *
  8.  *  2008 08 14  sunboyu@gmail.com
  9.  */
  10. class Session
  11. {
  12. var $lifetime;
  13. var $db = null;
  14. function __construct()
  15. {
  16. #return adodb lite connetction
  17. $this->db = GetDB();
  18. }
  19. #open
  20. function open( $savepath , $session_name )
  21. {
  22. $this->lifetime =  get_cfg_var("session.gc_maxlifetime");
  23. return true;
  24. }
  25. #close
  26. function close()
  27. {
  28. return true;
  29. }
  30. #read
  31. function read( $session_id )
  32. {
  33. global $_CFG;
  34. $sql = sprintf("SELECT * FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  35. $rs = $this->db->Execute( $sql );
  36. if($rs->RecordCount()>0)
  37. {
  38. $result = $rs->fields;
  40. return $result['session_value'];
  41. }
  42. else
  43. {
  44. return null;
  45. }
  46. }
  47. #write
  48. function write( $session_id , $session_value )
  49. {
  50. global $_CFG;
  51. $sql = sprintf("SELECT session_id FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  52. $rs = $this->db->Execute( $sql );
  53. if($rs->RecordCount()==0)
  54. {
  55. $newsql = sprintf("INSERT INTO %s SET session_id = %s , session_value = %s , session_expires = %d",
  56. $_CFG['table']['session'],
  57. GetSqlString( $session_id ),
  58. GetSqlString( $session_value ),
  59. GetSqlString( $this->lifetime+time() , "int" ));
  60. }
  61. else
  62. {
  63. $newsql = sprintf("UPDATE %s SET session_value = %s , session_expires = %d WHERE session_id = %s",
  64. $_CFG['table']['session'],
  65. GetSqlString( $session_value ),
  66. GetSqlString( $this->lifetime+time() , "int" ),
  67. GetSqlString( $session_id ));
  68. }
  69. return $this->db->Execute( $newsql );
  70. }
  71. #destroy
  72. function destroy( $session_id )
  73. {
  74. global $_CFG;
  75. $delsql = sprintf("DELETE FROM %s WHERE session_id = %s",$_CFG['table']['session'],GetSqlString( $session_id ));
  76. return $this->db->Execute( $delsql );
  77. }
  78. #gc
  79. function gc()
  80. {
  81. global $_CFG;
  82. $gcsql = sprintf("DELETE FROM %s WHERE session_expires < %d",$_CFG['table']['session'],time());
  83. return $this->db->Execute( $gcsql );
  84. }
  85. }
  86. ?>

session机制，之前已经介绍，实现代码如下

  1. $session = new Session();
  2. session_set_save_handler(array(&$session,"open"),
  3. array(&$session,"close"),
  4. array(&$session,"read"),
  5. array(&$session,"write"),
  6. array(&$session,"destroy"),
  7. array(&$session,"gc"));
  8. session_start();

把session与用户id对应，使用以下语句即可

  1. sprintf("UPDATE %s SET userid = %d WHERE session_id = %s",$_CFG['table']['session'],GetSqlString($rs['id'],'int'),GetSqlString(session_id(),'text'))



    • 有事说事

      加入LAMP技术交流群
      点击添加好友
      点击和我聊天

      给我发信

      我也有UC的