diff options
author | Vitor Mattos <vitor@php.rio> | 2021-10-19 14:15:51 +0300 |
---|---|---|
committer | Vitor Mattos <vitor@php.rio> | 2021-10-19 14:54:14 +0300 |
commit | dc518c46a710e13485feb0977b0f1343eea6d2ec (patch) | |
tree | c248315a5199bc01542b927ba7d0a6fc3ae6fac9 /lib | |
parent | d6c536d54589cfcf70d481d3035068a9910a14aa (diff) |
replace execute by executeQuery of QueryBuilder
Signed-off-by: Vitor Mattos <vitor@php.rio>
Diffstat (limited to 'lib')
22 files changed, 363 insertions, 363 deletions
diff --git a/lib/Command/ActiveCalls.php b/lib/Command/ActiveCalls.php index 49282d167..72643c67c 100644 --- a/lib/Command/ActiveCalls.php +++ b/lib/Command/ActiveCalls.php @@ -57,7 +57,7 @@ class ActiveCalls extends Base { ->from('talk_rooms') ->where($query->expr()->isNotNull('active_since')); - $result = $query->execute(); + $result = $query->executeQuery(); $numCalls = (int) $result->fetchColumn(); $result->closeCursor(); @@ -72,7 +72,7 @@ class ActiveCalls extends Base { ->where($query->expr()->gt('in_call', $query->createNamedParameter(Participant::FLAG_DISCONNECTED))) ->andWhere($query->expr()->gt('last_ping', $query->createNamedParameter(time() - 60))); - $result = $query->execute(); + $result = $query->executeQuery(); $numParticipants = (int) $result->fetchColumn(); $result->closeCursor(); diff --git a/lib/Manager.php b/lib/Manager.php index f414c57c0..0422ab1fc 100644 --- a/lib/Manager.php +++ b/lib/Manager.php @@ -126,7 +126,7 @@ class Manager { $helper->selectRoomsTable($query); $query->from('talk_rooms', 'r'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { if ($row['token'] === null) { // FIXME Temporary solution for the Talk6 release @@ -251,7 +251,7 @@ class Manager { $query->from('talk_rooms', 'r') ->where($query->expr()->isNotNull('r.assigned_hpb')); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $room = $this->createRoomObject($row); if (!$this->participantService->hasActiveSessions($room)) { @@ -284,7 +284,7 @@ class Manager { $query->setMaxResults($limit) ->setFirstResult($offset) ->orderBy('r.token', 'ASC'); - $result = $query->execute(); + $result = $query->executeQuery(); $rooms = []; while ($row = $result->fetch()) { @@ -342,7 +342,7 @@ class Manager { $this->loadLastMessageInfo($query); } - $result = $query->execute(); + $result = $query->executeQuery(); $rooms = []; while ($row = $result->fetch()) { if ($row['token'] === null) { @@ -373,7 +373,7 @@ class Manager { ->where($query->expr()->eq('r.type', $query->createNamedParameter(Room::TYPE_ONE_TO_ONE))) ->andWhere($query->expr()->like('r.name', $query->createNamedParameter('%' . $this->db->escapeLikeParameter(json_encode($userId)) . '%'))); - $result = $query->execute(); + $result = $query->executeQuery(); $rooms = []; while ($row = $result->fetch()) { if ($row['token'] === null) { @@ -401,7 +401,7 @@ class Manager { ->where($query->expr()->eq('a.actor_id', $query->createNamedParameter($userId))) ->andWhere($query->expr()->eq('a.actor_type', $query->createNamedParameter(Attendee::ACTOR_USERS))); - $result = $query->execute(); + $result = $query->executeQuery(); $roomTokens = []; while ($row = $result->fetch()) { if ($row['token'] === null) { @@ -450,7 +450,7 @@ class Manager { ); } - $result = $query->execute(); + $result = $query->executeQuery(); $rooms = []; while ($row = $result->fetch()) { $room = $this->createRoomObject($row); @@ -487,7 +487,7 @@ class Manager { ->andWhere($query->expr()->isNotNull('a.id')); } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -558,7 +558,7 @@ class Manager { $this->loadLastMessageInfo($query); } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -608,7 +608,7 @@ class Manager { $query->from('talk_rooms', 'r') ->where($query->expr()->eq('r.id', $query->createNamedParameter($roomId, IQueryBuilder::PARAM_INT))); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -659,7 +659,7 @@ class Manager { )); } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -705,7 +705,7 @@ class Manager { } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -735,7 +735,7 @@ class Manager { ->where($query->expr()->eq('r.object_type', $query->createNamedParameter($objectType))) ->andWhere($query->expr()->eq('r.object_id', $query->createNamedParameter($objectId))); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -773,7 +773,7 @@ class Manager { ->where($query->expr()->eq('s.session_id', $query->createNamedParameter($sessionId))) ->setMaxResults(1); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -825,7 +825,7 @@ class Manager { ->where($query->expr()->eq('r.type', $query->createNamedParameter(Room::TYPE_ONE_TO_ONE, IQueryBuilder::PARAM_INT))) ->andWhere($query->expr()->eq('r.name', $query->createNamedParameter($name))); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -855,7 +855,7 @@ class Manager { ->where($query->expr()->eq('r.type', $query->createNamedParameter(Room::TYPE_CHANGELOG, IQueryBuilder::PARAM_INT))) ->andWhere($query->expr()->eq('r.name', $query->createNamedParameter($userId))); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -899,23 +899,23 @@ class Manager { public function createRoom(int $type, string $name = '', string $objectType = '', string $objectId = ''): Room { $token = $this->getNewToken(); - $query = $this->db->getQueryBuilder(); - $query->insert('talk_rooms') + $insert = $this->db->getQueryBuilder(); + $insert->insert('talk_rooms') ->values( [ - 'name' => $query->createNamedParameter($name), - 'type' => $query->createNamedParameter($type, IQueryBuilder::PARAM_INT), - 'token' => $query->createNamedParameter($token), + 'name' => $insert->createNamedParameter($name), + 'type' => $insert->createNamedParameter($type, IQueryBuilder::PARAM_INT), + 'token' => $insert->createNamedParameter($token), ] ); if (!empty($objectType) && !empty($objectId)) { - $query->setValue('object_type', $query->createNamedParameter($objectType)) - ->setValue('object_id', $query->createNamedParameter($objectId)); + $insert->setValue('object_type', $insert->createNamedParameter($objectType)) + ->setValue('object_id', $insert->createNamedParameter($objectId)); } - $query->execute(); - $roomId = $query->getLastInsertId(); + $insert->executeStatement(); + $roomId = $insert->getLastInsertId(); $room = $this->getRoomById($roomId); @@ -1118,7 +1118,7 @@ class Manager { } $query->setParameter('token', $token); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); diff --git a/lib/Migration/CacheUserDisplayNames.php b/lib/Migration/CacheUserDisplayNames.php index bae450b35..e86f9895e 100644 --- a/lib/Migration/CacheUserDisplayNames.php +++ b/lib/Migration/CacheUserDisplayNames.php @@ -61,7 +61,7 @@ class CacheUserDisplayNames implements IRepairStep { ->andWhere($query->expr()->eq('display_name', $query->createNamedParameter(''))) ->groupBy('actor_id'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $user = $this->userManager->get($row['actor_id']); if (!$user instanceof IUser) { @@ -71,7 +71,7 @@ class CacheUserDisplayNames implements IRepairStep { $update->setParameter('displayName', $user->getDisplayName()) ->setParameter('actorType', Attendee::ACTOR_USERS) ->setParameter('actorId', $row['actor_id']); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Migration/FixNamespaceInDatabaseTables.php b/lib/Migration/FixNamespaceInDatabaseTables.php index 4d098015c..62a4d11f1 100644 --- a/lib/Migration/FixNamespaceInDatabaseTables.php +++ b/lib/Migration/FixNamespaceInDatabaseTables.php @@ -53,7 +53,7 @@ class FixNamespaceInDatabaseTables implements IRepairStep { '%' . $this->connection->escapeLikeParameter('Spreed'). '%' ))); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $oldClass = $row['class']; if (strpos($oldClass, 'OCA\\Spreed\\') !== 0) { @@ -64,7 +64,7 @@ class FixNamespaceInDatabaseTables implements IRepairStep { $update->setParameter('newClass', $newClass) ->setParameter('id', $row['id']); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Migration/Version10000Date20201015134000.php b/lib/Migration/Version10000Date20201015134000.php index daf2f3679..b3f4415a5 100644 --- a/lib/Migration/Version10000Date20201015134000.php +++ b/lib/Migration/Version10000Date20201015134000.php @@ -204,7 +204,7 @@ class Version10000Date20201015134000 extends SimpleMigrationStep { ->andWhere($query->expr()->isNotNull('user_id')); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $lastJoinedCall = 0; if (!empty($row['last_joined_call'])) { @@ -224,7 +224,7 @@ class Version10000Date20201015134000 extends SimpleMigrationStep { ; try { - $insert->execute(); + $insert->executeStatement(); } catch (\Exception $e) { if (class_exists(UniqueConstraintViolationException::class) && $e instanceof UniqueConstraintViolationException) { diff --git a/lib/Migration/Version11000Date20200922161218.php b/lib/Migration/Version11000Date20200922161218.php index 16bed5732..c05399710 100644 --- a/lib/Migration/Version11000Date20200922161218.php +++ b/lib/Migration/Version11000Date20200922161218.php @@ -84,7 +84,7 @@ class Version11000Date20200922161218 extends SimpleMigrationStep { $bridges = []; $query->select('id', 'json_values') ->from('talk_bridges'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $bridges[] = [ 'id' => $row['id'], @@ -97,12 +97,12 @@ class Version11000Date20200922161218 extends SimpleMigrationStep { return; } - $query = $this->connection->getQueryBuilder(); - $query->update('talk_bridges') - ->set('enabled', $query->createParameter('enabled')) - ->set('pid', $query->createParameter('pid')) - ->set('json_values', $query->createParameter('json_values')) - ->where($query->expr()->eq('id', $query->createParameter('id'))); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_bridges') + ->set('enabled', $update->createParameter('enabled')) + ->set('pid', $update->createParameter('pid')) + ->set('json_values', $update->createParameter('json_values')) + ->where($update->expr()->eq('id', $update->createParameter('id'))); foreach ($bridges as $bridge) { $values = json_decode($bridge['json_values'], true); @@ -111,11 +111,11 @@ class Version11000Date20200922161218 extends SimpleMigrationStep { $newValues = $values['parts'] ?: []; $encodedNewValues = json_encode($newValues); - $query->setParameter('enabled', $intEnabled, IQueryBuilder::PARAM_INT) + $update->setParameter('enabled', $intEnabled, IQueryBuilder::PARAM_INT) ->setParameter('pid', $values['pid'], IQueryBuilder::PARAM_INT) ->setParameter('json_values', $encodedNewValues, IQueryBuilder::PARAM_STR) ->setParameter('id', $bridge['id'], IQueryBuilder::PARAM_INT); - $query->execute(); + $update->executeStatement(); } } } diff --git a/lib/Migration/Version2000Date20171026140256.php b/lib/Migration/Version2000Date20171026140256.php index 5f8b61efa..b364eb83e 100644 --- a/lib/Migration/Version2000Date20171026140256.php +++ b/lib/Migration/Version2000Date20171026140256.php @@ -70,7 +70,7 @@ class Version2000Date20171026140256 extends SimpleMigrationStep { $query = $this->connection->getQueryBuilder(); $query->select('*') ->from('spreedme_rooms'); - $result = $query->execute(); + $result = $query->executeQuery(); $output->startProgress(); while ($row = $result->fetch()) { @@ -81,7 +81,7 @@ class Version2000Date20171026140256 extends SimpleMigrationStep { } $update->setParameter('room_id', (int) $row['id'], IQueryBuilder::PARAM_INT) - ->execute(); + ->executeStatement(); } $output->finishProgress(); } diff --git a/lib/Migration/Version2000Date20171026140257.php b/lib/Migration/Version2000Date20171026140257.php index ff74b1d5a..1e31c23a9 100644 --- a/lib/Migration/Version2000Date20171026140257.php +++ b/lib/Migration/Version2000Date20171026140257.php @@ -79,7 +79,7 @@ class Version2000Date20171026140257 extends SimpleMigrationStep { ->from('spreedme_rooms') ->where($query->expr()->emptyString('token')) ->orWhere($query->expr()->isNull('token')); - $result = $query->execute(); + $result = $query->executeQuery(); $output->startProgress(); while ($row = $result->fetch()) { @@ -89,7 +89,7 @@ class Version2000Date20171026140257 extends SimpleMigrationStep { $update->setParameter('token', $token) ->setParameter('room_id', (int) $row['id'], IQueryBuilder::PARAM_INT) - ->execute(); + ->executeStatement(); } $output->finishProgress(); } diff --git a/lib/Migration/Version2001Date20170707115443.php b/lib/Migration/Version2001Date20170707115443.php index 69316cc02..e80c78276 100644 --- a/lib/Migration/Version2001Date20170707115443.php +++ b/lib/Migration/Version2001Date20170707115443.php @@ -88,7 +88,7 @@ class Version2001Date20170707115443 extends SimpleMigrationStep { $query->selectAlias($query->createFunction('COUNT(*)'), 'num_rooms') ->from('spreedme_rooms'); - $result = $query->execute(); + $result = $query->executeQuery(); $return = (int) $result->fetch(); $result->closeCursor(); $numRooms = (int) $return['num_rooms']; @@ -100,7 +100,7 @@ class Version2001Date20170707115443 extends SimpleMigrationStep { $query->select('id') ->from('spreedme_rooms') ->where($query->expr()->eq('type', $query->createNamedParameter(Room::TYPE_ONE_TO_ONE))); - $result = $query->execute(); + $result = $query->executeQuery(); $one2oneRooms = []; while ($row = $result->fetch()) { @@ -136,7 +136,7 @@ class Version2001Date20170707115443 extends SimpleMigrationStep { ->where($update->expr()->in('roomId', $update->createNamedParameter($one2oneRooms, IQueryBuilder::PARAM_INT_ARRAY))); } - return (int) $update->execute(); + return (int) $update->executeStatement(); } /** @@ -160,6 +160,6 @@ class Version2001Date20170707115443 extends SimpleMigrationStep { $update->andWhere($update->expr()->notIn('roomId', $update->createNamedParameter($one2oneRooms, IQueryBuilder::PARAM_INT_ARRAY))); } - return (int) $update->execute(); + return (int) $update->executeStatement(); } } diff --git a/lib/Migration/Version2001Date20171026134605.php b/lib/Migration/Version2001Date20171026134605.php index 370d1c93f..e5294bba7 100644 --- a/lib/Migration/Version2001Date20171026134605.php +++ b/lib/Migration/Version2001Date20171026134605.php @@ -195,14 +195,14 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $query->select('*') ->from('spreedme_rooms'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $insert ->setParameter('name', $row['name']) ->setParameter('token', $row['token']) ->setParameter('type', (int) $row['type'], IQueryBuilder::PARAM_INT) ->setParameter('password', $row['password']); - $insert->execute(); + $insert->executeStatement(); $roomIdMap[(int)$row['id']] = $insert->getLastInsertId(); } @@ -240,7 +240,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $query->select('*') ->from('spreedme_room_participants'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { if (!isset($roomIdMap[(int) $row['roomId']])) { continue; @@ -257,7 +257,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { } else { $insert->setParameter('participantType', (int) $row['participanttype'], IQueryBuilder::PARAM_INT); } - $insert->execute(); + $insert->executeStatement(); } $result->closeCursor(); } @@ -282,7 +282,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->andWhere($query->expr()->eq('object_type', $query->createNamedParameter('room'))); try { - $result = $query->execute(); + $result = $query->executeQuery(); } catch (TableNotFoundException $e) { return; } @@ -292,7 +292,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $delete ->setParameter('id', (int) $row['notification_id']) ; - $delete->execute(); + $delete->executeStatement(); continue; } @@ -300,7 +300,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->setParameter('id', (int) $row['notification_id']) ->setParameter('newId', $roomIdMap[(int) $row['object_id']]) ; - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } @@ -327,7 +327,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->andWhere($query->expr()->eq('object_type', $query->createNamedParameter('room'))); try { - $result = $query->execute(); + $result = $query->executeQuery(); } catch (TableNotFoundException $e) { return; } catch (InvalidFieldNameException $e) { @@ -339,7 +339,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $delete ->setParameter('id', (int) $row['activity_id']) ; - $delete->execute(); + $delete->executeStatement(); continue; } @@ -349,7 +349,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $delete ->setParameter('id', (int) $row['activity_id']) ; - $delete->execute(); + $delete->executeStatement(); continue; } @@ -360,7 +360,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->setParameter('newId', $roomIdMap[(int) $row['object_id']]) ->setParameter('subjectParams', json_encode($params)) ; - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } @@ -385,7 +385,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->andWhere($query->expr()->eq('amq_type', $query->createNamedParameter('spreed'))); try { - $result = $query->execute(); + $result = $query->executeQuery(); } catch (TableNotFoundException $e) { return; } catch (InvalidFieldNameException $e) { @@ -399,7 +399,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { $delete ->setParameter('id', (int) $row['mail_id']) ; - $delete->execute(); + $delete->executeStatement(); continue; } @@ -409,7 +409,7 @@ class Version2001Date20171026134605 extends SimpleMigrationStep { ->setParameter('id', (int) $row['mail_id']) ->setParameter('subjectParams', json_encode($params)) ; - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Migration/Version2001Date20180103144447.php b/lib/Migration/Version2001Date20180103144447.php index 096d1601d..05f547d08 100644 --- a/lib/Migration/Version2001Date20180103144447.php +++ b/lib/Migration/Version2001Date20180103144447.php @@ -127,7 +127,7 @@ class Version2001Date20180103144447 extends SimpleMigrationStep { $update->update('talk_rooms') ->set('active_since', 'activeSince') ->set('active_guests', 'activeGuests'); - $update->execute(); + $update->executeStatement(); $update = $this->connection->getQueryBuilder(); $update->update('talk_participants') @@ -137,13 +137,13 @@ class Version2001Date20180103144447 extends SimpleMigrationStep { ->set('session_id', 'sessionId') ->set('participant_type', 'participantType') ->set('in_call', 'inCall'); - $update->execute(); + $update->executeStatement(); } else { $update = $this->connection->getQueryBuilder(); $update->update('talk_rooms') ->set('active_since', 'activesince') ->set('active_guests', 'activeguests'); - $update->execute(); + $update->executeStatement(); $update = $this->connection->getQueryBuilder(); $update->update('talk_participants') @@ -153,7 +153,7 @@ class Version2001Date20180103144447 extends SimpleMigrationStep { ->set('session_id', 'sessionid') ->set('participant_type', 'participanttype') ->set('in_call', 'incall'); - $update->execute(); + $update->executeStatement(); } } } diff --git a/lib/Migration/Version3003Date20180718112436.php b/lib/Migration/Version3003Date20180718112436.php index 73e92fdf3..fbab50866 100644 --- a/lib/Migration/Version3003Date20180718112436.php +++ b/lib/Migration/Version3003Date20180718112436.php @@ -82,12 +82,12 @@ class Version3003Date20180718112436 extends SimpleMigrationStep { ->where($query->expr()->eq('object_type', $query->createNamedParameter('chat'))) ->groupBy('object_id'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $lastActivity = new \DateTime($row['last_activity']); $update->setParameter('activity', $lastActivity, IQueryBuilder::PARAM_DATE) ->setParameter('room', $row['object_id']); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Migration/Version3003Date20180718133519.php b/lib/Migration/Version3003Date20180718133519.php index e40272e4f..d54587874 100644 --- a/lib/Migration/Version3003Date20180718133519.php +++ b/lib/Migration/Version3003Date20180718133519.php @@ -79,11 +79,11 @@ class Version3003Date20180718133519 extends SimpleMigrationStep { ->where($query->expr()->eq('object_type', $query->createNamedParameter('chat'))) ->groupBy('object_id'); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $update->setParameter('message', $row['message']) ->setParameter('room', $row['object_id']); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Migration/Version7000Date20190724121136.php b/lib/Migration/Version7000Date20190724121136.php index 20de3a34d..5c3311515 100644 --- a/lib/Migration/Version7000Date20190724121136.php +++ b/lib/Migration/Version7000Date20190724121136.php @@ -96,12 +96,12 @@ class Version7000Date20190724121136 extends SimpleMigrationStep { ->where($update->expr()->eq('user_id', $update->createParameter('user_id'))) ->andWhere($update->expr()->eq('room_id', $update->createParameter('room_id'))); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $update->setParameter('message_id', (int) $row['last_comment'], IQueryBuilder::PARAM_INT) ->setParameter('user_id', $row['user_id']) ->setParameter('room_id', (int) $row['object_id'], IQueryBuilder::PARAM_INT); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); @@ -110,11 +110,11 @@ class Version7000Date20190724121136 extends SimpleMigrationStep { * as the comment was posted (author only), we set the read marker to -1 * for all users and in case of -1 we calculate the marker on the next request. */ - $default = $this->connection->getQueryBuilder(); - $default->update('talk_participants') - ->set('last_read_message', $default->createNamedParameter(-1)) - ->where($default->expr()->isNotNull('user_id')) - ->andWhere($default->expr()->eq('last_read_message', $default->createNamedParameter(0))); - $default->execute(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_participants') + ->set('last_read_message', $update->createNamedParameter(-1)) + ->where($update->expr()->isNotNull('user_id')) + ->andWhere($update->expr()->eq('last_read_message', $update->createNamedParameter(0))); + $update->executeStatement(); } } diff --git a/lib/Migration/Version7000Date20190724121137.php b/lib/Migration/Version7000Date20190724121137.php index 441d50773..8d6c48543 100644 --- a/lib/Migration/Version7000Date20190724121137.php +++ b/lib/Migration/Version7000Date20190724121137.php @@ -63,12 +63,12 @@ class Version7000Date20190724121137 extends SimpleMigrationStep { ->where($update->expr()->eq('user_id', $update->createParameter('user_id'))) ->andWhere($update->expr()->eq('room_id', $update->createParameter('room_id'))); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $update->setParameter('message_id', (int) $row['last_mention_message'], IQueryBuilder::PARAM_INT) ->setParameter('user_id', $row['user_id']) ->setParameter('room_id', (int) $row['room_id'], IQueryBuilder::PARAM_INT); - $update->execute(); + $update->executeStatement(); } $result->closeCursor(); } diff --git a/lib/Model/AttendeeMapper.php b/lib/Model/AttendeeMapper.php index 758e57694..b8f2a74ba 100644 --- a/lib/Model/AttendeeMapper.php +++ b/lib/Model/AttendeeMapper.php @@ -152,7 +152,7 @@ class AttendeeMapper extends QBMapper { $query->andWhere($query->expr()->gte('last_joined_call', $query->createNamedParameter($lastJoinedCall, IQueryBuilder::PARAM_INT))); } - $result = $query->execute(); + $result = $query->executeQuery(); $count = (int) $result->fetchOne(); $result->closeCursor(); @@ -178,7 +178,7 @@ class AttendeeMapper extends QBMapper { $query->andWhere($query->expr()->in('participant_type', $query->createNamedParameter($participantType, IQueryBuilder::PARAM_INT_ARRAY))); } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -190,11 +190,11 @@ class AttendeeMapper extends QBMapper { * @return int Number of deleted entities */ public function deleteByIds(array $ids): int { - $query = $this->db->getQueryBuilder(); - $query->delete($this->getTableName()) - ->where($query->expr()->in('id', $query->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY))); + $delete = $this->db->getQueryBuilder(); + $delete->delete($this->getTableName()) + ->where($delete->expr()->in('id', $delete->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY))); - return (int) $query->execute(); + return (int) $delete->executeStatement(); } public function modifyPermissions(int $roomId, string $mode, int $newState): void { diff --git a/lib/Model/SessionMapper.php b/lib/Model/SessionMapper.php index afa88109b..ddc5460d2 100644 --- a/lib/Model/SessionMapper.php +++ b/lib/Model/SessionMapper.php @@ -71,11 +71,11 @@ class SessionMapper extends QBMapper { * @return int Number of deleted entities */ public function deleteByAttendeeId(int $attendeeId): int { - $query = $this->db->getQueryBuilder(); - $query->delete($this->getTableName()) - ->where($query->expr()->eq('attendee_id', $query->createNamedParameter($attendeeId, IQueryBuilder::PARAM_INT))); + $delete = $this->db->getQueryBuilder(); + $delete->delete($this->getTableName()) + ->where($delete->expr()->eq('attendee_id', $delete->createNamedParameter($attendeeId, IQueryBuilder::PARAM_INT))); - return (int) $query->execute(); + return (int) $delete->executeStatement(); } /** @@ -83,11 +83,11 @@ class SessionMapper extends QBMapper { * @return int Number of deleted entities */ public function deleteByIds(array $ids): int { - $query = $this->db->getQueryBuilder(); - $query->delete($this->getTableName()) - ->where($query->expr()->in('id', $query->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY))); + $delete = $this->db->getQueryBuilder(); + $delete->delete($this->getTableName()) + ->where($delete->expr()->in('id', $delete->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY))); - return (int) $query->execute(); + return (int) $delete->executeStatement(); } public function createSessionFromRow(array $row): Session { diff --git a/lib/Room.php b/lib/Room.php index 7129391ca..f79d7aabc 100644 --- a/lib/Room.php +++ b/lib/Room.php @@ -485,7 +485,7 @@ class Room { } } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -520,7 +520,7 @@ class Room { ->where($query->expr()->eq('s.session_id', $query->createNamedParameter($sessionId))) ->andWhere($query->expr()->eq('a.room_id', $query->createNamedParameter($this->getId()))) ->setMaxResults(1); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -544,7 +544,7 @@ class Room { ->where($query->expr()->eq('a.pin', $query->createNamedParameter($pin))) ->andWhere($query->expr()->eq('a.room_id', $query->createNamedParameter($this->getId()))) ->setMaxResults(1); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -586,7 +586,7 @@ class Room { } } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -634,7 +634,7 @@ class Room { } } - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -648,17 +648,17 @@ class Room { public function deleteRoom(): void { $event = new RoomEvent($this); $this->dispatcher->dispatch(self::EVENT_BEFORE_ROOM_DELETE, $event); - $query = $this->db->getQueryBuilder(); + $delete = $this->db->getQueryBuilder(); // Delete attendees - $query->delete('talk_attendees') - ->where($query->expr()->eq('room_id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $delete->delete('talk_attendees') + ->where($delete->expr()->eq('room_id', $delete->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $delete->executeStatement(); // Delete room - $query->delete('talk_rooms') - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $delete->delete('talk_rooms') + ->where($delete->expr()->eq('id', $delete->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $delete->executeStatement(); $this->dispatcher->dispatch(self::EVENT_AFTER_ROOM_DELETE, $event); if (class_exists(CriticalActionPerformedEvent::class)) { @@ -683,11 +683,11 @@ class Room { $event = new ModifyRoomEvent($this, 'name', $newName, $oldName); $this->dispatcher->dispatch(self::EVENT_BEFORE_NAME_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('name', $query->createNamedParameter($newName)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('name', $update->createNamedParameter($newName)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->name = $newName; $this->dispatcher->dispatch(self::EVENT_AFTER_NAME_SET, $event); @@ -715,11 +715,11 @@ class Room { $event = new ModifyRoomEvent($this, 'description', $description, $oldDescription); $this->dispatcher->dispatch(self::EVENT_BEFORE_DESCRIPTION_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('description', $query->createNamedParameter($description)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('description', $update->createNamedParameter($description)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->description = $description; $this->dispatcher->dispatch(self::EVENT_AFTER_DESCRIPTION_SET, $event); @@ -741,11 +741,11 @@ class Room { $event = new ModifyRoomEvent($this, 'password', $password); $this->dispatcher->dispatch(self::EVENT_BEFORE_PASSWORD_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('password', $query->createNamedParameter($hash)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('password', $update->createNamedParameter($hash)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->password = $hash; $this->dispatcher->dispatch(self::EVENT_AFTER_PASSWORD_SET, $event); @@ -758,11 +758,11 @@ class Room { * @return bool */ public function setLastActivity(\DateTime $now): bool { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('last_activity', $query->createNamedParameter($now, 'datetime')) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('last_activity', $update->createNamedParameter($now, 'datetime')) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->lastActivity = $now; @@ -777,38 +777,38 @@ class Room { */ public function setActiveSince(\DateTime $since, int $callFlag, bool $isGuest): bool { if ($isGuest && $this->getType() === self::TYPE_PUBLIC) { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('active_guests', $query->createFunction($query->getColumnName('active_guests') . ' + 1')) + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('active_guests', $update->createFunction($update->getColumnName('active_guests') . ' + 1')) ->set( 'call_flag', - $query->expr()->bitwiseOr('call_flag', $callFlag) + $update->expr()->bitwiseOr('call_flag', $callFlag) ) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->activeGuests++; } elseif (!$isGuest) { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') ->set( 'call_flag', - $query->expr()->bitwiseOr('call_flag', $callFlag) + $update->expr()->bitwiseOr('call_flag', $callFlag) ) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); } if ($this->activeSince instanceof \DateTime) { return false; } - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('active_since', $query->createNamedParameter($since, IQueryBuilder::PARAM_DATE)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) - ->andWhere($query->expr()->isNull('active_since')); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('active_since', $update->createNamedParameter($since, IQueryBuilder::PARAM_DATE)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) + ->andWhere($update->expr()->isNull('active_since')); + $update->executeStatement(); $this->activeSince = $since; @@ -816,43 +816,43 @@ class Room { } public function setLastMessage(IComment $message): void { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('last_message', $query->createNamedParameter((int) $message->getId())) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('last_message', $update->createNamedParameter((int) $message->getId())) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->lastMessage = $message; $this->lastMessageId = (int) $message->getId(); } public function resetActiveSince(): bool { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('active_guests', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)) - ->set('active_since', $query->createNamedParameter(null, IQueryBuilder::PARAM_DATE)) - ->set('call_flag', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)) - ->set('call_permissions', $query->createNamedParameter(Attendee::PERMISSIONS_DEFAULT, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) - ->andWhere($query->expr()->isNotNull('active_since')); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('active_guests', $update->createNamedParameter(0, IQueryBuilder::PARAM_INT)) + ->set('active_since', $update->createNamedParameter(null, IQueryBuilder::PARAM_DATE)) + ->set('call_flag', $update->createNamedParameter(0, IQueryBuilder::PARAM_INT)) + ->set('call_permissions', $update->createNamedParameter(Attendee::PERMISSIONS_DEFAULT, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) + ->andWhere($update->expr()->isNotNull('active_since')); $this->activeGuests = 0; $this->activeSince = null; - return (bool) $query->execute(); + return (bool) $update->executeStatement(); } public function setAssignedSignalingServer(?int $signalingServer): bool { - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('assigned_hpb', $query->createNamedParameter($signalingServer)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('assigned_hpb', $update->createNamedParameter($signalingServer)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); if ($signalingServer !== null) { - $query->andWhere($query->expr()->isNull('assigned_hpb')); + $update->andWhere($update->expr()->isNull('assigned_hpb')); } - return (bool) $query->execute(); + return (bool) $update->executeStatement(); } /** @@ -877,21 +877,21 @@ class Room { $event = new ModifyRoomEvent($this, 'type', $newType, $oldType); $this->dispatcher->dispatch(self::EVENT_BEFORE_TYPE_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('type', $query->createNamedParameter($newType, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('type', $update->createNamedParameter($newType, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->type = $newType; if ($oldType === self::TYPE_PUBLIC) { // Kick all guests and users that were not invited - $query = $this->db->getQueryBuilder(); - $query->delete('talk_attendees') - ->where($query->expr()->eq('room_id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) - ->andWhere($query->expr()->in('participant_type', $query->createNamedParameter([Participant::GUEST, Participant::GUEST_MODERATOR, Participant::USER_SELF_JOINED], IQueryBuilder::PARAM_INT_ARRAY))); - $query->execute(); + $delete = $this->db->getQueryBuilder(); + $delete->delete('talk_attendees') + ->where($delete->expr()->eq('room_id', $delete->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))) + ->andWhere($delete->expr()->in('participant_type', $delete->createNamedParameter([Participant::GUEST, Participant::GUEST_MODERATOR, Participant::USER_SELF_JOINED], IQueryBuilder::PARAM_INT_ARRAY))); + $delete->executeStatement(); } $this->dispatcher->dispatch(self::EVENT_AFTER_TYPE_SET, $event); @@ -923,11 +923,11 @@ class Room { $event = new ModifyRoomEvent($this, 'readOnly', $newState, $oldState); $this->dispatcher->dispatch(self::EVENT_BEFORE_READONLY_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('read_only', $query->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('read_only', $update->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->readOnly = $newState; @@ -963,11 +963,11 @@ class Room { $event = new ModifyRoomEvent($this, 'listable', $newState, $oldState); $this->dispatcher->dispatch(self::EVENT_BEFORE_LISTABLE_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('listable', $query->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('listable', $update->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->listable = $newState; @@ -1003,12 +1003,12 @@ class Room { $event = new ModifyLobbyEvent($this, 'lobby', $newState, $oldState, $dateTime, $timerReached); $this->dispatcher->dispatch(self::EVENT_BEFORE_LOBBY_STATE_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('lobby_state', $query->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) - ->set('lobby_timer', $query->createNamedParameter($dateTime, IQueryBuilder::PARAM_DATE)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('lobby_state', $update->createNamedParameter($newState, IQueryBuilder::PARAM_INT)) + ->set('lobby_timer', $update->createNamedParameter($dateTime, IQueryBuilder::PARAM_DATE)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->lobbyState = $newState; @@ -1039,11 +1039,11 @@ class Room { $event = new ModifyRoomEvent($this, 'sipEnabled', $newSipEnabled, $oldSipEnabled); $this->dispatcher->dispatch(self::EVENT_BEFORE_SIP_ENABLED_SET, $event); - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set('sip_enabled', $query->createNamedParameter($newSipEnabled, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->execute(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set('sip_enabled', $update->createNamedParameter($newSipEnabled, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); $this->sipEnabled = $newSipEnabled; @@ -1057,11 +1057,11 @@ class Room { return false; } - $query = $this->db->getQueryBuilder(); - $query->update('talk_rooms') - ->set($level . '_permissions', $query->createNamedParameter($newPermissions, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('id', $query->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); - $query->executeStatement(); + $update = $this->db->getQueryBuilder(); + $update->update('talk_rooms') + ->set($level . '_permissions', $update->createNamedParameter($newPermissions, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('id', $update->createNamedParameter($this->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); if ($level === 'default') { $this->defaultPermissions = $newPermissions; diff --git a/lib/Service/ParticipantService.php b/lib/Service/ParticipantService.php index 1b007c21e..260658e6b 100644 --- a/lib/Service/ParticipantService.php +++ b/lib/Service/ParticipantService.php @@ -855,7 +855,7 @@ class ParticipantService { ->andWhere($query->expr()->lte('s.last_ping', $query->createNamedParameter($this->timeFactory->getTime() - Session::SESSION_TIMEOUT_KILL, IQueryBuilder::PARAM_INT))); $sessionTableIds = []; - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $sessionTableIds[] = (int) $row['s_id']; } @@ -874,7 +874,7 @@ class ParticipantService { $attendeeIds = []; $attendees = []; - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $attendeeIds[] = (int) $row['a_id']; $attendees[] = $this->attendeeMapper->createAttendeeFromRow($row); @@ -958,51 +958,51 @@ class ParticipantService { } public function markUsersAsMentioned(Room $room, array $userIds, int $messageId, array $usersDirectlyMentioned): void { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_attendees') - ->set('last_mention_message', $query->createNamedParameter($messageId, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('room_id', $query->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) - ->andWhere($query->expr()->eq('actor_type', $query->createNamedParameter(Attendee::ACTOR_USERS))) - ->andWhere($query->expr()->in('actor_id', $query->createNamedParameter($userIds, IQueryBuilder::PARAM_STR_ARRAY))); - $query->execute(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_attendees') + ->set('last_mention_message', $update->createNamedParameter($messageId, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('room_id', $update->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) + ->andWhere($update->expr()->eq('actor_type', $update->createNamedParameter(Attendee::ACTOR_USERS))) + ->andWhere($update->expr()->in('actor_id', $update->createNamedParameter($userIds, IQueryBuilder::PARAM_STR_ARRAY))); + $update->executeStatement(); if (!empty($usersDirectlyMentioned)) { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_attendees') - ->set('last_mention_direct', $query->createNamedParameter($messageId, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('room_id', $query->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) - ->andWhere($query->expr()->eq('actor_type', $query->createNamedParameter(Attendee::ACTOR_USERS))) - ->andWhere($query->expr()->in('actor_id', $query->createNamedParameter($usersDirectlyMentioned, IQueryBuilder::PARAM_STR_ARRAY))); - $query->execute(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_attendees') + ->set('last_mention_direct', $update->createNamedParameter($messageId, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('room_id', $update->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) + ->andWhere($update->expr()->eq('actor_type', $update->createNamedParameter(Attendee::ACTOR_USERS))) + ->andWhere($update->expr()->in('actor_id', $update->createNamedParameter($usersDirectlyMentioned, IQueryBuilder::PARAM_STR_ARRAY))); + $update->executeStatement(); } } public function resetChatDetails(Room $room): void { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_attendees') - ->set('last_read_message', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)) - ->set('last_mention_message', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)) - ->set('last_mention_direct', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('room_id', $query->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))); - $query->executeStatement(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_attendees') + ->set('last_read_message', $update->createNamedParameter(0, IQueryBuilder::PARAM_INT)) + ->set('last_mention_message', $update->createNamedParameter(0, IQueryBuilder::PARAM_INT)) + ->set('last_mention_direct', $update->createNamedParameter(0, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('room_id', $update->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))); + $update->executeStatement(); } public function updateReadPrivacyForActor(string $actorType, string $actorId, int $readPrivacy): void { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_attendees') - ->set('read_privacy', $query->createNamedParameter($readPrivacy, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->eq('actor_type', $query->createNamedParameter($actorType))) - ->andWhere($query->expr()->eq('actor_id', $query->createNamedParameter($actorId))); - $query->execute(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_attendees') + ->set('read_privacy', $update->createNamedParameter($readPrivacy, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->eq('actor_type', $update->createNamedParameter($actorType))) + ->andWhere($update->expr()->eq('actor_id', $update->createNamedParameter($actorId))); + $update->executeStatement(); } public function updateDisplayNameForActor(string $actorType, string $actorId, string $displayName): void { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_attendees') - ->set('display_name', $query->createNamedParameter($displayName)) - ->where($query->expr()->eq('actor_type', $query->createNamedParameter($actorType))) - ->andWhere($query->expr()->eq('actor_id', $query->createNamedParameter($actorId))); - $query->execute(); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_attendees') + ->set('display_name', $update->createNamedParameter($displayName)) + ->where($update->expr()->eq('actor_type', $update->createNamedParameter($actorType))) + ->andWhere($update->expr()->eq('actor_id', $update->createNamedParameter($actorId))); + $update->executeStatement(); } public function getLastCommonReadChatMessage(Room $room): int { @@ -1013,7 +1013,7 @@ class ParticipantService { ->andWhere($query->expr()->eq('room_id', $query->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) ->andWhere($query->expr()->eq('read_privacy', $query->createNamedParameter(Participant::PRIVACY_PUBLIC, IQueryBuilder::PARAM_INT))); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -1036,7 +1036,7 @@ class ParticipantService { ->groupBy('room_id'); $commonReads = array_fill_keys($roomIds, 0); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $commonReads[(int) $row['room_id']] = (int) $row['last_common_read_message']; } @@ -1167,7 +1167,7 @@ class ParticipantService { */ protected function getParticipantsFromQuery(IQueryBuilder $query, Room $room): array { $participants = []; - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $attendee = $this->attendeeMapper->createAttendeeFromRow($row); if (isset($row['s_id'])) { @@ -1236,7 +1236,7 @@ class ParticipantService { ->andWhere($query->expr()->isNull('s.in_call')); $userIds = []; - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $userIds[] = $row['actor_id']; } @@ -1295,7 +1295,7 @@ class ParticipantService { ->where($query->expr()->eq('a.room_id', $query->createNamedParameter($room->getId(), IQueryBuilder::PARAM_INT))) ->andWhere($query->expr()->isNotNull('s.id')) ->setMaxResults(1); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); @@ -1318,7 +1318,7 @@ class ParticipantService { ->andWhere($query->expr()->neq('s.in_call', $query->createNamedParameter(Participant::FLAG_DISCONNECTED))) ->andWhere($query->expr()->gte('s.last_ping', $query->createNamedParameter($this->timeFactory->getTime() - Session::SESSION_TIMEOUT, IQueryBuilder::PARAM_INT))) ->setMaxResults(1); - $result = $query->execute(); + $result = $query->executeQuery(); $row = $result->fetch(); $result->closeCursor(); diff --git a/lib/Service/SessionService.php b/lib/Service/SessionService.php index 6dbf1e3fb..875423326 100644 --- a/lib/Service/SessionService.php +++ b/lib/Service/SessionService.php @@ -58,12 +58,12 @@ class SessionService { * @param int $lastPing */ public function updateMultipleLastPings(array $sessionIds, int $lastPing): void { - $query = $this->connection->getQueryBuilder(); - $query->update('talk_sessions') - ->set('last_ping', $query->createNamedParameter($lastPing, IQueryBuilder::PARAM_INT)) - ->where($query->expr()->in('session_id', $query->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))); + $update = $this->connection->getQueryBuilder(); + $update->update('talk_sessions') + ->set('last_ping', $update->createNamedParameter($lastPing, IQueryBuilder::PARAM_INT)) + ->where($update->expr()->in('session_id', $update->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))); - $query->execute(); + $update->executeStatement(); } public function updateLastPing(Session $session, int $lastPing): void { 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); diff --git a/lib/Signaling/Messages.php b/lib/Signaling/Messages.php index 418bf24bd..34fb1a507 100644 --- a/lib/Signaling/Messages.php +++ b/lib/Signaling/Messages.php @@ -53,11 +53,11 @@ class Messages { * @param string[] $sessionIds */ public function deleteMessages(array $sessionIds): void { - $query = $this->db->getQueryBuilder(); - $query->delete('talk_internalsignaling') - ->where($query->expr()->in('recipient', $query->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))) - ->orWhere($query->expr()->in('sender', $query->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))); - $query->execute(); + $delete = $this->db->getQueryBuilder(); + $delete->delete('talk_internalsignaling') + ->where($delete->expr()->in('recipient', $delete->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))) + ->orWhere($delete->expr()->in('sender', $delete->createNamedParameter($sessionIds, IQueryBuilder::PARAM_STR_ARRAY))); + $delete->executeStatement(); } /** @@ -66,17 +66,17 @@ class Messages { * @param string $message */ public function addMessage(string $senderSessionId, string $recipientSessionId, string $message): void { - $query = $this->db->getQueryBuilder(); - $query->insert('talk_internalsignaling') + $insert = $this->db->getQueryBuilder(); + $insert->insert('talk_internalsignaling') ->values( [ - 'sender' => $query->createNamedParameter($senderSessionId), - 'recipient' => $query->createNamedParameter($recipientSessionId), - 'timestamp' => $query->createNamedParameter($this->timeFactory->getTime()), - 'message' => $query->createNamedParameter($message), + 'sender' => $insert->createNamedParameter($senderSessionId), + 'recipient' => $insert->createNamedParameter($recipientSessionId), + 'timestamp' => $insert->createNamedParameter($this->timeFactory->getTime()), + 'message' => $insert->createNamedParameter($message), ] ); - $query->execute(); + $insert->executeStatement(); } /** @@ -84,14 +84,14 @@ class Messages { * @param string $message */ public function addMessageForAllParticipants(Room $room, string $message): void { - $query = $this->db->getQueryBuilder(); - $query->insert('talk_internalsignaling') + $insert = $this->db->getQueryBuilder(); + $insert->insert('talk_internalsignaling') ->values( [ - 'sender' => $query->createParameter('sender'), - 'recipient' => $query->createParameter('recipient'), - 'timestamp' => $query->createNamedParameter($this->timeFactory->getTime()), - 'message' => $query->createNamedParameter($message), + 'sender' => $insert->createParameter('sender'), + 'recipient' => $insert->createParameter('recipient'), + 'timestamp' => $insert->createNamedParameter($this->timeFactory->getTime()), + 'message' => $insert->createNamedParameter($message), ] ); @@ -99,9 +99,9 @@ class Messages { foreach ($participants as $participant) { $session = $participant->getSession(); if ($session instanceof Session) { - $query->setParameter('sender', $session->getSessionId()) + $insert->setParameter('sender', $session->getSessionId()) ->setParameter('recipient', $session->getSessionId()) - ->execute(); + ->executeStatement(); } } } @@ -126,7 +126,7 @@ class Messages { ->from('talk_internalsignaling') ->where($query->expr()->eq('recipient', $query->createNamedParameter($sessionId))) ->andWhere($query->expr()->lte('timestamp', $query->createNamedParameter($time))); - $result = $query->execute(); + $result = $query->executeQuery(); while ($row = $result->fetch()) { $messages[] = ['type' => 'message', 'data' => $row['message']]; @@ -137,7 +137,7 @@ class Messages { $query->delete('talk_internalsignaling') ->where($query->expr()->eq('recipient', $query->createNamedParameter($sessionId))) ->andWhere($query->expr()->lte('timestamp', $query->createNamedParameter($time))); - $query->execute(); + $query->executeQuery(); return $messages; } @@ -150,9 +150,9 @@ class Messages { public function expireOlderThan(int $olderThan): void { $time = $this->timeFactory->getTime() - $olderThan; - $query = $this->db->getQueryBuilder(); - $query->delete('talk_internalsignaling') - ->where($query->expr()->lt('timestamp', $query->createNamedParameter($time))); - $query->execute(); + $delete = $this->db->getQueryBuilder(); + $delete->delete('talk_internalsignaling') + ->where($delete->expr()->lt('timestamp', $delete->createNamedParameter($time))); + $delete->executeStatement(); } } |