Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nextcloud/spreed.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/lib/Share
diff options
context:
space:
mode:
authorVitor Mattos <vitor@php.rio>2021-10-19 14:15:51 +0300
committerVitor Mattos <vitor@php.rio>2021-10-19 14:54:14 +0300
commitdc518c46a710e13485feb0977b0f1343eea6d2ec (patch)
treec248315a5199bc01542b927ba7d0a6fc3ae6fac9 /lib/Share
parentd6c536d54589cfcf70d481d3035068a9910a14aa (diff)
replace execute by executeQuery of QueryBuilder
Signed-off-by: Vitor Mattos <vitor@php.rio>
Diffstat (limited to 'lib/Share')
-rw-r--r--lib/Share/RoomShareProvider.php178
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);