config = $args;
$this->maxlifetime = get_cfg_var(session.gc_maxlifetime); session_set_save_handler( array($this, open), array($this, close), array($this, read), array($this, write), array($this, destroy), array($this, gc)); } public function open() {
$this->link = mysqli_connect( $this->config['host'], $this->config['user'], $this->config['password'], $this->config['database']); mysqli_set_charset($this->link, utf8); $sql = 'create table if not exists `%s` ( `session_id` varchar(255) not null, `session_data` text, `session_expires` char(10) not null, primary key (`session_id`) ) engine=innodb default charset=utf8 collate=utf8_unicode_ci;'; $sql = sprintf($sql, $this->config['table']); mysqli_query($this->link, $sql); return true; } public function close() {
return true; } public function read($session_id) {
if(empty($session_id)) return null; $sql = 'select `session_data` as `data` from `%s` where `session_id` = %s and `session_expires` > %u';
$sql = sprintf($sql, mysqli_real_escape_string($this->link, $this->config['table']), mysqli_real_escape_string($this->link, $session_id), time()); $result = mysqli_query($this->link, $sql);
$row = mysqli_fetch_assoc($result); return $row['data']; } public function write($session_id, $session_data) {
if(empty($session_id)) return null; $newexpires = time() + $this->maxlifetime;
$sql = 'replace into `%s` set `session_id` = %s, `session_data` = %s, `session_expires` = %u'; $sql = sprintf($sql, mysqli_real_escape_string($this->link, $this->config['table']), mysqli_real_escape_string($this->link, $session_id), mysqli_real_escape_string($this->link, $session_data), $newexpires); $result = mysqli_query($this->link, $sql);
return mysqli_affected_rows($this->link);} public function destroy($session_id) {
$sql = 'delete from `%s` where `session_id` = %s'; $sql = sprintf($sql, mysqli_real_escape_string($this->link, $this->config['table']), mysqli_real_escape_string($this->link, $session_id)); $result = mysqli_query($this->link, $sql); return mysqli_affected_rows($this->link);} public function gc() {
$sql = 'delete from `%s` where `session_expires` $sql = sprintf($sql, mysqli_real_escape_string($this->link, $this->config['table']), time()); $result = mysqli_query($this->link, $sql);
return mysqli_affected_rows($this->link);}}class session { public static $collection = null; public static function open($clean = false, $token = false) {
if($clean) ob_end_clean(); if($token) session_id($token); session_start(); self::$collection = $_session; } public static function id() {
$num_args = func_num_args(); if($num_args) { $args = func_get_arg(0); return session_id($args); }else{ return session_id(); } } public static function get($name) {
return isset($_session[$name]) ? $_session[$name] : null; } public static function set($name, $value) {
$_session[$name] = $value; return true; } public static function delete($name) {
if(!isset($_session[$name])) return null; unset($_session[$name]); return true; } public static function destroy() {
session_destroy(); }}
$config = array(host=> 127.0.0.1,user=> root,password=> 123456,database=> test,charset=> utf8,table=> user_session);session_handler::init($config);session::open();session::set(profile, array(id=> 1, user=> haowei, vip-level=> 6));
复制代码