public function createGroup( $gid ) {
$this->fixDI();
- // Check cache first
- if (isset($this->groupCache[$gid])) {
- return false;
- } else {
- // Check for existence in DB
- $qb = $this->dbConn->getQueryBuilder();
- $cursor = $qb->select('gid')
- ->from('groups')
- ->where($qb->expr()->eq('gid', $qb->createNamedParameter($gid)))
- ->execute();
-
- $result = $cursor->fetch();
- $cursor->closeCursor();
-
- if($result) {
- // Can not add an existing group
-
- // Add to cache
- $this->groupCache[$gid] = $gid;
-
- return false;
- }
- }
-
- // Add group and exit
+ // Add group
$qb = $this->dbConn->getQueryBuilder();
- $result = $qb->insert('groups')
- ->setValue('gid', $qb->createNamedParameter($gid))
- ->execute();
-
- if (!$result) {
- return false;
- }
+ $result = $qb->insertIfNotExists('groups', [
+ 'gid' => $gid,
+ ]);
// Add to cache
$this->groupCache[$gid] = $gid;
- return true;
+ return $result === 1;
}
/**