復(fù)制代碼 代碼如下:

class session_handler {

?protected $maxlifetime = null;
?protected $dbHandle = null;
?public $config = null;

?public static function init($args) {
??return new self($args);
?}

?public function __construct($args) {

??$this->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));