Module: Arango::Database::AQLQueries

Included in:
Arango::Database
Defined in:
lib/arango/database/aql_queries.rb

Instance Method Summary collapse

Instance Method Details

#batch_execute_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/arango/database/aql_queries.rb', line 54

def batch_execute_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
                      intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
                      max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
                      skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  aql = Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                        fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                        intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                        max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                        satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                        block: block, &ruby_block)
  aql.batch_execute
end

#batch_execute_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/arango/database/aql_queries.rb', line 67

def batch_execute_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
                      intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
                      max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
                      skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  aql = Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                        fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                        intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                        max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                        satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                        block: block, &ruby_block)
  aql.batch_execute
end

#clear_slow_queries_list ⇒ Object 



100
101
102
103
 
# File 'lib/arango/database/aql_queries.rb', line 100

def clear_slow_queries_list
  result = Arango::Requests::AQL::DeleteSlowQueryList.execute(server: @server)
  true
end

#execute_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/arango/database/aql_queries.rb', line 28

def execute_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
                intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
                max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
                skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  aql = Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                        fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                        intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                        max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                        satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                        block: block, &ruby_block)
  aql.execute
end

#execute_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/arango/database/aql_queries.rb', line 41

def execute_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
                  intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
                  max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
                  skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  aql = Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                        fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                        intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                        max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                        satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                        block: block, &ruby_block)
  aql.execute
end

#kill_query(aql_id) ⇒ Object 



105
106
107
108
109
110
111
 
# File 'lib/arango/database/aql_queries.rb', line 105

def kill_query(aql_id)
  id = if id.class == String then id
       elsif id.class == Arango::AQL then id.id
       end
  result = Arango::Requests::AQL::KillQuery.execute(server: @server, args: {id: id})
  true
end

#new_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
 
# File 'lib/arango/database/aql_queries.rb', line 4

def new_aql(query:, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
            intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
            max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
            skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                  fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                  intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                  max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                  satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                  block: block, &ruby_block)
end

#new_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil, intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil, max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil, skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/arango/database/aql_queries.rb', line 16

def new_query(query, batch_size: nil, bind_vars: nil, cache: nil, count: nil, fail_on_warning: nil, full_count: nil,
              intermediate_commit_count: nil, intermediate_commit_size: nil, max_plans: nil, max_transaction_size: nil,
              max_warning_count: nil, memory_limit: nil, optimizer_rules: nil, profile: nil, satellite_sync_wait: nil,
              skip_inaccessible_collections: nil, ttl: nil, block: nil, &ruby_block)
  Arango::AQL.new(database: self, query: query, batch_size: batch_size, bind_vars: bind_vars, cache: cache, count: count,
                  fail_on_warning: fail_on_warning, full_count: full_count, intermediate_commit_count: intermediate_commit_count,
                  intermediate_commit_size: intermediate_commit_size, max_plans: max_plans, max_transaction_size: max_transaction_size,
                  max_warning_count: max_warning_count, memory_limit: memory_limit, optimizer_rules: optimizer_rules, profile: profile,
                  satellite_sync_wait: satellite_sync_wait, skip_inaccessible_collections: skip_inaccessible_collections, ttl: ttl,
                  block: block, &ruby_block)
end

#query_tracking_properties ⇒ Object 



80
81
82
 
# File 'lib/arango/database/aql_queries.rb', line 80

def query_tracking_properties
  Arango::Requests::AQL::GetQueryTrackingProperties.execute(server: @server)
end

#running_queries ⇒ Object 



90
91
92
93
 
# File 'lib/arango/database/aql_queries.rb', line 90

def running_queries
  result = Arango::Requests::AQL::CurrentQueries.execute(server: @server)
  result.map { |query_hash| Arango::AQL.from_result(query_hash) }
end

#set_query_tracking_properties(props) ⇒ Object 



84
85
86
87
88
 
# File 'lib/arango/database/aql_queries.rb', line 84

def set_query_tracking_properties(props)
  body = props.to_h
  body.transform_keys! { |k| k.to_s.camelize(:lower).to_sym }
  Arango::Requests::AQL::SetQueryTrackingProperties.execute(server: @server, body: props.to_h)
end

#slow_queries ⇒ Object 



95
96
97
98
 
# File 'lib/arango/database/aql_queries.rb', line 95

def slow_queries
  result = Arango::Requests::AQL::GetSlowQueryList.execute(server: @server)
  result.map { |query_hash| Arango::AQL.from_result(query_hash) }
end