diff --git a/session/Session.model.php b/session/Session.model.php new file mode 100644 index 0000000..091aa6a --- /dev/null +++ b/session/Session.model.php @@ -0,0 +1,70 @@ + + * @link http://netmonsters.ru + * @package Majestic + * @subpackage Session + * @since 2010-02-28 + * @version SVN: $Id$ + * @filesource $URL$ + */ + +class SessionModel extends Model +{ + + protected $life_time; + + public function __construct() + { + parent::__construct(); + $this->life_time = get_cfg_var('session.gc_maxlifetime'); + } + + /* Session handler methods */ + + public function open($save_path, $sess_name) + { + return true; + } + + public function close() + { + return true; + } + + public function read($id) + { + $sql = 'SELECT `data` FROM ' . $this->table() . ' WHERE `id`=? AND `expires` > UNIX_TIMESTAMP()'; + return (string) $this->fetchField($sql, $id, 'data'); + } + + public function write($id, $data) + { + preg_match('/user\|.+s:2:"id";s:(\d+):"(\d+)"/', $data, $match); + $user_id = empty($match) ? 0 : (int) $match[2]; + + $sql = 'INSERT INTO ' . $this->table() . ' (`id`, `expires`, `user_id`, `data`)' + . ' VALUES(' . $this->quote($id) . ', UNIX_TIMESTAMP() + ' . (int) $this->life_time . ', ' . $user_id . ', ' . $this->quote($data) . ')' + . ' ON DUPLICATE KEY UPDATE `expires`=UNIX_TIMESTAMP() + ' . (int) $this->life_time . ', `user_id`=' . $user_id . ', `data`=' . $this->quote($data); + $affected = $this->db->query($sql)->affectedRows(); + return (bool) ($this->getInsertId()) ? $this->getInsertId() : $affected; + } + + public function destroy($id) + { + return (bool) $this->db->delete($this->table(false), array('`id`=?' => (string) $id)); + } + + public function gc($max_life_time) + { + return (bool) $this->db->delete($this->table(false), '`expires` < UNIX_TIMESTAMP()'); + } + + /* End of Session handler methods */ + + + public function destroyByUserId($user_id) + { + return $this->db->delete($this->table(false), array('`user_id`=?' => $user_id)); + } +} \ No newline at end of file diff --git a/session/Session.php b/session/Session.php index 96546b2..b2546fd 100644 --- a/session/Session.php +++ b/session/Session.php @@ -171,7 +171,6 @@ class Session } self::$started = true; session_start(); - self::regenerateId(); } /** @@ -220,4 +219,16 @@ class Session ); } } + + public static function setSessionHandler($handler) + { + session_set_save_handler( + array($handler, 'open'), + array($handler, 'close'), + array($handler, 'read'), + array($handler, 'write'), + array($handler, 'destroy'), + array($handler, 'gc') + ); + } } diff --git a/session/session.sql b/session/session.sql new file mode 100644 index 0000000..c49b7a8 --- /dev/null +++ b/session/session.sql @@ -0,0 +1,10 @@ + +CREATE TABLE IF NOT EXISTS `session` ( + `id` char(32) NOT NULL, + `expires` int(11) unsigned NOT NULL, + `user_id` int(11) unsigned DEFAULT '0', + `data` text NOT NULL, + PRIMARY KEY (`id`), + KEY `expires` (`expires`), + KEY `user_id` (`user_id`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8; \ No newline at end of file