php使用MySQL保存session会话的方法

前端技术 2023/09/01 PHP

本文实例讲述了php使用MySQL保存session会话的方法。分享给大家供大家参考。具体分析如下：

在很多大的系统中一般都有这个功能，但是要分离出来分析，网上的资料也不太多 这里我整理了一篇发出来与大家分享

使用MySQL保存session会话较files有很多优点：

1) 有利于分布式系统，files只能保存在一台机器上
2) 有利于大访问量的系统，使用files时每个session保存在一个文件中，目录会超级大，查找session文件会比较困难。

使用MySQL保存会话首先要创建session表：

<?php
$hostname_login = \"localhost\"; // Server address
$username_login = \"root\"; // User name 
$password_login = \"\"; // Password
//
$data_name = \"session\"; // Database name
$login = mysql_pconnect($hostname_login, $username_login, $password_login) or trigger_error(mysql_error(),E_USER_ERROR); 
$sql=\"SHOW DATABASES LIKE \'\".$data_name.\"\'\"; // If it is exist
if($rs_table=mysql_query($sql,$login)) { 
  if($rs_value=mysql_fetch_array($rs_table)) { 
   echo \"数据库已经存在！\\n!\";
   exit(); 
  } 
}
$sql=\"CREATE DATABASE $data_name\";   
mysql_query($sql); // Crate database
echo \"数据库创建成功！\\n\"; 
mysql_select_db($data_name, $login);
$sql=\"CREATE TABLE `sessions` ( 
`SessionKey` varchar(32) NOT NULL default \'\', 
`SessionArray` blob NOT NULL, 
`SessionExpTime` int(20) unsigned NOT NULL default \'0\', 
PRIMARY KEY (`SessionKey`), 
KEY `SessionKey` (`SessionKey`) 
) ENGINE=MyISAM DEFAULT CHARSET=utf8\"; //新建数据库 sql语句
mysql_query($sql);
echo \"成功新建数据库表！\";
?>

MysqlSession 类如下：

<?php  
class MysqlSession {
// 注意在有使用Session的页面。页面一定要顶格，页面开始处不能留空。
private $DB_SERVER = \"localhost\"; // 数据库服务器主机名
  private $DB_NAME = \"\"; // 数据库名字
  private $DB_USER = \"root\"; // MYSQL 数据库访问用户名 
  private $DB_PASS = \"\"; // MYSQL 数据库访问密码 
   
  private $DB_SELECT_DB = \"\"; 
//private $SESS_LIFE = 1440; // Session的最大使用时长，单位秒。
private $SESS_LIFE = 0;
function MysqlSession (&$sessionDB) {
  //session_write_close();
  $this->DB_NAME = &$sessionDB;
  $this->SESS_LIFE = get_cfg_var(\"session.gc_maxlifetime\");
  session_module_name(\'user\');
  session_set_save_handler( 
  array(&$this, \'sess_open\'), 
  array(&$this, \'sess_close\'), 
  array(&$this, \'sess_read\'), 
  array(&$this, \'sess_write\'), 
  array(&$this, \'sess_destroy\'), 
  array(&$this, \'sess_gc\') 
  );
  session_start();
}
function sess_open($save_path, $session_name){  // 打开数据库连接
  if (! $this->DB_SELECT_DB = mysql_pconnect($this->DB_SERVER, $this->DB_USER, $this->DB_PASS)) { 
  echo \"SORRY! MYSQL ERROR : Can\'t connect to $this->DB_SERVER as $DB_USER\"; 
  echo \"MySQL Error: \", mysql_error(); 
  die; 
  } 
  if (! mysql_select_db($this->DB_NAME, $this->DB_SELECT_DB)) { 
  echo \"SORRY! MYSQL ERROR : Unable to select database $this->DB_NAME\"; 
  die; 
  } 
  return true; 
} 
function sess_close() { 
    return true; 
} 
function sess_read($SessionKey){  
    $Query = \"SELECT SessionArray FROM sessions WHERE SessionKey = \'\".$SessionKey.\"\' AND SessionExpTime > \" . time();
    // 过期不读取。
    $Result = mysql_query($Query, $this->DB_SELECT_DB); 
  if (list($SessionArray) = mysql_fetch_row($Result)) { 
     return $SessionArray; 
  } 
  return false; 
} 
function sess_write($SessionKey, $VArray) { 
  $SessionExpTime = time() + $this->SESS_LIFE;
  // 更新Session过期时间，Session过期时间 = 最后一次更新时间 + Session的最大使用时长
  $SessionArray = addslashes($VArray); 
  $Query = \"INSERT INTO sessions (SessionKey,SessionExpTime,SessionArray) VALUES (\'\".$SessionKey.\"\',\'\".$SessionExpTime.\"\',\'\".$SessionArray.\"\')\"; 
  $Result = mysql_query($Query, $this->DB_SELECT_DB); 
  if (!$Result){ 
      $Query = \"UPDATE sessions SET SessionExpTime = \'\".$SessionExpTime.\"\', SessionArray = \'\".$SessionArray.\"\' WHERE SessionKey = \'\".$SessionKey.\"\' AND  SessionExpTime > \" . time(); 
      $Result = mysql_query($Query, $this->DB_SELECT_DB); 
  }  
  return $Result; 
} 
function sess_destroy($SessionKey) { 
  $Query = \"DELETE FROM sessions WHERE SessionKey = \'\".$SessionKey.\"\'\"; 
  $Result = mysql_query($Query, $this->DB_SELECT_DB); 
  return $Result; 
} 
function sess_gc($maxlifetime) {
// 这个垃圾清除器系统调用。默认是1440秒清除一次。
//参数可以在PHP.ini里面设置。
  $Query = \"DELETE FROM sessions WHERE SessionExpTime < \" . time(); 
  $Result = mysql_query($Query, $this->DB_SELECT_DB); 
  return mysql_affected_rows($this->DB_SELECT_DB); 
} 
}
?>

用法：在原来使用 session_start 的地方，替换成 $session = new MysqlSession ()

注意：包含此程序前要打开数据库，主程序退出前不能关闭数据库，否则会出错。

希望本文所述对大家的php程序设计有所帮助。

本文地址：https://www.stayed.cn/item/2279

转载请注明出处。

本站部分内容来源于网络,如侵犯到您的权益,请 联系我

我的博客

人生若只如初见，何事秋风悲画扇。

我的标签

随笔档案