classes/session/SessionDAO.inc.php

<?php

// $Id: SessionDAO.inc.php,v 1.14 2008/07/01 01:16:10 asmecher Exp $


import('session.Session');

class SessionDAO extends DAO {
   function &getSession($sessionId) {
      $result = &$this->retrieve(
         'SELECT * FROM sessions WHERE session_id = ?', $sessionId
      );

      $session = null;
      if ($result->RecordCount() != 0) {
         $row = &$result->GetRowAssoc(false);

         $session = &new Session();
         $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']);

      }

      $result->Close();
      unset($result);

      return $session;
   }

   function insertSession(&$session) {
      return $this->update(
         'INSERT INTO sessions
            (session_id, ip_address, user_agent, created, last_used, remember, data)
            VALUES
            (?, ?, ?, ?, ?, ?, ?)',
         array(
            $session->getId(),
            $session->getIpAddress(),
            $session->getUserAgent(),
            $session->getSecondsCreated(),
            $session->getSecondsLastUsed(),
            $session->getRemember() ? 1 : 0,
            $session->getSessionData()
         )
      );
   }

   function updateSession(&$session) {
      return $this->update(
         'UPDATE sessions
            SET
               user_id = ?,
               ip_address = ?,
               user_agent = ?,
               created = ?,
               last_used = ?,
               remember = ?,
               data = ?
            WHERE session_id = ?',
         array(
            $session->getUserId(),
            $session->getIpAddress(),
            $session->getUserAgent(),
            $session->getSecondsCreated(),
            $session->getSecondsLastUsed(),
            $session->getRemember() ? 1 : 0,
            $session->getSessionData(),
            $session->getId()
         )
      );
   }

   function deleteSession(&$session) {
      return $this->deleteSessionById($session->getId());
   }

   function deleteSessionById($sessionId) {
      return $this->update(
         'DELETE FROM sessions WHERE session_id = ?', $sessionId
      );
   }

   function deleteSessionsByUserId($userId) {
      return $this->update(
         'DELETE FROM sessions WHERE user_id = ?', $userId
      );
   }

   function deleteSessionByLastUsed($lastUsed, $lastUsedRemember = 0) {
      if ($lastUsedRemember == 0) {
         return $this->update(
            'DELETE FROM sessions WHERE (last_used < ? AND remember = 0)', $lastUsed
         );
      } else {
         return $this->update(
            'DELETE FROM sessions WHERE (last_used < ? AND remember = 0) OR (last_used < ? AND remember = 1)',
            array($lastUsed, $lastUsedRemember)
         );
      }
   }

   function deleteAllSessions() {
      return $this->update('DELETE FROM sessions');
   }

   function sessionExistsById($sessionId) {
      $result = &$this->retrieve(
         'SELECT COUNT(*) FROM sessions WHERE session_id = ?',
         $sessionId
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

      $result->Close();
      unset($result);

      return $returner;
   }
}

?>

---