| @@ 383-389 (lines=7) @@ | ||
| 380 | * @param int $shareId |
|
| 381 | * @param string $token |
|
| 382 | */ |
|
| 383 | protected function updateSuccessfulReShare($shareId, $token) { |
|
| 384 | $query = $this->dbConnection->getQueryBuilder(); |
|
| 385 | $query->update('share') |
|
| 386 | ->where($query->expr()->eq('id', $query->createNamedParameter($shareId))) |
|
| 387 | ->set('token', $query->createNamedParameter($token)) |
|
| 388 | ->execute(); |
|
| 389 | } |
|
| 390 | ||
| 391 | /** |
|
| 392 | * store remote ID in federated reShare table |
|
| @@ 536-545 (lines=10) @@ | ||
| 533 | * |
|
| 534 | * @param string $shareId |
|
| 535 | */ |
|
| 536 | private function removeShareFromTableById($shareId) { |
|
| 537 | $qb = $this->dbConnection->getQueryBuilder(); |
|
| 538 | $qb->delete('share') |
|
| 539 | ->where($qb->expr()->eq('id', $qb->createNamedParameter($shareId))); |
|
| 540 | $qb->execute(); |
|
| 541 | ||
| 542 | $qb->delete('federated_reshares') |
|
| 543 | ->where($qb->expr()->eq('share_id', $qb->createNamedParameter($shareId))); |
|
| 544 | $qb->execute(); |
|
| 545 | } |
|
| 546 | ||
| 547 | /** |
|
| 548 | * @inheritdoc |
|
| @@ 897-906 (lines=10) @@ | ||
| 894 | * @param string $uid |
|
| 895 | * @param int $shareType |
|
| 896 | */ |
|
| 897 | public function userDeleted($uid, $shareType) { |
|
| 898 | //TODO: probabaly a good idea to send unshare info to remote servers |
|
| 899 | ||
| 900 | $qb = $this->dbConnection->getQueryBuilder(); |
|
| 901 | ||
| 902 | $qb->delete('share') |
|
| 903 | ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_REMOTE))) |
|
| 904 | ->andWhere($qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid))) |
|
| 905 | ->execute(); |
|
| 906 | } |
|
| 907 | ||
| 908 | /** |
|
| 909 | * This provider does not handle groups |
|
| @@ 117-124 (lines=8) @@ | ||
| 114 | * @param IUser $user |
|
| 115 | * @param int $id |
|
| 116 | */ |
|
| 117 | public function deleteById(IUser $user, $id) { |
|
| 118 | /* @var $qb IQueryBuilder */ |
|
| 119 | $qb = $this->db->getQueryBuilder(); |
|
| 120 | $qb->delete('authtoken') |
|
| 121 | ->where($qb->expr()->eq('id', $qb->createNamedParameter($id))) |
|
| 122 | ->andWhere($qb->expr()->eq('uid', $qb->createNamedParameter($user->getUID()))); |
|
| 123 | $qb->execute(); |
|
| 124 | } |
|
| 125 | } |
|
| 126 | ||
| @@ 243-251 (lines=9) @@ | ||
| 240 | * @param int $mountId |
|
| 241 | * @param string $newMountPoint |
|
| 242 | */ |
|
| 243 | public function setMountPoint($mountId, $newMountPoint) { |
|
| 244 | $builder = $this->connection->getQueryBuilder(); |
|
| 245 | ||
| 246 | $query = $builder->update('external_mounts') |
|
| 247 | ->set('mount_point', $builder->createNamedParameter($newMountPoint)) |
|
| 248 | ->where($builder->expr()->eq('mount_id', $builder->createNamedParameter($mountId, IQueryBuilder::PARAM_INT))); |
|
| 249 | ||
| 250 | $query->execute(); |
|
| 251 | } |
|
| 252 | ||
| 253 | /** |
|
| 254 | * @param int $mountId |
|
| @@ 257-265 (lines=9) @@ | ||
| 254 | * @param int $mountId |
|
| 255 | * @param string $newAuthBackend |
|
| 256 | */ |
|
| 257 | public function setAuthBackend($mountId, $newAuthBackend) { |
|
| 258 | $builder = $this->connection->getQueryBuilder(); |
|
| 259 | ||
| 260 | $query = $builder->update('external_mounts') |
|
| 261 | ->set('auth_backend', $builder->createNamedParameter($newAuthBackend)) |
|
| 262 | ->where($builder->expr()->eq('mount_id', $builder->createNamedParameter($mountId, IQueryBuilder::PARAM_INT))); |
|
| 263 | ||
| 264 | $query->execute(); |
|
| 265 | } |
|
| 266 | ||
| 267 | /** |
|
| 268 | * @param int $mountId |
|
| @@ 287-293 (lines=7) @@ | ||
| 284 | * |
|
| 285 | * @param IJob $job |
|
| 286 | */ |
|
| 287 | public function unlockJob($job) { |
|
| 288 | $query = $this->connection->getQueryBuilder(); |
|
| 289 | $query->update('jobs') |
|
| 290 | ->set('reserved_at', $query->expr()->literal(0, IQueryBuilder::PARAM_INT)) |
|
| 291 | ->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT))); |
|
| 292 | $query->execute(); |
|
| 293 | } |
|
| 294 | ||
| 295 | /** |
|
| 296 | * get the id of the last ran job |
|
| @@ 318-324 (lines=7) @@ | ||
| 315 | $query->execute(); |
|
| 316 | } |
|
| 317 | ||
| 318 | public function setExecutionTime($job, $timeTaken) { |
|
| 319 | $query = $this->connection->getQueryBuilder(); |
|
| 320 | $query->update('jobs') |
|
| 321 | ->set('execution_duration', $query->createNamedParameter($timeTaken, IQueryBuilder::PARAM_INT)) |
|
| 322 | ->where($query->expr()->eq('id', $query->createNamedParameter($job->getId(), IQueryBuilder::PARAM_INT))); |
|
| 323 | $query->execute(); |
|
| 324 | } |
|
| 325 | ||
| 326 | /** |
|
| 327 | * @inheritdoc |
|
| @@ 98-104 (lines=7) @@ | ||
| 95 | * |
|
| 96 | * @param int $id |
|
| 97 | */ |
|
| 98 | public function removeServer($id) { |
|
| 99 | $query = $this->connection->getQueryBuilder(); |
|
| 100 | $query->delete($this->dbTable) |
|
| 101 | ->where($query->expr()->eq('id', $query->createParameter('id'))) |
|
| 102 | ->setParameter('id', $id); |
|
| 103 | $query->execute(); |
|
| 104 | } |
|
| 105 | ||
| 106 | /** |
|
| 107 | * get trusted server with given ID |
|
| @@ 301-307 (lines=7) @@ | ||
| 298 | * |
|
| 299 | * @param IUser $user |
|
| 300 | */ |
|
| 301 | public function removeUserMounts(IUser $user) { |
|
| 302 | $builder = $this->connection->getQueryBuilder(); |
|
| 303 | ||
| 304 | $query = $builder->delete('mounts') |
|
| 305 | ->where($builder->expr()->eq('user_id', $builder->createNamedParameter($user->getUID()))); |
|
| 306 | $query->execute(); |
|
| 307 | } |
|
| 308 | ||
| 309 | public function removeUserStorageMount($storageId, $userId) { |
|
| 310 | $builder = $this->connection->getQueryBuilder(); |
|
| @@ 318-324 (lines=7) @@ | ||
| 315 | $query->execute(); |
|
| 316 | } |
|
| 317 | ||
| 318 | public function remoteStorageMounts($storageId) { |
|
| 319 | $builder = $this->connection->getQueryBuilder(); |
|
| 320 | ||
| 321 | $query = $builder->delete('mounts') |
|
| 322 | ->where($builder->expr()->eq('storage_id', $builder->createNamedParameter($storageId, IQueryBuilder::PARAM_INT))); |
|
| 323 | $query->execute(); |
|
| 324 | } |
|
| 325 | } |
|
| 326 | ||
| @@ 523-529 (lines=7) @@ | ||
| 520 | * @param IShare $share |
|
| 521 | * @param int $permissions |
|
| 522 | */ |
|
| 523 | protected function updatePermissionsInDatabase(IShare $share, $permissions) { |
|
| 524 | $query = $this->connection->getQueryBuilder(); |
|
| 525 | $query->update('share') |
|
| 526 | ->where($query->expr()->eq('id', $query->createNamedParameter($share->getId()))) |
|
| 527 | ->set('permissions', $query->createNamedParameter($permissions)) |
|
| 528 | ->execute(); |
|
| 529 | } |
|
| 530 | ||
| 531 | /** |
|
| 532 | * Check if value is null or an array has any null item |
|