fields('og', array('etid')) ->where("og.entity_type = 'node' AND `field_name` = 'blog_ref' AND og.etid NOT IN (SELECT `entity_id` FROM {flagging} WHERE `fid` = :fid AND `uid` = :uid) AND og.etid IN (SELECT `etid` FROM {og_membership} WHERE `gid` = :gid AND `entity_type` = 'node')", array(':fid' => 3, ':uid' => 1, ':gid' => 192)); $result = $query->execute(); $i = 0; foreach ($result as $record) { print $record->etid . PHP_EOL; $i++; } print $i;