Ukládání SESSIONS do databáze

Pro ukládání sessions do databáze existuje řada důvodů. Můžete chtít například využívat stejná sessions napříč weby, můžete mít zájem na marketingovém vyhodnocování obsahu dočasně vkládaných dat anebo chcete obejít záludnosti sdílených sessions na hostingu, kde nemáte přístup k php.ini a potřebujete například prodloužit dobu trvání sessions. Nejjednodušší je vytvořit custom handler a ukládat data do databáze.

session_set_save_handler()

Kouzlo s ukládáním sessions pomůže dovršit výše uvedená php funkce ve spolupráci s uživatelskými obslužnými funkcemi pro zápis, čtení a čištění úložiště (garbage collector).

require("classes/class.custom_sessions.php");
$ses_class = new session();
session_set_save_handler(array(&$ses_class, '_open'), array(&$ses_class, '_close'), array(&$ses_class, '_read'), array(&$ses_class, '_write'), array(&$ses_class, '_destroy'), array(&$ses_class, '_gc'));

session_start();
//dále se pracuje s proměnnými $_SESSION['xyz'] stejně jako při použití výchozího ukládání do sdílené složky

require("classes/class.custom_sessions.php");

$ses_class = new session();

session_set_save_handler(array(&$ses_class, '_open'), array(&$ses_class, '_close'), array(&$ses_class, '_read'), array(&$ses_class, '_write'), array(&$ses_class, '_destroy'), array(&$ses_class, '_gc'));

session_start();

//dále se pracuje s proměnnými $_SESSION['xyz'] stejně jako při použití výchozího ukládání do sdílené složky

