网站地图    收藏   

主页 > php专栏 > php会话 >

php怎么把session保存到MySql数据库中 - php会话

来源:自学PHP网    时间:2014-11-27 20:45 作者: 阅读:

[导读] session我们多半是保存在服务器中,但是今天有一个功能就是需要把session保存在数据库中,这样可以实现同ie多浏览了,php中session默认的存储方式是硬盘,php也可以改变默认的存储方式,主要使...

php怎么把session保存到MySql数据库中

session我们多半是保存在服务器中,但是今天有一个功能就是需要把session保存在数据库中,这样可以实现同ie多浏览了,php中session默认的存储方式是硬盘,php也可以改变默认的存储方式,主要使用到session_set_save_handler方法,下面分享下如何将session保存到MySql数据库中的具体代码.

1.建session表,代码如下:

  1. CREATE TABLE `session` ( 
  2.   `sessionid` varchar(128) NOT NULL, 
  3.   `uid` int(11) NOT NULL, 
  4.   `data` mediumblob NOT NULL, 
  5.   `timestamp` int(11) NOT NULL, 
  6.   `ip` varchar(15) NOT NULL, 
  7.   PRIMARY KEY  (`sessionid`), 
  8.   KEY `time_session` (`timestamp`,`sessionid`) 
  9. ) ENGINE=MyISAM DEFAULT CHARSET=utf8; 
  10. //uid 是保留字段 

2.自定义session类,代码如下:

  1. <?php 
  2. class CustomSession{ 
  3.  private static $db_host="localhost"
  4.  private static $db_user="root"
  5.  private static $db_password=""
  6.  private static $database="session"
  7.  
  8.  private $conn
  9.  
  10.  public static function getInstance(){ 
  11.   static $instance=null; 
  12.   if($instance==null){ 
  13.    $instance=new CustomSession(); 
  14.   } 
  15.  
  16.   return $instance
  17.  } 
  18.  
  19.  public function __construct(){ 
  20.   session_set_save_handler( 
  21.   array($this,"open"), 
  22.   array($this,"close"), 
  23.   array($this,"read"), 
  24.   array($this,"write"), 
  25.   array($this,"destroy"), 
  26.   array($this,"gc"
  27.   ); 
  28.  } 
  29.  
  30.  public function __destruct(){ 
  31.   session_write_close(); 
  32.  } 
  33.  
  34.  public function open(){ 
  35.   $this->conn=mysql_connect(CustomSession::$db_host,CustomSession::$db_user,CustomSession::$db_password); 
  36.   mysql_select_db(CustomSession::$database,$this->conn); 
  37.  } 
  38.  
  39.  public function close(){ 
  40.  
  41.   mysql_close($this->conn); 
  42.  } 
  43.  
  44.  public function read($id){ 
  45.   $escaped_id=mysql_escape_string($id); 
  46.   $res=$this->query("select * from `session` where `sessionid`='$escaped_id'"); 
  47.   if($row=mysql_fetch_assoc($res)){ 
  48.    $this->query("update `session` set `timetamp`=UTC_TIMESTAMP() where `sessionid`='$escaped_id'"); 
  49.    return $row['data']; 
  50.   } 
  51.   return ""
  52.  } 
  53.  
  54.  public function write($id,$data){ 
  55.   $query="replace into `session` (`sessionid`,`data`,`ip`,`timestamp`) values ('%s','%s','%s',UNIX_TIMESTAMP(UTC_TIMESTAMP()))"
  56.   $this->query(sprintf($query,mysql_escape_string($id),mysql_escape_string($data),$_SERVER["REMOTE_ADDR"])); 
  57.  } 
  58.  
  59.  public function destroy($id){ 
  60.   $escaped_id=mysql_escape_string($id); 
  61.   $res=$this->query("delete from `session` where `id`='$escaped_id'"); 
  62.   return (mysql_affected_rows($res)==1); 
  63.  } 
  64.  
  65.  public function gc($lifetime){ 
  66.   $this->query("delete from `session` where UNIX_TIMESTAMP(UTC_TIMESTAMP())-`timestamp` > $lifetime"); 
  67.  } 
  68.  
  69.  public function query($query){ 
  70.   $res=mysql_query($query,$this->conn); 
  71.   return $res
  72.  } 
  73.  
  74. ?> 

3.测试程序,代码如下:

  1. <?php 
  2. include('./CustomSession.class.php'); 
  3. CustomSession::getInstance(); 
  4. session_start(); 
  5. $_SESSION['username']='feng'
  6. print_r($_SESSION); 
  7. ?> 

运行测试程序后,查看数据库可以发现session表中已经增加了session记录.

自学PHP网专注网站建设学习,PHP程序学习,平面设计学习,以及操作系统学习

京ICP备14009008号-1@版权所有www.zixuephp.com

网站声明:本站所有视频,教程都由网友上传,站长收集和分享给大家学习使用,如由牵扯版权问题请联系站长邮箱904561283@qq.com

添加评论