php中session处理的定制

<?php
function mysession_open($save_path, $session_name)
{
	@mysql_connect("localhost", "root","1981427")				//选择数据库之前需要先连接数据库服务器
	or die("数据库服务器连接失败");
	@mysql_select_db("test")					//选择数据库mydb
	or die("数据库不存在或不可用");
	return true;
}

function mysession_close()
{
	return true;
}

function mysession_read($key)
{
	@mysql_connect("localhost", "root","1981427")				//选择数据库之前需要先连接数据库服务器
	or die("数据库服务器连接失败");
	@mysql_select_db("test")					//选择数据库mydb
	or die("数据库不存在或不可用");
	$expiry_time = time();						//获取Session失效时间
	//执行SQL语句获得Session的值
	$query = @mysql_query("select session_data from mysession "
	."where session_key = '$key' and session_expiry > $expiry_time")
	or die("SQL语句执行失败");
	if($row = mysql_fetch_array($query))
		return $row['session_data'];
	else
		return false;
}

function mysession_write($key, $data)
{
	@mysql_connect("localhost", "root","1981427")				//选择数据库之前需要先连接数据库服务器
	or die("数据库服务器连接失败");
	@mysql_select_db("test")					//选择数据库mydb
	or die("数据库不存在或不可用");
	$expiry_time = time() + 1200;						//获取Session失效时间
	//查询Session的键值是否已经存在
	$query = @mysql_query("select session_data from mysession "
	."where session_key = '$key'")
	or die("SQL语句执行失败");
	//如果不存在，则执行插入操作，否则执行更新操作
	if(mysql_numrows($query) == 0)
	{	
		//执行SQL语句插入Session的值
		$query = @mysql_query("insert into mysession values('$key', '$data', $expiry_time)")
		or die("SQL语句执行失败");
	}
	else
	{
		//执行SQL语句更新Session的值
		$query = @mysql_query("update mysession set "
		."session_data = '$data', session_expiry = $expiry_time "
		."where session_key = '$key'")
		or die("SQL语句执行失败");
	}
	return $query;
}

function mysession_destroy($key)
{
	@mysql_connect("localhost", "root","1981427")				//选择数据库之前需要先连接数据库服务器
	or die("数据库服务器连接失败");
	@mysql_select_db("test")					//选择数据库mydb
	or die("数据库不存在或不可用");
	//执行SQL语句删除Session
	$query = @mysql_query("delete from mysession where session_key = '$key'")
	or die("SQL语句执行失败");
	return $query;
}

function mysession_gc($expiry_time)
{
	@mysql_connect("localhost", "root","1981427")				//选择数据库之前需要先连接数据库服务器
	or die("数据库服务器连接失败");
	@mysql_select_db("test")					//选择数据库mydb
	or die("数据库不存在或不可用");
	$expiry_time = time();
	//执行SQL语句删除Session
	$query = @mysql_query("delete from mysession where session_expiry < $expiry_time")
	or die("SQL语句执行失败");
	return $query;
}

//设置用户自定义Session存储
session_set_save_handler('mysession_open',
	'mysession_close',
	'mysession_read',
	'mysession_write',
	'mysession_destroy',
	'mysession_gc');
?>

<?php
include('user-define-session-inc.php');		//包含session_set_save_handler定义的文件

session_start();
$_SESSION['username'] = "zhuzhao";
$_SESSION['password'] = "123456";
?>

<?php
include('user-define-session-inc.php');		//包含session_set_save_handler定义的文件

session_start();
echo "UserName:".$_SESSION['username']."<BR>";
echo "PassWord:".$_SESSION['password']."<BR>";
?>