diff options
Diffstat (limited to 'lib/Share')
-rw-r--r-- | lib/Share/RoomShareProvider.php | 178 |
1 files changed, 89 insertions, 89 deletions
diff --git a/lib/Share/RoomShareProvider.php b/lib/Share/RoomShareProvider.php index 66d1c3d80..d6ad8ab7e 100644 --- a/lib/Share/RoomShareProvider.php +++ b/lib/Share/RoomShareProvider.php @@ -238,26 +238,26 @@ class RoomShareProvider implements IShareProvider { string $token, ?\DateTime $expirationDate ): int { - $qb = $this->dbConnection->getQueryBuilder(); - $qb->insert('share') - ->setValue('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM)) - ->setValue('share_with', $qb->createNamedParameter($shareWith)) - ->setValue('uid_initiator', $qb->createNamedParameter($sharedBy)) - ->setValue('uid_owner', $qb->createNamedParameter($shareOwner)) - ->setValue('item_type', $qb->createNamedParameter($itemType)) - ->setValue('item_source', $qb->createNamedParameter($itemSource)) - ->setValue('file_source', $qb->createNamedParameter($itemSource)) - ->setValue('file_target', $qb->createNamedParameter($target)) - ->setValue('permissions', $qb->createNamedParameter($permissions)) - ->setValue('token', $qb->createNamedParameter($token)) - ->setValue('stime', $qb->createNamedParameter($this->timeFactory->getTime())); + $insert = $this->dbConnection->getQueryBuilder(); + $insert->insert('share') + ->setValue('share_type', $insert->createNamedParameter(IShare::TYPE_ROOM)) + ->setValue('share_with', $insert->createNamedParameter($shareWith)) + ->setValue('uid_initiator', $insert->createNamedParameter($sharedBy)) + ->setValue('uid_owner', $insert->createNamedParameter($shareOwner)) + ->setValue('item_type', $insert->createNamedParameter($itemType)) + ->setValue('item_source', $insert->createNamedParameter($itemSource)) + ->setValue('file_source', $insert->createNamedParameter($itemSource)) + ->setValue('file_target', $insert->createNamedParameter($target)) + ->setValue('permissions', $insert->createNamedParameter($permissions)) + ->setValue('token', $insert->createNamedParameter($token)) + ->setValue('stime', $insert->createNamedParameter($this->timeFactory->getTime())); if ($expirationDate !== null) { - $qb->setValue('expiration', $qb->createNamedParameter($expirationDate, 'datetime')); + $insert->setValue('expiration', $insert->createNamedParameter($expirationDate, 'datetime')); } - $qb->execute(); - $id = $qb->getLastInsertId(); + $insert->executeStatement(); + $id = $insert->getLastInsertId(); return $id; } @@ -275,7 +275,7 @@ class RoomShareProvider implements IShareProvider { ->from('share') ->where($qb->expr()->eq('id', $qb->createNamedParameter($id))); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $data = $cursor->fetch(); $cursor->closeCursor(); @@ -339,39 +339,39 @@ class RoomShareProvider implements IShareProvider { * @return IShare The share object */ public function update(IShare $share): IShare { - $qb = $this->dbConnection->getQueryBuilder(); - $qb->update('share') - ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId()))) - ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner())) - ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy())) - ->set('permissions', $qb->createNamedParameter($share->getPermissions())) - ->set('item_source', $qb->createNamedParameter($share->getNode()->getId())) - ->set('file_source', $qb->createNamedParameter($share->getNode()->getId())) - ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE)) - ->execute(); + $update = $this->dbConnection->getQueryBuilder(); + $update->update('share') + ->where($update->expr()->eq('id', $update->createNamedParameter($share->getId()))) + ->set('uid_owner', $update->createNamedParameter($share->getShareOwner())) + ->set('uid_initiator', $update->createNamedParameter($share->getSharedBy())) + ->set('permissions', $update->createNamedParameter($share->getPermissions())) + ->set('item_source', $update->createNamedParameter($share->getNode()->getId())) + ->set('file_source', $update->createNamedParameter($share->getNode()->getId())) + ->set('expiration', $update->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE)) + ->executeStatement(); /* * Update all user defined group shares */ - $qb = $this->dbConnection->getQueryBuilder(); - $qb->update('share') - ->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId()))) - ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner())) - ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy())) - ->set('item_source', $qb->createNamedParameter($share->getNode()->getId())) - ->set('file_source', $qb->createNamedParameter($share->getNode()->getId())) - ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE)) - ->execute(); + $update = $this->dbConnection->getQueryBuilder(); + $update->update('share') + ->where($update->expr()->eq('parent', $update->createNamedParameter($share->getId()))) + ->set('uid_owner', $update->createNamedParameter($share->getShareOwner())) + ->set('uid_initiator', $update->createNamedParameter($share->getSharedBy())) + ->set('item_source', $update->createNamedParameter($share->getNode()->getId())) + ->set('file_source', $update->createNamedParameter($share->getNode()->getId())) + ->set('expiration', $update->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE)) + ->executeStatement(); /* * Now update the permissions for all children that have not set it to 0 */ - $qb = $this->dbConnection->getQueryBuilder(); - $qb->update('share') - ->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId()))) - ->andWhere($qb->expr()->neq('permissions', $qb->createNamedParameter(0))) - ->set('permissions', $qb->createNamedParameter($share->getPermissions())) - ->execute(); + $update = $this->dbConnection->getQueryBuilder(); + $update->update('share') + ->where($update->expr()->eq('parent', $update->createNamedParameter($share->getId()))) + ->andWhere($update->expr()->neq('permissions', $update->createNamedParameter(0))) + ->set('permissions', $update->createNamedParameter($share->getPermissions())) + ->executeStatement(); return $share; } @@ -382,13 +382,13 @@ class RoomShareProvider implements IShareProvider { * @param IShare $share */ public function delete(IShare $share): void { - $qb = $this->dbConnection->getQueryBuilder(); - $qb->delete('share') - ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId()))); + $delete = $this->dbConnection->getQueryBuilder(); + $delete->delete('share') + ->where($delete->expr()->eq('id', $delete->createNamedParameter($share->getId()))); - $qb->orWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId()))); + $delete->orWhere($delete->expr()->eq('parent', $delete->createNamedParameter($share->getId()))); - $qb->execute(); + $delete->executeStatement(); } /** @@ -412,7 +412,7 @@ class RoomShareProvider implements IShareProvider { $qb->expr()->eq('item_type', $qb->createNamedParameter('file')), $qb->expr()->eq('item_type', $qb->createNamedParameter('folder')) )) - ->execute(); + ->executeQuery(); $data = $stmt->fetch(); $stmt->closeCursor(); @@ -433,14 +433,14 @@ class RoomShareProvider implements IShareProvider { 'file_target' => $qb->createNamedParameter($share->getTarget()), 'permissions' => $qb->createNamedParameter(0), 'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()), - ])->execute(); + ])->executeStatement(); } elseif ($data['permissions'] !== 0) { // Already a userroom share. Update it. $qb = $this->dbConnection->getQueryBuilder(); $qb->update('share') ->set('permissions', $qb->createNamedParameter(0)) ->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id']))) - ->execute(); + ->executeStatement(); } } @@ -459,24 +459,24 @@ class RoomShareProvider implements IShareProvider { ->where( $qb->expr()->eq('id', $qb->createNamedParameter($share->getId())) ); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $data = $cursor->fetch(); $cursor->closeCursor(); $originalPermission = $data['permissions']; - $qb = $this->dbConnection->getQueryBuilder(); - $qb->update('share') - ->set('permissions', $qb->createNamedParameter($originalPermission)) + $update = $this->dbConnection->getQueryBuilder(); + $update->update('share') + ->set('permissions', $update->createNamedParameter($originalPermission)) ->where( - $qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())) + $update->expr()->eq('parent', $update->createNamedParameter($share->getId())) )->andWhere( - $qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERROOM)) + $update->expr()->eq('share_type', $update->createNamedParameter(self::SHARE_TYPE_USERROOM)) )->andWhere( - $qb->expr()->eq('share_with', $qb->createNamedParameter($recipient)) + $update->expr()->eq('share_with', $update->createNamedParameter($recipient)) ); - $qb->execute(); + $update->executeStatement(); return $this->getShareById($share->getId(), $recipient); } @@ -505,7 +505,7 @@ class RoomShareProvider implements IShareProvider { $qb->expr()->eq('item_type', $qb->createNamedParameter('folder')) )) ->setMaxResults(1) - ->execute(); + ->executeQuery(); $data = $stmt->fetch(); $stmt->closeCursor(); @@ -526,14 +526,14 @@ class RoomShareProvider implements IShareProvider { 'file_target' => $qb->createNamedParameter($share->getTarget()), 'permissions' => $qb->createNamedParameter($share->getPermissions()), 'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()), - ])->execute(); + ])->executeStatement(); } else { // Already a userroom share. Update it. $qb = $this->dbConnection->getQueryBuilder(); $qb->update('share') ->set('file_target', $qb->createNamedParameter($share->getTarget())) ->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id']))) - ->execute(); + ->executeStatement(); } return $share; @@ -579,7 +579,7 @@ class RoomShareProvider implements IShareProvider { $qb->orderBy('s.id'); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $shares = []; while ($data = $cursor->fetch()) { $shares[$data['fileid']][] = $this->createShareObject($data); @@ -632,7 +632,7 @@ class RoomShareProvider implements IShareProvider { $qb->setFirstResult($offset); $qb->orderBy('id'); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $shares = []; while ($data = $cursor->fetch()) { $shares[] = $this->createShareObject($data); @@ -664,7 +664,7 @@ class RoomShareProvider implements IShareProvider { ->where($qb->expr()->eq('s.id', $qb->createNamedParameter($id))) ->andWhere($qb->expr()->eq('s.share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $data = $cursor->fetch(); $cursor->closeCursor(); @@ -729,7 +729,7 @@ class RoomShareProvider implements IShareProvider { $qb->expr()->eq('item_type', $qb->createNamedParameter('folder')) )); - $stmt = $query->execute(); + $stmt = $query->executeQuery(); while ($data = $stmt->fetch()) { $shareMap[$data['parent']]->setPermissions((int)$data['permissions']); @@ -759,7 +759,7 @@ class RoomShareProvider implements IShareProvider { ->from('share') ->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($path->getId()))) ->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))) - ->execute(); + ->executeQuery(); $shares = []; while ($data = $cursor->fetch()) { @@ -826,7 +826,7 @@ class RoomShareProvider implements IShareProvider { $qb->expr()->eq('s.item_type', $qb->createNamedParameter('folder')) )); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); while ($data = $cursor->fetch()) { if (!$this->isAccessibleResult($data)) { continue; @@ -879,7 +879,7 @@ class RoomShareProvider implements IShareProvider { ->from('share') ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))) ->andWhere($qb->expr()->eq('token', $qb->createNamedParameter($token))) - ->execute(); + ->executeQuery(); $data = $cursor->fetch(); @@ -964,7 +964,7 @@ class RoomShareProvider implements IShareProvider { $qb->expr()->eq('item_type', $qb->createNamedParameter('file')), $qb->expr()->eq('item_type', $qb->createNamedParameter('folder')) )); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $users = []; while ($row = $cursor->fetch()) { @@ -1054,7 +1054,7 @@ class RoomShareProvider implements IShareProvider { ->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))) ->orderBy('id'); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); while ($data = $cursor->fetch()) { $children[] = $this->createShareObject($data); } @@ -1087,7 +1087,7 @@ class RoomShareProvider implements IShareProvider { $qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($user))); } - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); $ids = []; while ($row = $cursor->fetch()) { $ids[] = (int)$row['id']; @@ -1100,31 +1100,31 @@ class RoomShareProvider implements IShareProvider { $qb->delete('share') ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERROOM))) ->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY))); - $qb->execute(); + $qb->executeStatement(); } } // Now delete all the original room shares - $qb = $this->dbConnection->getQueryBuilder(); - $qb->delete('share') - ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))) - ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($roomToken))); + $delete = $this->dbConnection->getQueryBuilder(); + $delete->delete('share') + ->where($delete->expr()->eq('share_type', $delete->createNamedParameter(IShare::TYPE_ROOM))) + ->andWhere($delete->expr()->eq('share_with', $delete->createNamedParameter($roomToken))); if ($user !== null) { - $qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($user))); + $delete->andWhere($delete->expr()->eq('uid_initiator', $delete->createNamedParameter($user))); } - $qb->execute(); + $delete->executeStatement(); // Finally delete all custom room shares leftovers for the given user if ($user !== null) { - $qb = $this->dbConnection->getQueryBuilder(); - $qb->select('id') + $query = $this->dbConnection->getQueryBuilder(); + $query->select('id') ->from('share') - ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_ROOM))) - ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($roomToken))); + ->where($query->expr()->eq('share_type', $query->createNamedParameter(IShare::TYPE_ROOM))) + ->andWhere($query->expr()->eq('share_with', $query->createNamedParameter($roomToken))); - $cursor = $qb->execute(); + $cursor = $query->executeQuery(); $ids = []; while ($row = $cursor->fetch()) { $ids[] = (int)$row['id']; @@ -1134,11 +1134,11 @@ class RoomShareProvider implements IShareProvider { if (!empty($ids)) { $chunks = array_chunk($ids, 100); foreach ($chunks as $chunk) { - $qb->delete('share') - ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERROOM))) - ->andWhere($qb->expr()->in('share_with', $qb->createNamedParameter($user))) - ->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY))); - $qb->execute(); + $delete->delete('share') + ->where($delete->expr()->eq('share_type', $delete->createNamedParameter(self::SHARE_TYPE_USERROOM))) + ->andWhere($delete->expr()->in('share_with', $delete->createNamedParameter($user))) + ->andWhere($delete->expr()->in('parent', $delete->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY))); + $delete->executeStatement(); } } } @@ -1162,7 +1162,7 @@ class RoomShareProvider implements IShareProvider { ) ); - $cursor = $qb->execute(); + $cursor = $qb->executeQuery(); while ($data = $cursor->fetch()) { $share = $this->createShareObject($data); |