CREATE TABLE IF NOT EXISTS `sessions` (
  `ses_id` varchar(64) NOT NULL,
  `ses_time` varchar(32) NOT NULL,
  `ses_start` varchar(32) NOT NULL,
  `ses_value` text NOT NULL,
  PRIMARY KEY (`ses_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

CREATE TABLE IF NOT EXISTS `sessions` (

`ses_id` varchar(64) NOT NULL,

`ses_time` varchar(32) NOT NULL,

`ses_start` varchar(32) NOT NULL,

`ses_value` text NOT NULL,

PRIMARY KEY (`ses_id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

<?php
class session 
{ 
	var $ses_table = "sessions"; 
	var $mysqli_connect = null;
                                 
	function db_connect() { 
      global $dbserver, $dbuser, $dbpass, $dbname;
      
      $this->mysqli_connect = mysqli_connect($dbserver, $dbuser, $dbpass, $dbname);
      mysqli_query($mysqli_connect, "SET NAMES utf8");
      
		if (!$mysqli_connect) { 
			return FALSE; 
		} else { 
			return TRUE; 
		} 
	} 

	 
	function _open($path, $name) { 
   	$this->db_connect(); 
		return TRUE; 
	} 


	function _close() { 
      if($this->mysqli_connect !== null)
			mysqli_close($this->mysqli_connect);
		return TRUE; 
	} 



	function _read($ses_id) { 

		$sql = "SELECT * FROM " . $this->ses_table . " WHERE ses_id = '$ses_id'"; 
		$result = mysqli_query($this->mysqli_connect, $sql); 
		
		if (!$result) { 
			return ''; 
		} 

		$num = mysqli_num_rows ($result); 
		if ($num > 0) { 
			$row = mysqli_fetch_assoc($result); 
			$data = $row["ses_value"]; 
			return $data; 
		} else { 
			return ''; 
		} 
	} 
   
   
   
	function _write($ses_id, $data) { 

		$sql = "UPDATE " . $this->ses_table . " SET ses_time = UNIX_TIMESTAMP(NOW()), ses_value='$data'  WHERE ses_id='$ses_id'"; 
		$result = mysqli_query($this->mysqli_connect, $sql); 

		if (!$result) { 
			return FALSE; 
		} 

		if (mysqli_affected_rows()) { 
			return TRUE; 
		} 

		$sql = "INSERT INTO " . $this->ses_table . " (ses_id, ses_time, ses_start, ses_value) VALUES ('$ses_id', UNIX_TIMESTAMP(NOW()), UNIX_TIMESTAMP(NOW()), '$data')"; 
		$result = mysqli_query($this->mysqli_connect, $sql);

		$match = "#^Duplicate entry '$ses_id' for key \d+$#";
		if (!$result && !preg_match($match,mysqli_error())) {
			return FALSE; 
		} else { 
			return TRUE; 
		} 
	} 


	function _destroy($ses_id) { 

		$sql = "DELETE FROM " . $this->ses_table . " WHERE ses_id = '$ses_id'"; 
		$result = mysqli_query($this->mysqli_connect, $sql);

		if (!$result) { 
			return FALSE; 
		}         else { 
			return TRUE; 
		} 
	} 
   
   
	function _gc($life) { 
      $life = 9000;

		$sql = "DELETE FROM " . $this->ses_table . " WHERE ses_time < UNIX_TIMESTAMP(NOW() - $life)"; 
		$result = mysqli_query($this->mysqli_connect, $sql); 

		if (!$result) { 
			return FALSE; 
		}         else { 
			return TRUE; 
		} 
	} 
}
?>

100

101

102

103

104

105

106

107

<?php

class session

{

var $ses_table = "sessions";

var $mysqli_connect = null;

function db_connect() {

global $dbserver, $dbuser, $dbpass, $dbname;

$this->mysqli_connect = mysqli_connect($dbserver, $dbuser, $dbpass, $dbname);

mysqli_query($mysqli_connect, "SET NAMES utf8");

if (!$mysqli_connect) {

return FALSE;

} else {

return TRUE;

}

function _open($path, $name) {

$this->db_connect();

return TRUE;

}

function _close() {

if($this->mysqli_connect !== null)

mysqli_close($this->mysqli_connect);

return TRUE;

}

function _read($ses_id) {

$sql = "SELECT * FROM " . $this->ses_table . " WHERE ses_id = '$ses_id'";

$result = mysqli_query($this->mysqli_connect, $sql);

if (!$result) {

return '';

}

$num = mysqli_num_rows ($result);

if ($num > 0) {

$row = mysqli_fetch_assoc($result);

$data = $row["ses_value"];

return $data;

} else {

return '';

}

function _write($ses_id, $data) {

$sql = "UPDATE " . $this->ses_table . " SET ses_time = UNIX_TIMESTAMP(NOW()), ses_value='$data' WHERE ses_id='$ses_id'";

$result = mysqli_query($this->mysqli_connect, $sql);

if (!$result) {

return FALSE;

}

if (mysqli_affected_rows()) {

return TRUE;

}

$sql = "INSERT INTO " . $this->ses_table . " (ses_id, ses_time, ses_start, ses_value) VALUES ('$ses_id', UNIX_TIMESTAMP(NOW()), UNIX_TIMESTAMP(NOW()), '$data')";

$result = mysqli_query($this->mysqli_connect, $sql);

$match = "#^Duplicate entry '$ses_id' for key \d+$#";

if (!$result && !preg_match($match,mysqli_error())) {

return FALSE;

} else {

return TRUE;

}

function _destroy($ses_id) {

$sql = "DELETE FROM " . $this->ses_table . " WHERE ses_id = '$ses_id'";

$result = mysqli_query($this->mysqli_connect, $sql);

if (!$result) {

return FALSE;

} else {

return TRUE;

}

function _gc($life) {

$life = 9000;

$sql = "DELETE FROM " . $this->ses_table . " WHERE ses_time < UNIX_TIMESTAMP(NOW() - $life)";

$result = mysqli_query($this->mysqli_connect, $sql);

if (!$result) {

return FALSE;

} else {

return TRUE;

}

Mohlo by vás zajímat:

Změna pořadí přetažením - AJAX třídění

Update formuláře pomocí AJAXu

Bezpečnější upload souborů pomocí php

Odeslání obrázku AJAXem

Základy práce s IMAP

PHP Developer

Mohlo by vás zajímat: