cache groups per user

This commit is contained in:
Evan Prodromou 2011-04-05 17:20:17 -04:00
parent 9568d17cb9
commit efd2c68de9
1 changed files with 25 additions and 16 deletions

View File

@ -245,30 +245,37 @@ class Profile extends Memcached_DataObject
return !empty($request);
}
function getGroups($offset=0, $limit=null)
function getGroups($offset=0, $limit=PROFILES_PER_PAGE)
{
$qry =
'SELECT user_group.* ' .
'FROM user_group JOIN group_member '.
'ON user_group.id = group_member.group_id ' .
'WHERE group_member.profile_id = %d ' .
'ORDER BY group_member.created DESC ';
$ids = array();
$keypart = sprintf('profile:groups:%d', $this->id);
if ($offset>0 && !is_null($limit)) {
if ($offset) {
if (common_config('db','type') == 'pgsql') {
$qry .= ' LIMIT ' . $limit . ' OFFSET ' . $offset;
} else {
$qry .= ' LIMIT ' . $offset . ', ' . $limit;
$idstring = self::cacheGet($keypart);
if ($idstring !== false) {
$ids = explode(',', $idstring);
} else {
$gm = new Group_member();
$gm->profile_id = $this->id;
if ($gm->find()) {
while ($gm->fetch()) {
$ids[] = $gm->group_id;
}
}
self::cacheSet($keypart, implode(',', $ids));
}
$groups = new User_group();
$groups = array();
$cnt = $groups->query(sprintf($qry, $this->id));
foreach ($ids as $id) {
$groups[] = User_group::staticGet('id', $id);
}
return $groups;
return new ArrayWrapper($groups);
}
/**
@ -286,6 +293,7 @@ class Profile extends Memcached_DataObject
} else {
if (Event::handle('StartJoinGroup', array($group, $this))) {
$join = Group_member::join($group->id, $this->id);
self::blow('profile:groups:%d', $this->id);
Event::handle('EndJoinGroup', array($group, $this));
}
}
@ -305,6 +313,7 @@ class Profile extends Memcached_DataObject
{
if (Event::handle('StartLeaveGroup', array($group, $this))) {
Group_member::leave($group->id, $this->id);
self::blow('profile:groups:%d', $this->id);
Event::handle('EndLeaveGroup', array($group, $this));
}
}