Module: Neo4j::ActiveNode::Query::QueryProxyMethodsOfMassUpdating
- Included in:
- QueryProxy
- Defined in:
- lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb
Instance Method Summary collapse
-
#delete(node) ⇒ Object
Deletes the relationship between a node and its last link in the QueryProxy chain.
-
#delete_all(identifier = nil) ⇒ Object
Deletes a group of nodes and relationships within a QP chain.
-
#delete_all_rels ⇒ Object
Deletes the relationships between all nodes for the last step in the QueryProxy chain.
-
#destroy(node) ⇒ Object
Returns all relationships between a node and its last link in the QueryProxy chain, destroys them in Ruby.
-
#replace_with(node_or_nodes) ⇒ Object
Deletes the relationships between all nodes for the last step in the QueryProxy chain and replaces them with relationships to the given nodes.
-
#update_all(updates, params = {}) ⇒ Object
Updates some attributes of a group of nodes within a QP chain.
-
#update_all_rels(updates, params = {}) ⇒ Object
Updates some attributes of a group of relationships within a QP chain.
Instance Method Details
#delete(node) ⇒ Object
Deletes the relationship between a node and its last link in the QueryProxy chain. Executed in the database, callbacks will not run.
38 39 40 41 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 38 def delete(node) self.match_to(node).query.delete(rel_var).exec clear_source_object_cache end |
#delete_all(identifier = nil) ⇒ Object
Deletes a group of nodes and relationships within a QP chain. When identifier is omitted, it will remove the last link in the chain. The optional argument must be a node identifier. A relationship identifier will result in a Cypher Error
26 27 28 29 30 31 32 33 34 35 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 26 def delete_all(identifier = nil) query_with_target(identifier) do |target| begin self.query.with(target).optional_match("(#{target})-[#{target}_rel]-()").delete("#{target}, #{target}_rel").exec rescue Neo4j::Core::CypherSession::CypherError # <=- Seems hacky self.query.delete(target).exec end clear_source_object_cache end end |
#delete_all_rels ⇒ Object
Deletes the relationships between all nodes for the last step in the QueryProxy chain. Executed in the database, callbacks will not be run.
44 45 46 47 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 44 def delete_all_rels return unless start_object && start_object._persisted_obj self.query.delete(rel_var).exec end |
#destroy(node) ⇒ Object
Returns all relationships between a node and its last link in the QueryProxy chain, destroys them in Ruby. Callbacks will be run.
62 63 64 65 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 62 def destroy(node) self.rels_to(node).map!(&:destroy) clear_source_object_cache end |
#replace_with(node_or_nodes) ⇒ Object
Deletes the relationships between all nodes for the last step in the QueryProxy chain and replaces them with relationships to the given nodes. Executed in the database, callbacks will not be run.
51 52 53 54 55 56 57 58 59 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 51 def replace_with(node_or_nodes) nodes = Array(node_or_nodes) self.delete_all_rels nodes.map do |node| node if _create_relation_or_defer(node) end.compact # nodes.each { |node| self << node } end |
#update_all(updates, params = {}) ⇒ Object
Updates some attributes of a group of nodes within a QP chain. The optional argument makes sense only of ‘updates` is a string.
9 10 11 12 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 9 def update_all(updates, params = {}) # Move this to ActiveNode module? update_all_with_query(identity, updates, params) end |
#update_all_rels(updates, params = {}) ⇒ Object
Updates some attributes of a group of relationships within a QP chain. The optional argument makes sense only of ‘updates` is a string.
18 19 20 21 |
# File 'lib/neo4j/active_node/query/query_proxy_methods_of_mass_updating.rb', line 18 def update_all_rels(updates, params = {}) fail 'Cannot update rels without a relationship variable.' unless @rel_var update_all_with_query(@rel_var, updates, params) end |