| @@ 282-290 (lines=9) @@ | ||
| 279 | * @param IUser $user |
|
| 280 | * @param array $data |
|
| 281 | */ |
|
| 282 | protected function updateExistingUser(IUser $user, $data) { |
|
| 283 | $uid = $user->getUID(); |
|
| 284 | $jsonEncodedData = json_encode($data); |
|
| 285 | $query = $this->connection->getQueryBuilder(); |
|
| 286 | $query->update($this->table) |
|
| 287 | ->set('data', $query->createNamedParameter($jsonEncodedData)) |
|
| 288 | ->where($query->expr()->eq('uid', $query->createNamedParameter($uid))) |
|
| 289 | ->execute(); |
|
| 290 | } |
|
| 291 | ||
| 292 | /** |
|
| 293 | * build default user record in case not data set exists yet |
|
| @@ 320-327 (lines=8) @@ | ||
| 317 | $query->execute(); |
|
| 318 | } |
|
| 319 | ||
| 320 | public function removeUserStorageMount($storageId, $userId) { |
|
| 321 | $builder = $this->connection->getQueryBuilder(); |
|
| 322 | ||
| 323 | $query = $builder->delete('mounts') |
|
| 324 | ->where($builder->expr()->eq('user_id', $builder->createNamedParameter($userId))) |
|
| 325 | ->andWhere($builder->expr()->eq('storage_id', $builder->createNamedParameter($storageId, IQueryBuilder::PARAM_INT))); |
|
| 326 | $query->execute(); |
|
| 327 | } |
|
| 328 | ||
| 329 | public function remoteStorageMounts($storageId) { |
|
| 330 | $builder = $this->connection->getQueryBuilder(); |
|
| @@ 77-86 (lines=10) @@ | ||
| 74 | return $query->execute()->fetchColumn(); |
|
| 75 | } |
|
| 76 | ||
| 77 | private function update($fileid, $newPath) { |
|
| 78 | $builder = $this->connection->getQueryBuilder(); |
|
| 79 | ||
| 80 | $query = $builder->update('filecache') |
|
| 81 | ->set('path', $builder->createNamedParameter($newPath)) |
|
| 82 | ->set('path_hash', $builder->createNamedParameter(md5($newPath))) |
|
| 83 | ->where($builder->expr()->eq('fileid', $builder->createNamedParameter($fileid))); |
|
| 84 | ||
| 85 | $query->execute(); |
|
| 86 | } |
|
| 87 | ||
| 88 | private function reparent($from, $to) { |
|
| 89 | $builder = $this->connection->getQueryBuilder(); |
|