Module: ApacheAge::Entities::Edge

Extended by:
ActiveSupport::Concern
Included in:
ApacheAge::Edge
Defined in:
lib/apache_age/entities/edge.rb

Instance Method Summary collapse

Instance Method Details

#age_type ⇒ Object 



36
 
# File 'lib/apache_age/entities/edge.rb', line 36

def age_type = 'edge'

#create_sql ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/apache_age/entities/edge.rb', line 50

def create_sql
  self.start_node = start_node.save unless start_node.persisted?
  self.end_node = end_node.save unless end_node.persisted?

  start_node_age_label = ActiveRecord::Base.sanitize_sql(start_node.age_label)
  end_node_age_label = ActiveRecord::Base.sanitize_sql(end_node.age_label)
  sanitized_start_id = ActiveRecord::Base.sanitize_sql(["?", start_node.id])
  sanitized_end_id = ActiveRecord::Base.sanitize_sql(["?", end_node.id])
  # cant use sanitize_sql_like because it escapes the % and _ characters
  # label_name = ActiveRecord::Base.sanitize_sql_like(age_label)

  reject_keys = i[id start_id end_id start_node end_node]
  sanitized_properties =
    self.to_h.reject { |k, _v| reject_keys.include?(k) }.reject { |_k, v| v.nil? }
      .map { |k, v| "#{k}: #{ActiveRecord::Base.sanitize_sql(["?", v])}" }
      .join(', ')
  "    SELECT *\n    FROM cypher('\#{age_graph}', $$\n        MATCH (from_node:\#{start_node_age_label}), (to_node:\#{end_node_age_label})\n        WHERE id(from_node) = \#{sanitized_start_id} AND id(to_node) = \#{sanitized_end_id}\n        CREATE (from_node)-[edge:\#{age_label} {\#{sanitized_properties}}]->(to_node)\n        RETURN edge\n    $$) as (edge agtype);\n  SQL\nend\n"

#end_class ⇒ Object 



37
 
# File 'lib/apache_age/entities/edge.rb', line 37

def end_class = end_node.class

#end_node_class ⇒ Object 



39
 
# File 'lib/apache_age/entities/edge.rb', line 39

def end_node_class = end_node.class

#initialize(**attributes) ⇒ Object 



28
29
30
31
32
33
34
 
# File 'lib/apache_age/entities/edge.rb', line 28

def initialize(**attributes)
  super
  self.end_id ||= end_node.id if end_node
  self.start_id ||= start_node.id if start_node
  self.end_node ||= Entity.find(end_id) if end_id
  self.start_node ||= Entity.find(start_id) if start_id
end

#start_class ⇒ Object 



38
 
# File 'lib/apache_age/entities/edge.rb', line 38

def start_class = start_node.class

#start_node_class ⇒ Object 



40
 
# File 'lib/apache_age/entities/edge.rb', line 40

def start_node_class = start_node.class

#update_sql ⇒ Object

So far just properties of string type with '' around them



78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/apache_age/entities/edge.rb', line 78

def update_sql
  alias_name = age_alias || age_label.downcase
  set_clause =
    age_properties.map do |k, v|
      if v
        sanitized_value = ActiveRecord::Base.sanitize_sql(["?", v])
        "#{alias_name}.#{k} = #{sanitized_value}"
      else
        "#{alias_name}.#{k} = NULL"
      end
    end.join(', ')

  sanitized_id = ActiveRecord::Base.sanitize_sql(["?", id])

  "    SELECT *\n    FROM cypher('\#{age_graph}', $$\n        MATCH ()-[\#{alias_name}:\#{age_label}]->()\n        WHERE id(\#{alias_name}) = \#{sanitized_id}\n        SET \#{set_clause}\n        RETURN \#{alias_name}\n    $$) as (\#{age_label} agtype);\n  SQL\nend\n"

#validate_nodes ⇒ Object

Custom validation method to validate start_node and end_node



45
46
47
48
 
# File 'lib/apache_age/entities/edge.rb', line 45

def validate_nodes
  errors.add(:start_node, 'invalid') if start_node && !start_node.valid?
  errors.add(:end_node, 'invalid') if end_node && !end_node.valid?
end