Module: ActiveGraph::Core::Schema

Included in:
Base
Defined in:
lib/active_graph/core/schema.rb

Constant Summary collapse

FILTER = 
{
  3 => [:type, 'node_unique_property'],
  4 => [:uniqueness, 'UNIQUE'],
}

Instance Method Summary collapse

Instance Method Details

#constraints ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/active_graph/core/schema.rb', line 27

def constraints
  if version?('<4.3')
    raw_indexes.select(&method(:filter))
  else
    raw_constraints.select(&method(:constraint_filter))
  end.map { |row| definition(row).merge(type: :uniqueness) }
end

#indexes ⇒ Object 



21
22
23
24
25
 
# File 'lib/active_graph/core/schema.rb', line 21

def indexes
  raw_indexes.map do |row|
    definition(row).merge(type: row[:type].to_sym, state: row[:state].to_sym)
  end
end

#raw_indexes ⇒ Object 



41
42
43
44
45
46
 
# File 'lib/active_graph/core/schema.rb', line 41

def raw_indexes
  read_transaction do
    query(version?('<4.3') ? 'CALL db.indexes()' : 'SHOW INDEXES YIELD *', {}, skip_instrumentation: true)
      .reject { |row| row[:type] == 'LOOKUP' }
  end
end

#version ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/active_graph/core/schema.rb', line 9

def version
  @version ||= read_transaction do
    # BTW: community / enterprise could be retrieved via `result.first.edition`
    query('CALL dbms.components()', {}, skip_instrumentation: true).first[:versions][0]
      .then(&Gem::Version.method(:new))
  end
end

#version?(requirement) ⇒ Boolean

Returns:

  • (Boolean) 


17
18
19
 
# File 'lib/active_graph/core/schema.rb', line 17

def version?(requirement)
  Gem::Requirement.create(requirement).satisfied_by?(Gem::Version.new(version))
end