Sha256: 7e96bd6bed236eb03197ca5652532d2ae88aadceedf89b13d333ebf383ff34e7
Contents?: true
Size: 1.67 KB
Versions: 8
Compression:
Stored size: 1.67 KB
Contents
module ActiveGraph module Core module Schema def version read_transaction do # BTW: community / enterprise could be retrieved via `result.first.edition` query('CALL dbms.components()', {}, skip_instrumentation: true).first[:versions][0] end end def indexes raw_indexes do |keys, result| result.map do |row| { type: row[:type].to_sym, label: label(keys, row), properties: properties(row), state: row[:state].to_sym } end end end def constraints raw_indexes do |keys, result| result.select(&method(v4?(keys) ? :v4_filter : :v3_filter)).map do |row| { type: :uniqueness, label: label(keys, row), properties: properties(row) } end end end def raw_indexes read_transaction do result = query('CALL db.indexes()', {}, skip_instrumentation: true) yield result.keys, result.reject { |row| row[:type] == 'LOOKUP' } end end private def v4_filter(row) row[:uniqueness] == 'UNIQUE' end def v3_filter(row) row[:type] == 'node_unique_property' end def label(keys, row) if v34?(keys) row[:label] else (v4?(keys) ? row[:labelsOrTypes] : row[:tokenNames]).first end.to_sym end def v4?(keys) return @v4 unless @v4.nil? @v4 = keys.include?(:labelsOrTypes) end def v34?(keys) return @v34 unless @v34.nil? @v34 = keys.include?(:label) end def properties(row) row[:properties].map(&:to_sym) end end end end
Version data entries
8 entries across 8 versions & 1 rubygems