config = new AauthConfig(); $this->DBGroup = $this->config->dbProfile; $this->table = $this->config->dbTableGroupToUser; if ($db instanceof ConnectionInterface) { $this->db = & $db; } else { $this->db = Database::connect($this->DBGroup); } } /** * Get all Group Ids by User Id * * @param integer $userId User Id * * @return array|null */ public function findAllByUserId(int $userId) { $builder = $this->builder(); $builder->select('group_id'); $builder->where('user_id', $userId); return $builder->get()->getResult('array'); } /** * Get all User Ids by Group Id * * @param integer $groupId Group Id * * @return array|null */ public function findAllByGroupId(int $groupId) { $builder = $this->builder(); $builder->select('user_id'); $builder->where('group_id', $groupId); return $builder->get()->getResult('array'); } /** * Check if exists by Group Id and User Id * * @param integer $groupId Group Id * @param integer $userId User Id * * @return boolean */ public function exists(int $groupId, int $userId) { $builder = $this->builder(); $builder->where('group_id', $groupId); $builder->where('user_id', $userId); return ($builder->countAllResults() ? true : false); } /** * Insert * * @param integer $groupId Group Id * @param integer $userId User Id * * @return boolean */ public function insert(int $groupId, int $userId) { $builder = $this->builder(); $data['group_id'] = $groupId; $data['user_id'] = $userId; $builder->insert($data); return true; } /** * Delete by Group Id and User Id * * @param integer $groupId Group Id * @param integer $userId User Id * * @return boolean */ public function delete(int $groupId, int $userId) { $builder = $this->builder(); $builder->where('group_id', $groupId); $builder->where('user_id', $userId); $builder->delete(); return true; } /** * Deletes all by Group Id * * @param integer $groupId Group Id * * @return boolean */ public function deleteAllByGroupId(int $groupId) { $builder = $this->builder(); $builder->where('group_id', $groupId); $builder->delete(); return true; } /** * Deletes all by User Id * * @param integer $userId User Id * * @return boolean */ public function deleteAllByUserId(int $userId) { $builder = $this->builder(); $builder->where('user_id', $userId); $builder->delete(); return true; } /** * Provides a shared instance of the Query Builder. * * @param string $table Table Name * * @return BaseBuilder */ protected function builder(string $table = null) { if ($this->builder instanceof BaseBuilder) { return $this->builder; } $table = empty($table) ? $this->table : $table; $this->builder = $this->db->table($table); return $this->builder; } }