Problem dotyczący session_handler

[api (Sitemaster)]

Mam sobie taką klase session_handlera wraz z przykładem użycia:

Wymaga bazy mysql nazwa bazy: pnr tabela: session -> session_id varchar(32) NOT NULL -> session_start int(11) UNSIGNED NOT NULL -> session_time int(11) UNSIGNED NOT NULL -> session_value text NOT NULL <? error_reporting(E_ALL); class Session { var $p; /** * Dane konfiguracyjne bazy danych * @var array $db_config Ustawiane przez konstruktor @see session(); * @access public */ var $db_config; /** * Tabela z danymi sesyjnymi * @var array $session_table Ustawiana przez konstruktor @see session(); * @access public */ var $session_table; /** * Maksymalny czas istnienia nieaktywnej sesji * @var array $session_table Ustawiana przez konstruktor @see session(); * @access public */ var $session_lifetime; /** * Konstruktor * Ustalanie parametrów i przygotowywanie środowiska pod funkcjonowanie klasy * @param string $db_config Dane konfiguracyjne bazy * @param string $session_table Tabela z danymi sesyjnymi * @param string $session_lifetime Maksymalny czas istnienia nieaktywnej sesji @default 0 * @return void * @access public */ function session($db_config = ‘’, $session_table, $session_lifetime = 0) { if(!empty($db_config)){ // Ustalanie danych konfiguracyjnych bazy $this->db_config[‘host’] = $db_config[‘host’]; $this->db_config[‘user’] = $db_config[‘user’]; $this->db_config[‘password’] = $db_config[‘password’]; $this->db_config[‘datebase’] = $db_config[‘datebase’]; $this->db_config[‘persistent’] = $db_config[‘persistent’]; } // Ustawianie tabeli $this->session_table = $session_table; } /** * Nawiązywanie połączenia bazodanowego * @return bool * @access public */ function connection() { $connect_type = $this->db_config[‘persistent’] ? ‘mysql_pconnect’ : ‘mysql_connect’; $connect = $connect_type($this->db_config[‘host’], $this->db_config[‘user’], $this->db_config[‘password’]) or Die(“Nieee”); $this->p = $connect; $db_select = mysql_select_db ($this->db_config[‘datebase’]); if ($connect && $db_select) { return true; } else { return false; } } /** * Inicjalizacja sesji * @param string $sesion_savepath Lokalizacja zapisu sesji * @param string $session_name Nazwa sesji * @return bool * @access private */ function _open($session_savepath, $session_name) { if($this->db_config != null) { // Nawiązywanie połączenia $this->connection(); } return true; } /** * Zakończenie sesji * @return bool * @access private */ function _close() { $this->_gc($this->session_lifetime); return true; } /** * Odczytywanie danych sesyjnych * @param string $session_id Identyfikator sesji * @return mixed * @access private */ function _read($session_id) { $sql_query = “SELECT session_value FROM " . $this->session_table . " WHERE session_id = '” . $session_id . “’”; $result = @mysql_query($sql_query,$this->p); if ($result && @mysql_num_rows($result) > 0) { $row = mysql_fetch_array($result); $session_value = $row[‘session_value’]; return $session_value; } else { return false; } } /** * Zapisywanie danych sesyjnych * @param string $session_id Identyfikator sesji * @param string $session_value Wartości sesyjne * @return bool * @access private */ function _write($session_id, $session_value) { $session_start = time(); $session_time = time(); $sql_query = “INSERT INTO " . $this->session_table . " (session_id, session_start, session_time, session_value) VALUES (’” . $session_id . "’, " . $session_start . ", " . $session_time . “, '” . $session_value . “’)”; $result = @mysql_query($sql_query,$this->p); if ($result) { return true; } else { $sql_query = "UPDATE " . $this->session_table . " SET session_time = " . $session_time . “, session_value = '” . $session_value . “’ WHERE session_id = '” . $session_id . “’”; $result = @mysql_query($sql_query,$this->p); if ($result) { return true; } else { return false; } } } /** * Usuwanie danych sesyjnych * @param string $session_id Identyfikator sesji * @return bool * @access private */ function _destroy($session_id) { $sql_query = “DELETE FROM " . $this->session_table . " WHERE session_id = '” . $session_id . “’”; $result = @mysql_query($sql_query,$this->p); if ($result) { return true; } else { return false; } } /** * “Garbage collection” - Usuwanie niepotrzebnych danych sesyjnych * @param in $session_lifetime Identyfikator sesji * @return bool * @access private */ function _gc($session_lifetime) { $session_lifetime = time() - $this->session_lifetime; $sql_query = "DELETE FROM “.$this->session_table.” WHERE session_time < ".time() - $session_lifetime; $result = @mysql_query($sql_query,$this->p); if ($result) { return true; } else { return false;} } } //-------------------KONIEC KLASY--------------------------- /* Dane konfiguracyjne bazy */ $db_config[‘host’] = “localhost”; $db_config[‘user’]= “root”; $db_config[‘password’] = “krasnal”; $db_config[‘datebase’] = “pnr”; $db_config[‘persistent’] = true; /** * Nazwa tabeli, w której przechowywane są dane sesyjne */ $session_table = “session”; /** * Czas trwania sesji po upływie którego nieaktywne sesje zostają * usunięte */ $session_lifetime = 30; // Tworzenie obiektu zarządzania sesją $session = new Session($db_config, $session_table, $session_lifetime); // Zastępowanie domyślnych funkcji metodami sesji session_set_save_handler (array(&$session, ‘_open’), array(&$session, ‘_close’), array(&$session, ‘_read’), array(&$session, ‘_write’), array(&$session, ‘_destroy’), array(&$session, ‘_gc’)); session_start(); //Test $_SESSION[“zmiennasesyjna”] = “test”; echo $_SESSION[“zmiennasesyjna”]; ?>

Niby wszystko ładnie, po odpaleniu zapisuje w bazie id sesji, czas rozpoczęcia, czas i wartość.

Problem w tym, ze:

1. nie usuwa przeterminowanej sesji z bazy

2. po uruchomieniu skryptu w nowym oknie/lub innej przeglądarce, nie tworzy nowego wpisu dla nowego session_id, tylko nadpisuje stary

Czyli w bazie widnieje tylko jeden wpis, a powinno być tyle ile otwartych sesji.

Co poprawić by wyeliminować te problemy?