Forum PHP.pl

WITAM!

Napisałem (a raczej odtworzyłem z "php. Czarna księga") implementację sesji opartą na bazie danych.

Kod obsługi sesji wygląda następująco:

[PHP] pobierz, plaintext 
<?php
 
// Dostarczenie nazwy bazy danych
function session_db()
{
	return('probka');
}
 
// Dostarczenie nazwy tabeli
function session_table()
{
	return('session');
}
 
// Zapis komunikatów z funkcji sesji
function session_log($message)
{
	if($file = fopen('session.txt', 'a'))
	{
		$m = explode(' ', microtime());
		fwrite($file, date("H:i:s", $m[1]) . substr($m[0], 1) . " " . $message . "\n");
		fclose($file);
	}
}
 
// Otwarcie sesji
function session_open($path, $name)
{
	$host = "localhost";
	$user = "jm";
	$pass = "123pas";
 
	session_log('session_open');
 
	if(!mysql_connect($host, $user, $pass))
	{
		session_log('Funkcja session_open(): błąd połączenia z bazą danych: ' . mysql_error());
		return false;
	}
 
	return true;
}
 
// Zamknięcie sesji
function session_close()
{
	session_log('session_close');
	return true;
}
 
// Funkcja przyjmuje identyfikator sesji i zwraca łańcuch zawierający dane sesji.
// Jeśli dane nie są dostępne, funkcja zwraca łańcuch o zerowej długości.
function session_read($id)
{
	session_log('session_read');
 
	if(!mysql_select_db(session_db()))
	{
		session_log('Funkcja session_read(): błąd wyboru bazy danych: ' . mysql_error());
		return false;
	}
 
	$sql = 'select * from ' . session_table() . ' where id = "' . $id . '"';
 
	if(!$result = mysql_query($sql))
	{
		session_log('Błąd MySQL: ' . mysql_error() . ' z SQL: ' . $sql);
		return false;
	}
 
	if(mysql_num_rows($result))
	{
		session_log('Kwerenda MySQL zwróciła ' . mysql_num_rows($result) . ' wierszy.');
		$row = mysql_fetch_assoc($result);
		session_log('Funkcja session_read() zwróciła ' . $row['data']);
		return $row['data'];
	}
	else
	{
		session_log('Funkcja session_read() znalazła zero rekordów przy kwerendzie SQL: ' . $sql);
		return "";
	} 
}
 
// Funkcja przyjmuje identyfikator sesji oraz jej zakodowane dane,
// zapisuje dane do bazy danych.
// W przypadku powodzenia zwraza true, w razie wystąpienia błędu wartość false.
function session_write($id, $data)
{
	session_log('session_write');
 
	if(!mysql_select_db(session_db()))
	{
		session_log('Funkcja session_write(): błąd wyboru bazy danych: ' . mysql_error());
		return false;
	}
 
	$sql = 'update ' . session_table() . ' set data = "' . addslashes($data) .'"';
 
	if(isset($PHP_AUTH_USER))
		$sql .= ', user = "' . addslashes($PHP_AUTH_USER) . '"';
 
	$sql .= ' where id = "' . $id .'"';
 
	if(!$result = mysql_query())
	{
		session_log('Błąd funkcji session_write() ' . mysql_error() . ' z SQL: ' . $sql);	
		return false;
	}
 
	if($rows = mysql_affected_rows())
	{
		session_log('Funkcja session_write() zaktualizowała ' . $rows . ' wierszy kwerendą SQL: ' . $sql);
		return true;
	}
 
	session_log('Funkcja session_write() zaktualizowała zero wierszy kwerendą SQL: ' . $sql);
 
	$sql = 'insert into ' . session_table . ' set data = "' . addslashes($data) . '", id = "' . addslashes($id) . '", time = null';
 
	if(!$result = mysql_query($sql))
	{
		session_log('Błąd funkcji session_write() ' . mysql_error() . ' z SQL: ' . $sql);		
		return false;
	}
	else
	{
		session_log('Funkcja session_write() wstawiła wiersz kwerendą SQL: ' . $sql);
		return true;
	}
}
 
// usunięcie istniejącego rekoru sesji
function session_remove($id)
{
	session_log('session_remove');	
 
	if(!mysql_select_db(session_db()))
	{
		session_log('Funkcja session_remove(): błąd wyboru bazy danych: ' . mysql_error());
		return false;
	}
 
	$sql = 'delete from ' . session_table . ' where id = "' . $id . '"';
 
	if($result = mysql_query($sql))
	{
		session_log('Wykonano polecenie MySQL delete.');
		return true;
	}
	else
	{
		session_log('Błąd aktualizacji MySQL: ' . mysql_error() . " z SQL: " . $sql);
		return false;
	}
}
 
// mechanizm porządkujacy (usuwający stare sesje)
function session_gc($life)
{
	session_log('session_gc');	
 
	if(!mysql_select_db(session_db()))
	{
		session_log('Funkcja session_gc(): błąd wyboru bazy danych: ' . mysql_error());
		return false;
	}
 
	$sql = 'delete from ' . session_table() . ' where time < "' . date("YmdHis", time() - $life) . '"';
 
	print('session_gc sql: ' . $sql);
 
	if($result = mysql_query($sql))
	{
		session_log('Funkcja session_gc() usunęła ' . mysql_affected_rows() . ' wierszy.');
		return true;
	}
	else
	{
		session_log('Błąd funkcji session_gc(): ' . mysql_error() . ' z SQL: ' . $sql);
		return false;	
	}
}
 
session_module_name("user");
session_set_save_handler("session_open", "session_close", "session_read", "session_write", "session_remove", "session_gc");
 
?>
[PHP] pobierz, plaintext 

Lecz gdy dołączę ten plik do innego i uruchomię sesją:

[PHP] pobierz, plaintext 
<?php
session_start();
?>
[PHP] pobierz, plaintext 

dostaję błąd systemowy: Pamięć nie może być read...

Gdzie może być błąd.

Kod SQL tworzący bd:

[SQL] pobierz, plaintext 
CREATE TABLE session
(
id varchar(32) NOT NULL,
time timestamp(14),
user tinytext NOT NULL,
DATA text NOT NULL,
PRIMARY KEY(id)
);
[SQL] pobierz, plaintext