Commit c37508f1 authored by Sonia Zorba's avatar Sonia Zorba
Browse files

Removed SELECT FOR UPDATE clauses

parent 6a784be3

src/main/java/it/inaf/oats/vospace/persistence/NodeDAO.java

+3 −4
Original line number Diff line number Diff line
@@ -232,7 +232,7 @@ public class NodeDAO { 
    }



    public Optional<Long> getNodeId(String nodeVosPath) {

        String sql = "SELECT node_id FROM node_vos_path WHERE vos_path = ? FOR UPDATE";

        String sql = "SELECT node_id FROM node_vos_path WHERE vos_path = ?";



        List<Long> nodeIdList = jdbcTemplate.query(conn -> {

            PreparedStatement ps = conn.prepareStatement(sql);
@@ -260,8 +260,7 @@ public class NodeDAO { 
                + "FROM node n\n"

                + "JOIN node_vos_path os ON n.node_id = os.node_id\n"

                + "JOIN location loc ON n.location_id = loc.location_id\n"

                + "WHERE n.node_id = ?\n"

                + "FOR UPDATE";

                + "WHERE n.node_id = ?";



        List<Node> result = jdbcTemplate.query(conn -> {

            PreparedStatement ps = conn.prepareStatement(sql);
@@ -296,7 +295,7 @@ public class NodeDAO { 
                + "JOIN node_vos_path os ON n.node_id = os.node_id\n"

                + "JOIN location loc ON n.location_id = loc.location_id\n"

                + "WHERE n.path ~ ('*.' || ? || '.*')::lquery\n"

                + "ORDER BY n.path FOR UPDATE";

                + "ORDER BY n.path";



        List<Node> result = jdbcTemplate.query(conn -> {

            PreparedStatement ps = conn.prepareStatement(sql);