SessionDAO.inc.php

<?php
 
import('lib.pkp.classes.session.Session');
 
class SessionDAO extends DAO {
 
   function newDataObject() {
      return new Session();
   }
 
   function &getSession($sessionId) {
      $result = $this->retrieve(
         'SELECT * FROM sessions WHERE session_id = ?',
         array($sessionId)
      );
 
      $session = null;
      if ($result->RecordCount() != 0) {
         $row = $result->GetRowAssoc(false);
 
         $session = $this->newDataObject();
         $session->setId($row['session_id']);
         $session->setUserId($row['user_id']);
         $session->setIpAddress($row['ip_address']);
         $session->setUserAgent($row['user_agent']);
         $session->setSecondsCreated($row['created']);
         $session->setSecondsLastUsed($row['last_used']);
         $session->setRemember($row['remember']);
         $session->setSessionData($row['data']);
         $session->setDomain($row['domain']);
      }
 
      $result->Close();
      return $session;
   }
 
   function insertObject($session) {
      $this->update(
         'INSERT INTO sessions
            (session_id, ip_address, user_agent, created, last_used, remember, data, domain)
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            $session->getId(),
            $session->getIpAddress(),
            substr($session->getUserAgent(), 0, 255),
            (int) $session->getSecondsCreated(),
            (int) $session->getSecondsLastUsed(),
            $session->getRemember() ? 1 : 0,
            $session->getSessionData(),
            $session->getDomain()
         )
      );
   }
 
   function updateObject(&$session) {
      return $this->update(
         'UPDATE sessions
            SET
               user_id = ?,
               ip_address = ?,
               user_agent = ?,
               created = ?,
               last_used = ?,
               remember = ?,
               data = ?,
               domain = ?
            WHERE session_id = ?',
         array(
            $session->getUserId()==''?null:(int) $session->getUserId(),
            $session->getIpAddress(),
            substr($session->getUserAgent(), 0, 255),
            (int) $session->getSecondsCreated(),
            (int) $session->getSecondsLastUsed(),
            $session->getRemember() ? 1 : 0,
            $session->getSessionData(),
            $session->getDomain(),
            $session->getId()
         )
      );
   }
 
   function deleteObject(&$session) {
      return $this->deleteById($session->getId());
   }
 
   function deleteById($sessionId) {
      return $this->update(
         'DELETE FROM sessions WHERE session_id = ?',
         array($sessionId)
      );
   }
 
   function deleteByUserId($userId) {
      return $this->update(
         'DELETE FROM sessions WHERE user_id = ?',
         array((int) $userId)
      );
   }
 
   function deleteByLastUsed($lastUsed, $lastUsedRemember = 0) {
      if ($lastUsedRemember == 0) {
         return $this->update(
            'DELETE FROM sessions WHERE (last_used < ? AND remember = 0)',
            array((int) $lastUsed)
         );
      } else {
         return $this->update(
            'DELETE FROM sessions WHERE (last_used < ? AND remember = 0) OR (last_used < ? AND remember = 1)',
            array((int) $lastUsed, (int) $lastUsedRemember)
         );
      }
   }
 
   function deleteAllSessions() {
      return $this->update('DELETE FROM sessions');
   }
 
   function sessionExistsById($sessionId) {
      $result = $this->retrieve(
         'SELECT COUNT(*) FROM sessions WHERE session_id = ?',
         array($sessionId)
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;
 
      $result->Close();
      return $returner;
   }
}