php session 写入数据库，phpsession

本文实例介绍了php session 写入数据库的方法，分享给大家供大家参考，具体内容如下

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` < "%u"';

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

以上就是本文的全部内容，希望对大家的学习有所帮助。

您可能感兴趣的文章:PHP用mysql数据库存储session的代码

Session保存到数据库的php类分享

php把session写入数据库示例

PHP独立Session数据库存储操作类分享

php中使用session_set_save_handler()函数把session保存到MySQL数据库实例

PHP将session信息存储到数据库的类实例

php实现将Session写入数据库

php基于session实现数据库交互的类实例

本文原创发布php中文网，转载请注明出处，感谢您的尊重！