程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> PHP綜合 >> PHP將session保存到MySQL數據庫中的代碼

PHP將session保存到MySQL數據庫中的代碼

編輯:PHP綜合
  PHP保存session默認的是采用的文件的方式來保存的,這僅僅在文件的空間開銷很小的windows上是可以采用的,但是如果我們采用 uinx或者是liux上的文件系統的時候,這樣的文件系統的文件空間開銷是很大的,然而session是要時時刻刻的使用的,大量的用戶就要創建很多的 session文件,這樣對整個的服務器帶來性能問題。
  另一方面,如果服務器起采用群集的方式的話就不能保持session的一致性,所以我們就緒要采用數據庫的方式來保存session,這樣,不管有幾台服務器同時使用,只要把他們的session保存在一台數據庫服務器上就可以保證 session的完整了,具體如何來實現請繼續看下去。
  PHP保存session默認的情況下是采用的文件方式來保存的,我們在PHP的配制文件PHP.ini中可以看到這樣的一行:session.save_handler="files"這樣的意思就是采用文件來保存session 的,要采用數據庫來保存的話,我們需要修改成用戶模式,改成session.save_handler="use"就可以了,但是,這僅僅是說明我門沒有采用文件的方式存儲session,我們還要選擇數據庫和建立數據庫的表。
  建立數據庫和數據庫的表結構,我們可以采用PHP可以使用的任何的數據庫,因為PHP和mysql的結合最好,我就使用mysql來做示例,當然根據你的需要可以改稱別的數據庫。
  創建數據庫create database 'session';創建表結構
  create table 'session'( id char(32) not null , 'user 'char(30), data char(3000) ,primary key ('id') );
  PHP保存session編寫PHP文件
  <?php
  $con = mysql_connect("127.0.0.1", "user" , "pass");
  mysql_select_db("session");
  function open($save_path, $session_name) {
  return(true);
  }
  function close() {
  return(true);
  }
  function read($id) {
  if ($result = mysql_query("select * from session where id='$id'")) {
  if ($row = mysql_felth_row($result)) {
  return $row["data"];
  }
  } else {
  return "";
  }
  }
  function write($id, $sess_data) {
  if ($result = mysql_query("update session set data='$sess_data' where id='$id'")) {
  return true;
  } else {
  return false;
  }
  }
  function destroy($id) {
  if ($result = mysql_query("delete * from session where id='$id'")) {
  return true;
  } else {
  return false;
  }
  }
  function gc($maxlifetime) {
  return true;
  }
  session_set_save_handler("open", "close", "read", "write", "destroy", "gc");
  session_start();
  // proceed to use sessions normally
  保存成為session_user_start.php。
  現在我們的PHP保存session的工作就已經完成了,只要你在需要在使用session的時候,把session_user_start.php包含進來.
  注意,這個文件一定要在文件的第一行包含,然後就像使用文件的session一樣的方法使用就可以了。
  以上僅僅是個簡單教程,在實際的應用中,可以對它封裝得更專業些,參考代碼如下:
  SessionMysql.class.php
  <?php
  /**
  * SessionMysql 數據庫存儲類
  */
  defined('IN_QIAN') or exit('Access Denied');
  class SessionMysql {
  public $lifetime = 1800; // 有效期,單位:秒(s),默認30分鐘
  public $db;
  public $table;
  /**
  * 構造函數
  */
  public function __construct() {
  $this->db = Base::loadModel('SessionModel');
  $this->lifetime = Base::loadConfig('system', 'session_lifetime');
  session_set_save_handler(
  array(&$this, 'open'), // 在運行session_start()時執行
  array(&$this, 'close'), // 在腳本執行完成 或 調用session_write_close() 或 session_destroy()時被執行,即在所有session操作完後被執行
  array(&$this, 'read'), // 在運行session_start()時執行,因為在session_start時,會去read當前session數據
  array(&$this, 'write'), // 此方法在腳本結束和使用session_write_close()強制提交SESSION數據時執行
  array(&$this, 'destroy'), // 在運行session_destroy()時執行
  array(&$this, 'gc') // 執行概率由session.gc_probability 和 session.gc_divisor的值決定,時機是在open,read之後,session_start會相繼執行open,read和gc
  );
  session_start(); // 這也是必須的,打開session,必須在session_set_save_handler後面執行
  }
  /**
  * session_set_save_handler open方法
  *
  * @param $savePath
  * @param $sessionName
  * @return true
  */
  public function open($savePath, $sessionName) {
  return true;
  }
  /**
  * session_set_save_handler close方法
  *
  * @return bool
  */
  public function close() {
  return $this->gc($this->lifetime);
  }
  /**
  * 讀取session_id
  *
  * session_set_save_handler read方法
  * @return string 讀取session_id
  */
  public function read($sessionId) {
  $condition = array(
  'where' => array(
  'session_id' => $sessionId
  ),
  'fields' => 'data'
  );
  $row = $this->db->fetchFirst($condition);
  return $row ? $row['data'] : '';
  }
  /**
  * 寫入session_id 的值
  *
  * @param $sessionId 會話ID
  * @param $data 值
  * @return mixed query 執行結果
  */
  public function write($sessionId, $data) {
  $userId = isset($_SESSION['userId']) ? $_SESSION['userId'] : 0;
  $roleId = isset($_SESSION['roleId']) ? $_SESSION['roleId'] : 0;
  $grouId = isset($_SESSION['grouId']) ? $_SESSION['grouId'] : 0;
  $m = defined('ROUTE_M') ? ROUTE_M : '';
  $c = defined('ROUTE_C') ? ROUTE_C : '';
  $a = defined('ROUTE_A') ? ROUTE_A : '';
  if (strlen($data) > 255) {
  $data = '';
  }
  $ip = get_ip();
  $sessionData = array(
  'session_id' => $sessionId,
  'user_id' => $userId,
  'ip' => $ip,
  'last_visit' => SYS_TIME,
  'role_id' => $roleId,
  'group_id' => $grouId,
  'm' => $m,
  'c' => $c,
  'a' => $a,
  'data' => $data,
  );
  return $this->db->insert($sessionData, 1, 1);
  }
  /**
  * 刪除指定的session_id
  *
  * @param string $sessionId 會話ID
  * @return bool
  */
  public function destroy($sessionId) {
  return $this->db->delete(array('session_id' => $sessionId));
  }
  /**
  * 刪除過期的 session
  *
  * @param $lifetime session有效期(單位:秒)
  * @return bool
  */
  public function gc($lifetime) {
  $expireTime = SYS_TIME - $lifetime;
  return $this->db->delete("`last_visit`<$expireTime");
  }
  }
  在系統文件的某個地方,實例化這個類即可!
  new SessionMysql(); *
  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved