利用session_set_save_handler()函数将session保存到MySQL数据库中

001

<?php

002

/**

003

*
SessionMysql数据库存储类

004

*/

005

006

defined(

'IN_QIAN'

)

or

exit

(

'Access
Denied'

);

007

008

class

SessionMysql
{

009

010

public

$lifetime

=
1800;

//
有效期，单位：秒（s），默认30分钟

011

public

$db

;

012

public

$table

;

013

014

/**

015

*
构造函数

016

*/

017

public

function

__construct()
{

018

$this

->db
=Base::loadModel(

'SessionModel'

);

019

$this

->lifetime
=Base::loadConfig(

'system'

,

'session_lifetime'

);

020

session_set_save_handler(

021

array

(&

$this

,

'open'

),

//
在运行session_start()时执行

022

array

(&

$this

,

'close'

),

//
在脚本执行完成或调用session_write_close()或session_destroy()时被执行，即在所有session操作完后被执行

023

array

(&

$this

,

'read'

),

//
在运行session_start()时执行，因为在session_start时，会去read当前session数据

024

array

(&

$this

,

'write'

),

//
此方法在脚本结束和使用session_write_close()强制提交SESSION数据时执行

025

array

(&

$this

,

'destroy'

),

//
在运行session_destroy()时执行

026

array

(&

$this

,

'gc'

)

//
执行概率由session.gc_probability和session.gc_divisor的值决定，时机是在open，read之后，session_start会相继执行open，read和gc

027

);

028

session_start();

//
这也是必须的，打开session，必须在session_set_save_handler后面执行

029

}

030

031

/**

032

*
session_set_save_handleropen方法

033

*

034

*
@param$savePath

035

*
@param$sessionName

036

*
@returntrue

037

*/

038

public

function

open(

$savePath

,

$sessionName

)
{

039

return

true;

040

}

041

042

/**

043

*
session_set_save_handlerclose方法

044

*

045

*
@returnbool

046

*/

047

public

function

close()
{

048

return

$this

->gc(

$this

->lifetime);

049

}

050

051

/**

052

*
读取session_id

053

*

054

*
session_set_save_handlerread方法

055

*
@returnstring读取session_id

056

*/

057

public

function

read(

$sessionId

)
{

058

$condition

=

array

(

059

'where'

=>

array

(

060

'session_id'

=>

$sessionId

061

),

062

'fields'

=>

'data'

063

);

064

$row

=

$this

->db->fetchFirst(

$condition

);

065

return

$row

?

$row

[

'data'

]
:

''

;

066

}

067

068

/**

069

*
写入session_id的值

070

*

071

*
@param$sessionId会话ID

072

*
@param$data值

073

*
@returnmixedquery执行结果

074

*/

075

public

function

write(

$sessionId

,

$data

)
{

076

$userId

=
isset(

$_SESSION

[

'userId'

])
?

$_SESSION

[

'userId'

]
:0;

077

$roleId

=
isset(

$_SESSION

[

'roleId'

])
?

$_SESSION

[

'roleId'

]
:0;

078

$grouId

=
isset(

$_SESSION

[

'grouId'

])
?

$_SESSION

[

'grouId'

]
:0;

079

$m

=
defined(

'ROUTE_M'

)
?ROUTE_M:

''

;

080

$c

=
defined(

'ROUTE_C'

)
?ROUTE_C:

''

;

081

$a

=
defined(

'ROUTE_A'

)
?ROUTE_A:

''

;

082

if

(

strlen

(

$data

)
>255){

083

$data

=

''

;

084

}

085

$ip

=
get_ip();

086

$sessionData

=

array

(

087

'session_id'

=>

$sessionId

,

088

'user_id'

=>

$userId

,

089

'ip'

=>

$ip

,

090

'last_visit'

=>
SYS_TIME,

091

'role_id'

=>

$roleId

,

092

'group_id'

=>

$grouId

,

093

'm'

=>

$m

,

094

'c'

=>

$c

,

095

'a'

=>

$a

,

096

'data'

=>

$data

,

097

);

098

return

$this

->db->insert(

$sessionData

,
1,1);

099

}

100

101

/**

102

*
删除指定的session_id

103

*

104

*
@paramstring$sessionId会话ID

105

*
@returnbool

106

*/

107

public

function

destroy(

$sessionId

)
{

108

return

$this

->db->

delete

(

array

(

'session_id'

=>

$sessionId

));

109

}

110

111

/**

112

*
删除过期的session

113

*

114

*
@param$lifetimesession有效期（单位：秒）

115

*
@returnbool

116

*/

117

public

function

gc(

$lifetime

)
{

118

$expireTime

=
SYS_TIME-

$lifetime

;

119

return

$this

->db->

delete

(

"`last_visit`<$expireTime"

);

120

}

121

}

122

?>