先看代码,通过<code>session_set_save_handler</code>机制可以实现一个自定义的会话机制,依赖于mysql数据库
<?php
$sdbc=NULL;
function open_session(){
global $sdbc;
$sdbc=mysqli_connect("localhost","root","root",'test');
if(mysqli_connect_errno($sdbc)){
return false;
}else{
return true;
}
}
function close_session(){
global $sdbc;
return mysqli_close($sdbc);
}
function read_session($sid){
global $sdbc;
$q=sprintf('SELECT * FROM session WHERE id="$s"',mysqli_real_escape_string($sdbc,$sid));
$r=mysqli_query($sdbc,$q);
if(mysqli_num_rows($r)==1){
list($data)=mysqli_fetch_array($r,MYSQLI_NUM);
return $data;
}else{
return"";
}
}
function write_session($sid,$data){
global $sdbc;
$q=sprintf('REPLACE INTO session (id,data) VALUE ("$s","%s")',mysqli_real_escape_string($sdbc,$sid),mysqli_real_escape_string($sdbc,$data));
$r=mysqli_query($sdbc,$q);
return true;
}
function destroy_session($sid){
global $sdbc;
$q=sprintf('DELETE FROM session WHERE id="%s"',mysqli_real_escape_string($sdbc,$sid));
$r=mysqli_query($sdbc,$q);
$_SESSION=array();
}
function clean_session($expire){
global $sdbc;
$q=sprintf('DELETE FROM session WHERE DATE_ADD(last_accessed,INTERVAL $d SECOND )<NOW()0',(int)$expire);
$r=mysqli_query($sdbc,$q);
return true;
}
session_set_save_handler('open_session','close_session','read_session','write_session','destroy_session','clean_session');
session_start();
代码解释:
(1)<code>mysqli_connect</code>打开一个连接掉mysql数据库的连接,语法:<code>mysqli_connect('localhost','username','password','tablename')</code>
(2)<code>mysqli_connect_errno</code>返回上一次错误链接的错误代码。
(3)<code>sprintf</code>把其中的<code>%</code>换成一个作为参数传递的参数。
(4)<code>mysqli_query</code>针对mysql数据库进行操作,mysqli_query(database,query)。
(5)<code>mysqli_num_rows</code>返回结果集中行的数量。
(6)<code>mysqli_fetch_array</code>从结果中取得一行作为结果。
(7)<code>mysqli_real_escape_string</code>函数转义在 SQL 语句中使用的字符串中的特殊字符。语法:<code>myaqli_real_escape_string(database,word)</code>
(9)session_set_save_handler设置用户自定义会话存储函数。