Class: Twb::Util::Cypher

Inherits:
Object
  • Object
show all
Includes:
TabTool
Defined in:
lib/twb/util/cypher.rb

Constant Summary collapse

@@hasher = 
Digest::SHA256.new

Instance Attribute Summary collapse

Attributes included from TabTool

#alerts, #docDir, #docfiles, #funcdoc, #id, #licensed, #logfilename, #logger, #loglevel, #metrics, #properties, #ttdocdir, #type, #uuid

Instance Method Summary collapse

Methods included from TabTool

#addDocFile, #alert, #closeDocFiles, #config, #docFile, #docFileMaxNameLen, #docfilesdoc, #docfilesdocto_s, #emit, #emitCSV, #finis, #hasConfig, #init, #initCSV, #initDocDir, #initLogger, #license=, #licensed?, #loadConfig

Constructor Details

#initialize ⇒ Cypher

Returns a new instance of Cypher.



32
33
34
35
36
37
38
39
 
# File 'lib/twb/util/cypher.rb', line 32

def initialize
  emit "Cypher.initialize"
  @fileName  = 'Neo4jCommands'
  @mode      = :create
  @nodes     = []
  @edges     = []
  @cleanup   = false
end

Instance Attribute Details

#cleanup ⇒ Object

Returns the value of attribute cleanup.



30
31
32
 
# File 'lib/twb/util/cypher.rb', line 30

def cleanup
  @cleanup
end

#edges ⇒ Object 



29
30
31
 
# File 'lib/twb/util/cypher.rb', line 29

def edges
  @edges
end

#fileName ⇒ Object 



29
30
31
 
# File 'lib/twb/util/cypher.rb', line 29

def fileName
  @fileName
end

#mode ⇒ Object 



29
30
31
 
# File 'lib/twb/util/cypher.rb', line 29

def mode
  @mode
end

#nodes ⇒ Object 



29
30
31
 
# File 'lib/twb/util/cypher.rb', line 29

def nodes
  @nodes
end

Instance Method Details

#encode(node, terminator = '') ⇒ Object 



99
100
101
102
103
104
105
 
# File 'lib/twb/util/cypher.rb', line 99

def encode node, terminator=''
  puts "def encode node: #{node}  "
  case @mode
  when :merge  then "MERGE (%s:%s { name:'%s', uuid: '%s' } ) %s" % [node.uuid, varName, node.type, node.name, terminator ]
  when :create then "CREATE (#{node.uuid}:#{node.type} {} )"
  end
end

#encodeEdge(command, varName, node, terminator = '') ⇒ Object 



107
108
109
 
# File 'lib/twb/util/cypher.rb', line 107

def encodeEdge command, varName, node, terminator=''
  "%-8s (%s:%s { uuid: '%s' } ) %s" % [command, varName, node.type, node.uuid, terminator ]
end

#render ⇒ Object 



41
42
43
44
45
46
47
48
 
# File 'lib/twb/util/cypher.rb', line 41

def render
  puts "Cypher.render"
  @file = File.open(docFile("#{@fileName}.cypher"),'w')
  renderNodes
  renderEdges
  @file.close
  return @file
end

#renderEdges ⇒ Object

USING PERIODIC COMMIT LOAD CSV WITH HEADERS FROM “file:://C:/tech/Tableau/Tableau Tools/Ruby/experiments/GraphElements.nodes.csv” AS row CREATE (:row.Type row.Name, uuid: row.UUID);



84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/twb/util/cypher.rb', line 84

def renderEdges
  csv = CSV.open("./ttdoc/#{@fileName}.edges.csv",'w')
  csv << ['Source Type' , 'Source Name'  , 'Source UUID'  , 'Relationship', 'Target Type', 'Target Name', 'Target UUID' ]
  @edges.each do |edge|
    relationship = edge.relationship.upcase.gsub(/[ ]+/,'_')
    csv << [edge.from.type,  edge.from.name,  edge.from.uuid,  relationship ,  edge.to.type , edge.to.name,  edge.to.uuid ]
    @file.puts ' '
    @file.puts encodeEdge('MATCH', 'source', edge.from)
    @file.puts encodeEdge('MATCH', 'target', edge.to)
    @file.puts "%-8s (source)-[r:%s]->(target) " % ['MERGE', edge.relationship.upcase.gsub(/[ ]+/,'_')]
    @file.puts "RETURN source.name, type(r), target.name ;"
  end
  csv.close
end

#renderNodes ⇒ 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
76
77
78
79
 
# File 'lib/twb/util/cypher.rb', line 50

def renderNodes
  puts "Cypher def renderNodes @nodes:#{@nodes.to_s}"
  csv = CSV.open(docFile("#{@fileName}.nodes.csv"),'w')
  csv << ['Type','Name','UUID']
  nodesCSV = Set.new
  nodeCmds = SortedSet.new
  nodesByType = Hash.new { |type,nodes| type[nodes] = [] }
  @nodes.each do |node|
    nodesCSV << [node.type, node.name, node.uuid]
    nodeCmds << encode(node,';')
    nodesByType[node.type] << node
  end
  if @cleanup
    nodesByType.keys.each do |type|
      @file.puts "DROP   CONSTRAINT ON (node:#{type}) ASSERT node.uuid IS UNIQUE ;"
    end
    @file.puts "MATCH (n) DETACH DELETE n ;"
    nodesByType.keys.each do |type|
      @file.puts "CREATE CONSTRAINT ON (node:#{type}) ASSERT node.uuid IS UNIQUE ;"
    end
    @file.puts "//--"
  end
  nodesCSV.each do |rec|
    csv << rec
  end
  nodeCmds.each do |cmd|
    @file.puts cmd
  end
  csv.close
end

#to_s ⇒ Object 



111
112
113
 
# File 'lib/twb/util/cypher.rb', line 111

def to_s
  "file:#{@fileName}; #nodes:#{@nodes.length}; #edges:#{@edges.length}"
end