1. sfPostgreSQLSessionStorage.class.php
  2. /**
 * Provides support for session storage using a PostgreSQL brand database.
 *
 * parameters: see sfDatabaseSessionStorage
 *
 * @package    symfony
 * @subpackage storage
 * @author     Fabien Potencier 
 * @author     Sean Kerr 
 * @version    SVN: $Id: sfPostgreSQLSessionStorage.class.php 23810 2009-11-12 11:07:44Z Kris.Wallsmith $
 */
  3. class sfPostgreSQLSessionStorage extends sfDatabaseSessionStorage
  4. {
  5.   /**
  6.    * Destroys a session.
  7.    *
  8.    * @param  string $id  A session ID
  9.    *
  10.    * @return bool true, if the session was destroyed, otherwise an exception is thrown
  11.    *
  12.    * @throws <b>sfDatabaseException</b> If the session cannot be destroyed
  13.    */
  14.   public function sessionDestroy($id)
  15.   {
  16.     // get table/column
  17.     $db_table  = $this->options['db_table'];
  18.     $db_id_col = $this->options['db_id_col'];
  20.     // cleanup the session id, just in case
  21.     $id = addslashes($id);
  23.     // delete the record associated with this id
  24.     $sql = 'DELETE FROM '.$db_table.' WHERE '.$db_id_col.' = \''.$id.'\'';
  26.     if (@pg_query($this->db, $sql))
  27.     {
  28.       return true;
  29.     }
  31.     // failed to destroy session
  32.     throw new sfDatabaseException(sprintf('sfPostgreSQLSessionStorage cannot destroy session id "%s".', $id));
  33.   }
  35.   /**
  36.    * Cleans up old sessions.
  37.    *
  38.    * @param  int $lifetime  The lifetime of a session
  39.    *
  40.    * @return bool true, if old sessions have been cleaned, otherwise an exception is thrown
  41.    *
  42.    * @throws <b>sfDatabaseException</b> If any old sessions cannot be cleaned
  43.    */
  44.   public function sessionGC($lifetime)
  45.   {
  46.     // get table/column
  47.     $db_table    = $this->options['db_table'];
  48.     $db_time_col = $this->options['db_time_col'];
  50.     // delete the record associated with this id
  51.     $sql = 'DELETE FROM '.$db_table.' WHERE '.$db_time_col.' < '.(time() - $lifetime);
  53.     if (!@pg_query($this->db, $sql))
  54.     {
  55.       throw new sfDatabaseException('sfPostgreSQLSessionStorage cannot delete old sessions.');
  56.     }
  58.     return true;
  59.   }
  61.   /**
  62.    * Reads a session.
  63.    *
  64.    * @param  string $id  A session ID
  65.    *
  66.    * @return string      The session data if the session was read or created, otherwise an exception is thrown
  67.    *
  68.    * @throws <b>sfDatabaseException</b> If the session cannot be read
  69.    */
  70.   public function sessionRead($id)
  71.   {
  72.     // get table/column
  73.     $db_table    = $this->options['db_table'];
  74.     $db_data_col = $this->options['db_data_col'];
  75.     $db_id_col   = $this->options['db_id_col'];
  76.     $db_time_col = $this->options['db_time_col'];
  78.     // cleanup the session id, just in case
  79.     $id = addslashes($id);
  81.     // delete the record associated with this id
  82.     $sql = 'SELECT '.$db_data_col.' FROM '.$db_table.' WHERE '.$db_id_col.' = \''.$id.'\'';
  84.     $result = @pg_query($this->db, $sql);
  86.     if ($result != false && @pg_num_rows($result) == 1)
  87.     {
  88.       // found the session
  89.       $data = pg_fetch_row($result);
  91.       return $data[0];
  92.     }
  93.     else
  94.     {
  95.       // session does not exist, create it
  96.       $sql = 'INSERT INTO '.$db_table.' ('.$db_id_col.', '.$db_data_col.', '.$db_time_col.') VALUES (\''.$id.'\', \'\', '.time().')';
  98.       if (@pg_query($this->db, $sql))
  99.       {
  100.         return '';
  101.       }
  103.       // can't create record
  104.       throw new sfDatabaseException(sprintf('sfPostgreSQLSessionStorage cannot create new record for id "%s".', $id));
  105.     }
  106.   }
  108.   /**
  109.    * Writes session data.
  110.    *
  111.    * @param  string $id    A session ID
  112.    * @param  string $data  A serialized chunk of session data
  113.    *
  114.    * @return bool true, if the session was written, otherwise an exception is thrown
  115.    *
  116.    * @throws <b>sfDatabaseException</b> If the session data cannot be written
  117.    */
  118.   public function sessionWrite($id, $data)
  119.   {
  120.     // get table/column
  121.     $db_table    = $this->options['db_table'];
  122.     $db_data_col = $this->options['db_data_col'];
  123.     $db_id_col   = $this->options['db_id_col'];
  124.     $db_time_col = $this->options['db_time_col'];
  126.     // cleanup the session id and data, just in case
  127.     $id   = addslashes($id);
  128.     $data = addslashes($data);
  130.     // delete the record associated with this id
  131.     $sql = 'UPDATE '.$db_table.' SET '.$db_data_col.' = \''.$data.'\', '.$db_time_col.' = '.time().' WHERE '.$db_id_col.' = \''.$id.'\'';
  133.     if (@pg_query($this->db, $sql))
  134.     {
  135.       return true;
  136.     }
  138.     // failed to write session data
  139.     throw new sfDatabaseException(sprintf('sfPostgreSQLSessionStorage cannot write session data for id "%s".', $id));
  140.   }
  141. }
Debug toolbar