تالار گفتمان nCIS.ir

class DB
{
   /** @var PDO $con */
   private static $con = null;
   const DB = 'session_db';
   const HOST = 'localhost';
   const PASS = '';
   const USER = 'root';

   public function __construct()
   {
       throw new Exception('Cannot create an object from this class.');
   }

   public static function connect()
   {
       $dsn = 'mysql:dbname=' . self::DB . ';host=' . self::HOST . ';charset=utf8';
       try {
           self::$con = new PDO($dsn, self::USER, self::PASS);
       } catch (Exception $e) {
           die('Connection failed: ' . $e->getMessage());
       }
       self::execute('SET NAMES 'utf8'');
   }

   public static function execute($query)
   {
       if (!self::$con) {
           self::Connect();
       }
       return self::$con->exec($query);
   }

   public static function arrayQuery($query, $params = null)
   {
       if (!self::$con) {
           self::connect();
       }
       $data = [];
       $statement = self::$con->prepare($query);
       if ($statement->execute($params)) {
           foreach ($statement->fetchAll(PDO::FETCH_OBJ) as $row) {
               $data[] = $row;
           }
       }
       return $data;
   }

   public static function query($query, $params = null)
   {
       if (!self::$con) {
           self::connect();
       }
       $statement = self::$con->prepare($query);
       if ($statement->execute($params)) {
           return $statement->rowCount();
       }
       return -1;
   }
}

class DbSessionHandler implements SessionHandlerInterface
{
   public $sessionTable = 'session_table';
   public $autoCreateSessionTable = true;
   public $expireTime = 1200; // in Seconds

   private function createTable()
   {
       DB::query('START TRANSACTION;');
       DB::query("
           CREATE TABLE `{$this->sessionTable}` (
             `id` char(32) NOT NULL,
             `data` longblob NOT NULL,
             `expire` int(11) NOT NULL
           ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
      ");
       DB::query("ALTER TABLE `{$this->sessionTable}` ADD PRIMARY KEY (`id`);");
       DB::query('COMMIT;');
   }

   private function deleteExpired()
   {
       return DB::query("DELETE FROM `{$this->sessionTable}` WHERE (`expire`<:expire)", [':expire' => time()]);
   }


   public function close()
   {
       return true;
   }

   public function destroy($session_id)
   {
       DB::query("DELETE FROM `{$this->sessionTable}` WHERE (`id`=:id)", [':id' => $session_id]);
       return true;

   }

   public function gc($maxlifetime)
   {
       $this->deleteExpired();
       return true;
   }

   public function open($save_path, $name)
   {
       if ($this->autoCreateSessionTable) {
           if ($this->deleteExpired() < 0) {
               $this->createTable();
           }
       }
       return true;
   }

   public function read($session_id)
   {
       $data = DB::arrayQuery("SELECT `data` FROM `{$this->sessionTable}` WHERE (`id`=:id AND `expire`>=:expire)", [':id' => $session_id, ':expire' => time()]);
       return (count($data) > 0 ? base64_decode($data[0]->data) : '');
   }

   public function write($session_id, $session_data)
   {
       return DB::query("REPLACE INTO `{$this->sessionTable}` VALUES (:id, :data, :expire)", [':id' => $session_id, ':data' => base64_encode($session_data), ':expire' => time() + $this->expireTime]) > 0;
   }
}

require_once 'DB.php';
require_once 'DbSessionHandler.php';
session_set_save_handler(new DbSessionHandler());
session_start();
$_SESSION['name'] = 'ncis.ir';