1. 程式人生 > >php之將用戶信息寫入數據庫

php之將用戶信息寫入數據庫

顯示 更新 post blog 鏈接 -m .net 靜態 延遲

session高級應用將用戶信息寫入到數據庫中

首先建立數據庫表

在實驗數據庫sqldb中建立session表,用於存儲數據

技術分享


在根文件夾下建立須要用到的文件(重點是session,class.php這個類文件。包括列一些方法)

技術分享

在session.class.php中主要用到的是session_set_save_handler()這種方法。借助PDO進行數據操作。用類編寫寫入數據庫表中,

類中定義了一些靜態方法,其屬性也要為靜態的,這樣session的數據就直接寫入數據庫中,而不是保存在本地目錄中

首先建立一個Session類。類中首先定義一些私有靜態的屬性。定義了ip。生存時間和時間

<?php
	//定義session類
    class Session{
    	private static $handler=null;
    	private static $ip=null;
    	private static $lifetime=null;
    	private static $time=null;

private static function init($handler){
    		self::$handler=$handler; //代表PDO的鏈接
    		//ip先推斷不為空
    		self::$ip=!empty($_SERVER["REMOTE_ADDR"])? $_SERVER["REMOTE_ADDR"] : ‘unkown‘;
    		//從配置文件取出生存時間
    		self::$lifetime=ini_get(‘session.gc_maxlifetime‘);
    		self::$time=time();
    	}

接下來就是定義開啟session的方法

//定義開啟session的方法
static function start(PDO $pdo){
    	self::init($pdo);  //初始化私有方法
    	session_set_save_handler(
    		array(__CLASS__,"open"),
    		array(__CLASS__,"close"),
    		array(__CLASS__,"read"),
    		array(__CLASS__,"write"),
    		array(__CLASS__,"destroy"),
    		array(__CLASS__,"gc")
    		);
    	session_start();
}


在開啟session中有open, close, read, write, destory, gc 的方法。以下主要是定義出這些方法

open() 和 close() 方法

public static function open($path, $name){
    return true;
}
public static function close(){
    return true;
}

在定義這些方法時,最重要的是write() 和 read() 方法,由於這是直接從數據庫讀出或寫入,採用PDO數據庫預處理方式

read():先進行PDO預處理。然後在獲取的一條記錄中,要推斷ip是否為數據庫中的ip,取出的數據是否已經過期,都不是就成功讀出

    public static function read($PHPSESSID){
    	$sql="select PHPSESSID,update_time,client_ip,data from session where PHPSESSID= ?"; //用?參數
    	//PDO預處理
    	$stmt=self::$handler->prepare($sql);
    	$stmt->execute(array($PHPSESSID));
    	//獲取一條記錄
    	if(!$result=$stmt->fetch(PDO::FETCH_ASSOC)){
    		return ‘‘;
    	}
    	//推斷當前訪問ip是否為數據庫存在的ip
    	if(self::$ip != $result["client_ip"]){
    		self::destroy($PHPSESSID);  //銷毀用戶
    		return ‘‘;
    	}
    	//推斷是不是過期的
    	if(($result["update_time"] + self::$lifetime) < self::$time){
    		self::destroy($PHPSESSID);
    		return ‘‘;
    	}
    	return $result[‘data‘];  //成功讀出
    }


write():相同寫入的方法也比較重要,須要推斷傳進來的數據是否為空,假設為空就不進行插入

    public static function write($PHPSESSID, $data){
    	$sql="select PHPSESSID,update_time,client_ip,data from session where PHPSESSID= ?

"; $stmt=self::$handler->prepare($sql); $stmt->execute(array($PHPSESSID)); if($result=$stmt->fetch(PDO::FETCH_ASSOC)){ //延遲30更新 if($result[‘data‘] != $data || self::$time > ($result[‘update_time‘]+30)){ //更新數據語句 $sql="uptate session set update_time=?, data=?

where PHPSESSID=?"; $stm=self::$handler->prepare($sql); $stm->execute(array(self::$time, $data, $PHPSESSID)); } }else{ //推斷傳進來的數據是否為空。空時不插入 if(!empty($data)){ $sql="insert into session(PHPSESSID,update_time,client_ip,data) values(?

,?,?,?

)"; //插入值用?

參數 $sth=self::$handler->prepare($sql); $sth->execute(array($PHPSESSID,self::$time,self::$ip,$data)); //必須用數組 } } return true; }


接下來就是數據的銷毀

相同 destory() 和 gc()

destory():數據刪除

gc():垃圾回收

    public static function destroy($PHPSESSID){
    	$sql="delete from session where PHPSESSID=?

"; $stmt=self::$handler->prepare($sql); $stmt->execute(array($PHPSESSID)); return true; } private static function gc($lifetime){ $sql="delete from session where update_time < ?

"; $stmt=self::$handler->prepare($sql); $stmt->execute(array(self::$time-$lifetime)); return true; } }


最後就拋出一個異常並調用session類

    try{
    	$pdo=new PDO("mysql:host=localhost;dbname=sqldb","root","heyifeng19930924");
    }catch(PDOException $e){
    	echo $e->getMessage();
    }

    //調用session類
    Session::start($pdo);


在測試文件裏。寫法和session高級使用方法(即上一篇博客的測試文件)一樣

僅僅是在包括文件裏包括這個類文件

即:include"session.class.php";



測試結果,假設插入數據成功,查詢表格信息,在數據庫中顯示:

技術分享

即傳遞列PHPSESSID的值


刪除撤銷後。查詢表格顯示

技術分享

即撤銷了PHPSESSID的值













php之將用戶信息寫入數據庫