pdo = $pdo; } /** * Fetches properties for a path. * * This method received a PropFind object, which contains all the * information about the properties that need to be fetched. * * Usually you would just want to call 'get404Properties' on this object, * as this will give you the _exact_ list of properties that need to be * fetched, and haven't yet. * * However, you can also support the 'allprops' property here. In that * case, you should check for $propFind->isAllProps(). * * @param string $path * @param PropFind $propFind * @return void */ function propFind($path, PropFind $propFind) { if (!$propFind->isAllProps() && count($propFind->get404Properties()) === 0) { return; } $query = 'SELECT name, value, valuetype FROM ' . $this->tableName . ' WHERE path = ?'; $stmt = $this->pdo->prepare($query); $stmt->execute([$path]); while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) { if (gettype($row['value']) === 'resource') { $row['value'] = stream_get_contents($row['value']); } switch ($row['valuetype']) { case null : case self::VT_STRING : $propFind->set($row['name'], $row['value']); break; case self::VT_XML : $propFind->set($row['name'], new Complex($row['value'])); break; case self::VT_OBJECT : $propFind->set($row['name'], unserialize($row['value'])); break; } } } /** * Updates properties for a path * * This method received a PropPatch object, which contains all the * information about the update. * * Usually you would want to call 'handleRemaining' on this object, to get; * a list of all properties that need to be stored. * * @param string $path * @param PropPatch $propPatch * @return void */ function propPatch($path, PropPatch $propPatch) { $propPatch->handleRemaining(function($properties) use ($path) { if ($this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME) === 'pgsql') { $updateSql = <<tableName} (path, name, valuetype, value) VALUES (:path, :name, :valuetype, :value) ON CONFLICT (path, name) DO UPDATE SET valuetype = :valuetype, value = :value SQL; } else { $updateSql = <<tableName} (path, name, valuetype, value) VALUES (:path, :name, :valuetype, :value) SQL; } $updateStmt = $this->pdo->prepare($updateSql); $deleteStmt = $this->pdo->prepare("DELETE FROM " . $this->tableName . " WHERE path = ? AND name = ?"); foreach ($properties as $name => $value) { if (!is_null($value)) { if (is_scalar($value)) { $valueType = self::VT_STRING; } elseif ($value instanceof Complex) { $valueType = self::VT_XML; $value = $value->getXml(); } else { $valueType = self::VT_OBJECT; $value = serialize($value); } $updateStmt->bindParam('path', $path, \PDO::PARAM_STR); $updateStmt->bindParam('name', $name, \PDO::PARAM_STR); $updateStmt->bindParam('valuetype', $valueType, \PDO::PARAM_INT); $updateStmt->bindParam('value', $value, \PDO::PARAM_LOB); $updateStmt->execute(); } else { $deleteStmt->execute([$path, $name]); } } return true; }); } /** * This method is called after a node is deleted. * * This allows a backend to clean up all associated properties. * * The delete method will get called once for the deletion of an entire * tree. * * @param string $path * @return void */ function delete($path) { $stmt = $this->pdo->prepare("DELETE FROM " . $this->tableName . " WHERE path = ? OR path LIKE ? ESCAPE '='"); $childPath = strtr( $path, [ '=' => '==', '%' => '=%', '_' => '=_' ] ) . '/%'; $stmt->execute([$path, $childPath]); } /** * This method is called after a successful MOVE * * This should be used to migrate all properties from one path to another. * Note that entire collections may be moved, so ensure that all properties * for children are also moved along. * * @param string $source * @param string $destination * @return void */ function move($source, $destination) { // I don't know a way to write this all in a single sql query that's // also compatible across db engines, so we're letting PHP do all the // updates. Much slower, but it should still be pretty fast in most // cases. $select = $this->pdo->prepare('SELECT id, path FROM ' . $this->tableName . ' WHERE path = ? OR path LIKE ?'); $select->execute([$source, $source . '/%']); $update = $this->pdo->prepare('UPDATE ' . $this->tableName . ' SET path = ? WHERE id = ?'); while ($row = $select->fetch(\PDO::FETCH_ASSOC)) { // Sanity check. SQL may select too many records, such as records // with different cases. if ($row['path'] !== $source && strpos($row['path'], $source . '/') !== 0) continue; $trailingPart = substr($row['path'], strlen($source) + 1); $newPath = $destination; if ($trailingPart) { $newPath .= '/' . $trailingPart; } $update->execute([$newPath, $row['id']]); } } }