class Blazer::Adapters::DrillAdapter

Public Instance Methods

run_statement(statement, comment) click to toggle source
# File lib/blazer/adapters/drill_adapter.rb, line 4
def run_statement(statement, comment)
  columns = []
  rows = []
  error = nil

  begin
    # remove trailing semicolon
    response = drill.query(statement.sub(/;\s*\z/, ""))
    rows = response.map { |r| r.values }
    columns = rows.any? ? response.first.keys : []
  rescue => e
    error = e.message
  end

  [columns, rows, error]
end

Private Instance Methods

drill() click to toggle source
# File lib/blazer/adapters/drill_adapter.rb, line 23
def drill
  @drill ||= ::Drill.new(url: settings["url"])
end