Module: Legion::Extensions::Neo4j::Runners::Cypher

Includes:
Helpers::Lex, Helpers::Client
Included in:
Client
Defined in:
lib/legion/extensions/neo4j/runners/cypher.rb

Instance Method Summary collapse

Methods included from Helpers::Client

#connection, #execute_cypher

Instance Method Details

#multi_statement(statements, database: 'neo4j', url: nil, username: nil, password: nil) ⇒ Object

Raises:



26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/legion/extensions/neo4j/runners/cypher.rb', line 26

def multi_statement(statements, database: 'neo4j', url: nil, username: nil, password: nil, **)
  payload = {
    statements: statements.map do |s|
      if s.is_a?(String)
        { statement: s, parameters: {} }
      else
        { statement: s[:statement], parameters: s[:parameters] || {} }
      end
    end
  }
  resp = connection(url: url, username: username, password: password)
         .post("/db/#{database}/tx/commit", payload)
  body = resp.body
  raise CypherError, body[:errors].map { |e| e['message'] }.join('; ') if body.is_a?(Hash) && body[:errors] && !body[:errors].empty?

  body
end

#query(statement, parameters: {}, database: 'neo4j', url: nil, username: nil, password: nil) ⇒ Object 



12
13
14
15
 
# File 'lib/legion/extensions/neo4j/runners/cypher.rb', line 12

def query(statement, parameters: {}, database: 'neo4j', url: nil, username: nil, password: nil, **)
  execute_cypher(statement, parameters: parameters, database: database,
                           url: url, username: username, password: password)
end

#query_single(statement, parameters: {}, database: 'neo4j', url: nil, username: nil, password: nil) ⇒ Object 



17
18
19
20
21
22
23
24
 
# File 'lib/legion/extensions/neo4j/runners/cypher.rb', line 17

def query_single(statement, parameters: {}, database: 'neo4j', url: nil, username: nil, password: nil, **)
  result = execute_cypher(statement, parameters: parameters, database: database,
                                    url: url, username: username, password: password)
  results = result.dig('results', 0, 'data')
  return nil if results.nil? || results.empty?

  results.first
end