Newer
Older
/*
* This file is part of vospace-rest
* Copyright (C) 2021 Istituto Nazionale di Astrofisica
* SPDX-License-Identifier: GPL-3.0-or-later
*/
import it.inaf.oats.vospace.URIUtils;
import it.inaf.oats.vospace.datamodel.NodeProperties;
import it.inaf.oats.vospace.datamodel.NodeUtils;
import it.inaf.oats.vospace.exception.InternalFaultException;
import java.net.URISyntaxException;
Sonia Zorba
committed
import java.sql.Array;
import net.ivoa.xml.vospace.v2.Node;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
Sara Bertocco
committed
import java.sql.Types;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.function.Function;
import java.util.stream.Collectors;
import net.ivoa.xml.vospace.v2.ContainerNode;
import net.ivoa.xml.vospace.v2.DataNode;
import net.ivoa.xml.vospace.v2.Property;
import net.ivoa.xml.vospace.v2.View;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
@Repository
public class NodeDAO {
private static final Logger LOG = LoggerFactory.getLogger(DeleteNodeController.class);
@Value("${vospace-authority}")
private String authority;
@Autowired
public NodeDAO(DataSource dataSource) {
jdbcTemplate = new JdbcTemplate(dataSource);
}
public void createNode(Node node) {
createNode(node, null);
}
public void createNode(Node myNode, String jobId) {
String nodeVosPath = URIUtils.returnVosPathFromNodeURI(myNode, authority);
List<NodePaths> paths = getNodePathsFromDB(nodeVosPath);
Sara Bertocco
committed
throw new IllegalStateException("Unable to find parent node during node creation");
Sara Bertocco
committed
sb.append("INSERT INTO node");
sb.append(" (name, job_id, creator_id, group_read, group_write,");
sb.append(" is_public, parent_path, parent_relative_path, type, accept_views, provide_views)");
sb.append(" VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
Sara Bertocco
committed
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sb.toString());
ps.setString(++i, NodeUtils.getNodeName(nodeVosPath));
if (jobId == null) {
ps.setNull(++i, Types.VARCHAR);
} else {
ps.setString(++i, jobId);
}
ps.setString(++i, NodeProperties.getStandardNodePropertyByName(myNode, "creator"));
ps.setArray(++i, fromPropertyToArray(ps, NodeProperties.getStandardNodePropertyByName(myNode, "groupread")));
ps.setArray(++i, fromPropertyToArray(ps, NodeProperties.getStandardNodePropertyByName(myNode, "groupwrite")));
ps.setBoolean(++i, Boolean.valueOf(NodeProperties.getStandardNodePropertyByName(myNode, "publicread")));
ps.setObject(++i, paths.get(0).getPath(), Types.OTHER);
ps.setObject(++i, paths.get(0).getRelativePath(), Types.OTHER);
ps.setObject(++i, NodeUtils.getDbNodeType(myNode), Types.OTHER);
ps.setObject(++i, fromViewsToArray(ps, myNode, d -> d.getAccepts()), Types.OTHER);
ps.setObject(++i, fromViewsToArray(ps, myNode, d -> d.getProvides()), Types.OTHER);
Sara Bertocco
committed
return ps;
});
public Optional<Node> listNode(String path) {
String sql = "SELECT (CASE WHEN c.path = n.path THEN ? ELSE (? || ? || c.name) END) AS vos_path, c.node_id, c.name,\n"
+ "c.type, c.async_trans, c.sticky, c.job_id IS NOT NULL AS busy_state, c.creator_id, c.group_read, c.group_write,\n"
+ "c.is_public, c.content_length, c.created_on, c.last_modified, c.accept_views, c.provide_views\n"
+ "JOIN node c ON c.path ~ (n.path::varchar || ? || '*{1}')::lquery OR c.path = n.path\n"
+ "WHERE n.node_id = id_from_vos_path(?)\n"
+ "ORDER BY vos_path";
List<Node> parentAndChildren = jdbcTemplate.query(conn -> {
int i = 0;
ps.setString(++i, path);
ps.setString(++i, path);
ps.setString(++i, "/".equals(path) ? "" : "/");
ps.setString(++i, "/".equals(path) ? "" : ".");
ps.setString(++i, path);
if (parentAndChildren.isEmpty()) {
return Optional.empty();
}
// Query returns parent as first node
Node node = parentAndChildren.get(0);
// Fill children
if (node instanceof ContainerNode && parentAndChildren.size() > 1) {
ContainerNode parent = (ContainerNode) node;
for (int i = 1; i < parentAndChildren.size(); i++) {
parent.getNodes().add(parentAndChildren.get(i));
}
}
public List<String> listNodeChildren(String path) {
String sql = "SELECT n.name\n"
+ "FROM node n\n"
+ "WHERE n.path ~ ('*.' || id_from_vos_path(?) || '.*{1}')::lquery\n"
+ "ORDER BY n.path";
List<String> childrenNames = jdbcTemplate.query(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
int i = 0;
ps.setString(++i, path);
return ps;
}, (row, index) -> {
return row.getString("name");
});
return childrenNames;
public Node setNode(Node newNode) {
return setNode(newNode, false);
/**
* If recursive flag is true the update is applied to children too.
*/
public Node setNode(Node newNode, boolean recursive) {
String vosPath = URIUtils.returnVosPathFromNodeURI(newNode, authority);
Sonia Zorba
committed
String sql = "UPDATE node\n"
+ "SET group_read = ?, group_write = ?, is_public = ?"
+ "WHERE node_id = id_from_vos_path(?)\n";
PreparedStatement ps = conn.prepareStatement(sql);
int i = 0;
ps.setArray(++i, fromPropertyToArray(ps, NodeProperties.getNodePropertyByURI(newNode, NodeProperties.GROUP_READ_URI)));
ps.setArray(++i, fromPropertyToArray(ps, NodeProperties.getNodePropertyByURI(newNode, NodeProperties.GROUP_WRITE_URI)));
ps.setBoolean(++i, Boolean.valueOf(NodeProperties.getNodePropertyByURI(newNode, NodeProperties.PUBLIC_READ_URI)));
ps.setString(++i, vosPath);
return ps;
});
}
Sonia Zorba
committed
return newNode;
private Node getNodeFromResultSet(ResultSet rs) throws SQLException {
Sonia Zorba
committed
if (node instanceof DataNode) {
DataNode dataNode = (DataNode) node;
dataNode.setBusy(rs.getBoolean("busy_state"));
dataNode.setAccepts(getViews(rs.getArray("accept_views")));
dataNode.setProvides(getViews(rs.getArray("provide_views")));
Sonia Zorba
committed
}
node.setUri(getUri(rs.getString("vos_path")));
List<Property> properties = new ArrayList<>();
Sonia Zorba
committed
// Content length is required for CADC client compatibility
String contentLength = rs.getString("content_length");
addProperty(NodeProperties.LENGTH_URI, contentLength == null ? "0" : contentLength, properties);
Sonia Zorba
committed
Sonia Zorba
committed
String creationTime = rs.getString("created_on").replace(" ", "T");
Sonia Zorba
committed
addProperty(NodeProperties.INITIAL_CREATION_TIME_URI, creationTime, properties);
addProperty(NodeProperties.DATE_URI, creationTime, properties); // required by CADC
Sonia Zorba
committed
addProperty(NodeProperties.CREATOR_URI, rs.getString("creator_id"),
addProperty(NodeProperties.MODIFICATION_TIME_URI, rs.getString("last_modified"),
properties);
Sonia Zorba
committed
addProperty(NodeProperties.GROUP_READ_URI, getGroupsString(rs, "group_read"),
properties);
Sonia Zorba
committed
addProperty(NodeProperties.GROUP_WRITE_URI, getGroupsString(rs, "group_write"),
properties);
Sonia Zorba
committed
addProperty(NodeProperties.PUBLIC_READ_URI, String.valueOf(rs.getBoolean("is_public")),
properties);
Sonia Zorba
committed
addProperty("urn:async_trans", String.valueOf(rs.getBoolean("async_trans")),
properties);
addProperty("urn:sticky", String.valueOf(rs.getBoolean("sticky")), properties);
Sonia Zorba
committed
node.setProperties(properties);
public Optional<Long> getNodeId(String nodeVosPath) {
String sql = "SELECT node_id FROM node_vos_path WHERE vos_path = ?";
List<Long> nodeIdList = jdbcTemplate.query(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1, nodeVosPath);
return ps;
}, (row, index) -> {
return row.getLong("node_id");
});
switch (nodeIdList.size()) {
case 0:
return Optional.empty();
case 1:
return Optional.of(nodeIdList.get(0));
default:
throw new InternalFaultException("More than 1 node id at path: " + nodeVosPath);
public Optional<ShortNodeDescriptor> getShortNodeDescriptor(String nodeVosPath,
String userId, List<String> userGroups) {
String sql = "SELECT path,\n"
Nicola Fulvio Calabria
committed
+ "NOT (n.async_trans OR n.sticky OR COALESCE(location_type = 'async', FALSE)) AS is_writable,\n"
+ "((SELECT COUNT(*) FROM (SELECT UNNEST(?) INTERSECT SELECT UNNEST(n.group_write)) AS allowed_groups ) = 0 AND\n"
+ "n.creator_id <> ?) AS is_permission_denied,\n"
+ "n.type = 'container' AS is_container,\n"
+ "n.job_id IS NOT NULL AS busy_state\n"
+ "FROM node n \n"
+ "JOIN node_vos_path p ON n.node_id = p.node_id \n"
+ "LEFT JOIN location loc ON loc.location_id = n.location_id\n"
+ "WHERE vos_path = ?\n";
Optional<ShortNodeDescriptor> sndOpt = jdbcTemplate.query(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
if (userGroups == null) {
groups = new String[0];
} else {
groups = userGroups.toArray(String[]::new);
}
ps.setArray(1, ps.getConnection().createArrayOf("varchar", groups));
ps.setString(2, userId);
ps.setString(3, nodeVosPath);
return ps;
}, rs -> {
if (!rs.next()) {
return Optional.empty();
}
String nodePath = rs.getString("path");
Boolean isContainer = rs.getBoolean(("is_container"));
Boolean isWritable = rs.getBoolean("is_writable");
Boolean isBusy = rs.getBoolean("busy_state");
Boolean isPermissionDenied = rs.getBoolean("is_permission_denied");
ShortNodeDescriptor result = new ShortNodeDescriptor(nodePath, isContainer, isWritable, isBusy, isPermissionDenied);
return Optional.of(result);
});
return sndOpt;
}
public void renameNode(Long nodeId, String name) {
String sql = "UPDATE node SET name = ?\n, os_name = COALESCE(os_name, name)"
+ "WHERE path ~ ('*.' || ?)::lquery";
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1, name);
ps.setLong(2, nodeId);
return ps;
});
}
public void moveNodeBranch(Long sourceRootId, String destParentLtreePath) {
String sql = "UPDATE node c SET "
+ "parent_path = (? || SUBPATH(c.path, (SELECT nlevel(parent_path) FROM node WHERE node_id = ?), -1))::ltree, "
+ "parent_relative_path = COALESCE(c.parent_relative_path, c.parent_path) " // not sure about this
+ "FROM node n "
+ "WHERE n.path @> c.path AND n.node_id = ?";
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
public void copyBranch(String sourceVosPath, String destVosPath, String jobId) {
String destVosParentPath = NodeUtils.getParentPath(destVosPath);
String destName = NodeUtils.getNodeName(destVosPath);
String parentInsert = "INSERT INTO node (node_id, parent_path, parent_relative_path, name, type, location_id, creator_id, group_write, group_read, is_public, job_id)\n";
String ctePathPrefix = "SELECT CASE WHEN path::varchar = '' THEN '' ELSE (path::varchar || '.') END AS prefix\n"
+ "FROM node WHERE node_id = id_from_vos_path(?)";
String cteCopiedNodes = "SELECT nextval('node_node_id_seq') AS new_node_id,\n"
+ "((SELECT prefix FROM path_prefix) || currval('node_node_id_seq'))::ltree AS new_path,\n"
+ "path, relative_path, parent_path, parent_relative_path, ? AS name,\n"
+ "type, location_id, creator_id, group_write, group_read, is_public\n"
+ "FROM node WHERE node_id = id_from_vos_path(?)\n"
+ "UNION ALL\n"
+ "SELECT nextval('node_node_id_seq') AS new_node_id,\n"
+ "(p.new_path::varchar || '.' || currval('node_node_id_seq'))::ltree,\n"
+ "n.path, n.relative_path, n.parent_path, n.parent_relative_path, n.name,\n"
+ "n.type, n.location_id, n.creator_id, n.group_write, n.group_read, n.is_public\n"
+ "FROM node n\n"
+ "JOIN copied_nodes p ON p.path = n.parent_path";
String cteCopiedNodesPaths = "SELECT subpath(new_path, 0, nlevel(new_path) - 1) AS new_parent_path,\n"
+ "nlevel(parent_path) - nlevel(parent_relative_path) AS rel_offset, * FROM copied_nodes";
String parentSelect = "SELECT\n"
+ "new_node_id, new_parent_path,\n"
+ "CASE WHEN nlevel(new_parent_path) = rel_offset THEN ''::ltree ELSE subpath(new_parent_path, rel_offset) END new_parent_relative_path,\n"
+ "name, type, location_id, creator_id, group_write, group_read, is_public, ?\n"
+ "FROM copied_nodes_paths";
String sql = parentInsert
+ "WITH RECURSIVE path_prefix AS ("
+ ctePathPrefix + "),\n"
+ "copied_nodes AS ("
+ cteCopiedNodes + "),\n"
+ "copied_nodes_paths AS ("
+ cteCopiedNodesPaths + ")\n"
+ parentSelect;
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1, destVosParentPath);
ps.setString(2, destName);
ps.setString(3, sourceVosPath);
ps.setString(4, jobId);
public boolean isBranchBusy(long parentNodeId) {
String sql = "SELECT COUNT(c.node_id) > 0 "
+ "FROM node n "
+ "JOIN node c ON c.path <@ n.path "
+ "WHERE n.node_id = ? AND c.job_id IS NOT NULL";
return jdbcTemplate.queryForObject(sql, new Object[]{parentNodeId}, new int[]{Types.BIGINT}, Boolean.class);
public void setBranchJobId(Long rootNodeId, String jobId) {
String sql = "UPDATE node SET job_id = ?\n"
+ "WHERE path ~ ('*.' || ? || '.*')::lquery";
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1, jobId);
ps.setLong(2, rootNodeId);
return ps;
});
}
public boolean isBranchWritable(long parentNodeId, String userId, List<String> userGroups) {
String sql = "SELECT COUNT(c.node_id) = 0 "
+ "FROM node n "
+ "JOIN node c ON c.path <@ n.path "
+ "LEFT JOIN location loc ON c.location_id = loc.location_id "
+ "WHERE n.node_id = ? "
+ "AND (c.async_trans OR c.sticky OR location_type = 'async' OR "
+ "((SELECT COUNT(*) FROM (SELECT UNNEST(?) INTERSECT SELECT UNNEST(c.group_write)) AS allowed_groups) = 0 "
+ "AND c.creator_id <> ?))";
return jdbcTemplate.query(sql, ps -> {
ps.setLong(1, parentNodeId);
if (userGroups == null) {
groups = new String[0];
} else {
groups = userGroups.toArray(String[]::new);
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
}
ps.setArray(2, ps.getConnection().createArrayOf("varchar", groups));
ps.setString(3, userId);
}, row -> {
if (!row.next()) {
throw new IllegalStateException("Expected one result");
}
return row.getBoolean(1);
});
}
public boolean isBranchReadable(long parentNodeId, String userId, List<String> userGroups) {
String sql = "SELECT COUNT(c.node_id) = 0 "
+ "FROM node n "
+ "JOIN node c ON c.path <@ n.path "
+ "WHERE n.node_id = ? "
+ "(NOT COALESCE(c.is_public, FALSE) "
+ "AND (SELECT COUNT(*) FROM (SELECT UNNEST(?) INTERSECT SELECT UNNEST(c.group_read)) AS allowed_groups) = 0 "
+ "AND c.creator_id <> ?";
return jdbcTemplate.query(sql, ps -> {
ps.setLong(1, parentNodeId);
String[] groups;
if (userGroups == null) {
groups = new String[0];
} else {
groups = userGroups.toArray(String[]::new);
ps.setArray(2, ps.getConnection().createArrayOf("varchar", groups));
ps.setString(3, userId);
}, row -> {
if (!row.next()) {
throw new IllegalStateException("Expected one result");
}
return row.getBoolean(1);
});
}
Nicola Fulvio Calabria
committed
public void deleteNode(String path) {
int nodesWithPath = countNodesWithPath(path);
Nicola Fulvio Calabria
committed
if (nodesWithPath == 0) {
throw new IllegalStateException("Node at path "
Nicola Fulvio Calabria
committed
+ path + " not found");
}
Nicola Fulvio Calabria
committed
if (nodesWithPath > 1) {
throw new IllegalStateException("Multiple nodes at path " + path);
}
Nicola Fulvio Calabria
committed
String insertSql = "INSERT INTO deleted_node "
+ "(node_id, parent_path, parent_relative_path, "
+ "name, os_name, tstamp_wrapper_dir, type, location_id, format, "
+ "async_trans, job_id, creator_id, group_read, "
Nicola Fulvio Calabria
committed
+ "group_write, is_public, delta, content_type, content_encoding, "
+ "content_length, content_md5, created_on, last_modified, "
+ "accept_views, provide_views, protocols, sticky)\n";
Nicola Fulvio Calabria
committed
String deleteSql = "DELETE \n"
+ "FROM node n\n"
+ "USING node p\n"
+ "WHERE n.path <@ p.path AND p.node_id = id_from_vos_path(?)\n"
+ "RETURNING\n"
+ "n.node_id, n.parent_path, n.parent_relative_path, "
+ "n.name, n.os_name, n.tstamp_wrapper_dir, n.type, n.location_id, n.format, "
+ "n.async_trans, n.job_id, n.creator_id, n.group_read, "
+ "n.group_write, n.is_public, n.delta, n.content_type, n.content_encoding, "
+ "n.content_length, n.content_md5, n.created_on, n.last_modified, "
+ "n.accept_views, n.provide_views, n.protocols, n.sticky\n";
String withSql = "WITH del AS (" + deleteSql + ")";
String sql = withSql + insertSql + "SELECT * FROM del\n";
Nicola Fulvio Calabria
committed
}
// utility method for deleteNode
Nicola Fulvio Calabria
committed
public int countNodesWithPath(String path) {
String sql = "SELECT COUNT(*) FROM node WHERE node_id = id_from_vos_path(?)";
Nicola Fulvio Calabria
committed
Object[] args = {path};
int[] types = {Types.VARCHAR};
Nicola Fulvio Calabria
committed
return jdbcTemplate.queryForObject(sql, args, types, Integer.class);
}
public String getNodeOsName(String vosPath) {
String sql = "SELECT \n"
Object[] args = {vosPath};
int[] types = {Types.VARCHAR};
return jdbcTemplate.queryForObject(sql, args, types, String.class);
}
public void setNodeLocation(String vosPath, int locationId, String nodeOsName) {
String sql = "UPDATE node SET location_id = ?, os_name = ? WHERE node_id = id_from_vos_path(?)";
int updated = jdbcTemplate.update(sql, ps -> {
ps.setInt(1, locationId);
ps.setString(2, nodeOsName);
ps.setString(3, vosPath);
});
if (updated != 1) {
throw new InternalFaultException("Unable to set node location for path " + vosPath);
}
}
Sonia Zorba
committed
private String getGroupsString(ResultSet rs, String column) throws SQLException {
Array array = rs.getArray(column);
if (array == null) {
return null;
}
return String.join(" ", (String[]) array.getArray());
}
// If value is null does nothing
private void addProperty(String uri, String value, List<Property> list) {
if (value != null) {
Property prop = new Property();
prop.setUri(uri);
prop.setValue(value);
list.add(prop);
}
}
private String getUri(String path) {
return URIUtils.returnURIFromVosPath(path, authority);
Sara Bertocco
committed
private NodePaths getPathsFromResultSet(ResultSet rs) throws SQLException {
NodePaths paths = new NodePaths(rs.getString("path"), rs.getString("relative_path"));
Sara Bertocco
committed
}
private Array fromPropertyToArray(PreparedStatement ps, String myProperty) throws SQLException {
if (myProperty == null || myProperty.isBlank()) {
Sara Bertocco
committed
return null;
} else {
return ps.getConnection().createArrayOf("varchar", myProperty.split(" "));
Sara Bertocco
committed
}
private Array fromViewsToArray(PreparedStatement ps, Node node, Function<DataNode, List<View>> viewsExtractor) throws SQLException {
if (node instanceof DataNode) {
DataNode dataNode = (DataNode) node;
List<View> views = viewsExtractor.apply(dataNode);
if (views != null && !views.isEmpty()) {
Object[] array = views.stream().map(v -> v.getUri()).toArray();
return ps.getConnection().createArrayOf("varchar", array);
}
}
return null;
}
if (array == null) {
return null;
}
try {
return Arrays.stream((String[]) array.getArray())
.map(uri -> {
View view = new View();
view.setUri(uri);
return view;
})
.collect(Collectors.toList());
} catch (SQLException ex) {
throw new RuntimeException(ex);
}
/*
Map contains:
Key column
column name value
column name value
and value is a String containing comma separated groups having permissions
*/
private Map<String, List<String>> getPermissionsFromDB(String vosPath) {
+ "FROM node n WHERE node_id = id_from_vos_path(?)";
return jdbcTemplate.query(sql, new Object[]{vosPath}, new int[]{Types.VARCHAR}, rs -> {
if (!rs.next()) {
throw new InternalFaultException("No records found for " + vosPath);
}
return Map.of(
"group_read", getArrayValue(rs, "group_read"),
"group_write", getArrayValue(rs, "group_write")
);
});
}
private List<String> getArrayValue(ResultSet rs, String key) throws SQLException {
Array array = rs.getArray(key);
if (array == null) {
return new ArrayList<>();
}
return Arrays.asList((String[]) array.getArray());
private void updatePermissionsRecursively(Node newNode, String vosPath) {
Map<String, List<String>> permissions = getPermissionsFromDB(vosPath);
List<String> existingGroupReadList = permissions.get("group_read");
List<String> existingGroupWriteList = permissions.get("group_write");
List<String> newGroupReadList = NodeProperties.getNodePropertyAsListByURI(newNode, NodeProperties.GROUP_READ_URI);
List<String> newGroupWriteList = NodeProperties.getNodePropertyAsListByURI(newNode, NodeProperties.GROUP_WRITE_URI);
Set<String> existingGroupRead = new HashSet<>(existingGroupReadList);
Set<String> existingGroupWrite = new HashSet<>(existingGroupWriteList);
Set<String> newGroupRead = new HashSet<>(newGroupReadList);
Set<String> newGroupWrite = new HashSet<>(newGroupWriteList);
Set<String> groupReadToAdd = differenceBetweenSets(newGroupRead, existingGroupRead);
Set<String> groupReadToRemove = differenceBetweenSets(existingGroupRead, newGroupRead);
Set<String> groupWriteToAdd = differenceBetweenSets(newGroupWrite, existingGroupWrite);
Set<String> groupWriteToRemove = differenceBetweenSets(existingGroupWrite, newGroupWrite);
String sql = "UPDATE node c SET "
+ "group_read = update_array(c.group_read, ?, ?), "
+ "group_write = update_array(c.group_write, ?, ?), "
+ "FROM node n "
+ "WHERE n.node_id = id_from_vos_path(?) AND c.path <@ n.path";
jdbcTemplate.update(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
int i = 0;
ps.setArray(++i, ps.getConnection().createArrayOf("varchar", groupReadToAdd.toArray()));
ps.setArray(++i, ps.getConnection().createArrayOf("varchar", groupReadToRemove.toArray()));
ps.setArray(++i, ps.getConnection().createArrayOf("varchar", groupWriteToAdd.toArray()));
ps.setArray(++i, ps.getConnection().createArrayOf("varchar", groupWriteToRemove.toArray()));
ps.setBoolean(++i, Boolean.valueOf(NodeProperties.getNodePropertyByURI(newNode, NodeProperties.PUBLIC_READ_URI)));
ps.setString(++i, vosPath);
return ps;
});
}
// Returns the difference a minus b
private Set<String> differenceBetweenSets(Set<String> a, Set<String> b) {
Set<String> diff = new HashSet<>(a);
diff.removeAll(b);
private List<NodePaths> getNodePathsFromDB(String path) {
String sql = "SELECT path, relative_path "
+ "FROM node n "
+ "WHERE node_id = id_from_vos_path(?)";
List<NodePaths> paths = jdbcTemplate.query(conn -> {
PreparedStatement ps = conn.prepareStatement(sql);
ps.setString(1, parentPath);
return ps;
}, (row, index) -> {
return getPathsFromResultSet(row);
});
public class ShortNodeDescriptor {
private final String nodeLtreePath;
private final boolean container;
private final boolean writable;
private final boolean busy;
private final boolean permissionDenied;
public ShortNodeDescriptor(String nodeLtreePath, boolean container, boolean writable, boolean busy, boolean permissionDenied) {
this.nodeLtreePath = nodeLtreePath;
this.container = container;
this.writable = writable;
this.busy = busy;
this.permissionDenied = permissionDenied;
}
public String getDestinationNodeLtreePath() {
return nodeLtreePath;
}
public boolean isContainer() {
return container;
}
public boolean isWritable() {
return writable;
}
public boolean isBusy() {
return busy;
}
public boolean isPermissionDenied() {
return permissionDenied;
}
Sara Bertocco
committed
private class NodePaths {
private final String path;
private final String relativePath;
public NodePaths(String myPath, String myRelativePath) {
Sara Bertocco
committed
this.path = myPath;
public String getRelativePath() {
return this.relativePath;