UserGroupAssignmentDAO.inc.php

<?php
 
import('lib.pkp.classes.security.UserGroupAssignment');
 
class UserGroupAssignmentDAO extends DAO {
 
   function newDataObject() {
      return new UserGroupAssignment();
   }
 
   function _fromRow($row) {
      $userGroupAssignment = $this->newDataObject();
      $userGroupAssignment->setUserGroupId($row['user_group_id']);
      $userGroupAssignment->setUserId($row['user_id']);
 
      return $userGroupAssignment;
   }
 
   function deleteByUserId($userId, $userGroupId = null) {
      $params = array((int) $userId);
      if ($userGroupId) $params[] = (int) $userGroupId;
 
      $this->update(
         'DELETE FROM user_user_groups
         WHERE user_id = ?
         ' . ($userGroupId?' AND user_group_id = ?':''),
         $params
      );
   }
 
   function deleteAssignmentsByUserGroupId($userGroupId) {
      return $this->update('DELETE FROM user_user_groups
                     WHERE user_group_id = ?',
                  (int) $userGroupId);
   }
 
   function deleteAssignmentsByContextId($contextId, $userId = null) {
      $params = array((int) $contextId);
      if ($userId) $params[] = (int) $userId;
      $result = $this->retrieve(
         'SELECT  uug.user_group_id, uug.user_id
         FROM  user_groups ug
            JOIN user_user_groups uug ON ug.user_group_id = uug.user_group_id
         WHERE ug.context_id = ?
            ' . ($userId?' AND uug.user_id = ?':''),
         $params
      );
 
      $assignments = new DAOResultFactory($result, $this, '_fromRow');
      while ($assignment = $assignments->next()) {
         $this->deleteByUserId($assignment->getUserId(), $assignment->getUserGroupId());
      }
   }
 
 
   function getByUserId($userId, $contextId = null, $roleId = null) {
      $params = array((int) $userId);
      if ($contextId) $params[] = (int) $contextId;
      if ($roleId) $params[] = (int) $roleId;
 
      $result = $this->retrieve(
         'SELECT uug.user_group_id, uug.user_id
         FROM  user_groups ug
            JOIN user_user_groups uug ON ug.user_group_id = uug.user_group_id
            WHERE uug.user_id = ?' .
            ($contextId?' AND ug.context_id = ?':'') .
            ($roleId?' AND ug.role_id = ?':''),
         $params
      );
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
 
   function insertObject($userGroupAssignment) {
      $this->replace(
         'user_user_groups',
         array(
            'user_id' => (int) $userGroupAssignment->getUserId(),
            'user_group_id' => (int) $userGroupAssignment->getUserGroupId(),
         ),
         array('user_id', 'user_group_id')
      );
   }
 
   function deleteAssignment(&$userGroupAssignment) {
      $this->update(
         'DELETE FROM user_user_groups WHERE user_id = ? AND user_group_id = ?',
         array((int) $userGroupAssignment->getUserId(), (int) $userGroupAssignment->getUserGroupId())
      );
   }
}