Sha256: 97a330ab278b662001a03bceee0c27fd12d37960ff7b9391ef2a46e24c85d139

Contents?: true

Size: 606 Bytes

Versions: 56

Compression:

Stored size: 606 Bytes

Contents

module Blazer
  module Adapters
    class DrillAdapter < BaseAdapter
      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

      def drill
        @drill ||= ::Drill.new(url: settings["url"])
      end
    end
  end
end

Version data entries

56 entries across 56 versions & 3 rubygems

Version Path
sql-jarvis-2.1.11 lib/blazer/adapters/drill_adapter.rb
sql-jarvis-2.1.10 lib/blazer/adapters/drill_adapter.rb
sql-jarvis-2.1.9 lib/blazer/adapters/drill_adapter.rb
sql-jarvis-2.1.8 lib/blazer/adapters/drill_adapter.rb
sql-jarvis-2.1.7 lib/blazer/adapters/drill_adapter.rb
sql-jarvis-2.1.6 lib/blazer/adapters/drill_adapter.rb
blazer-2.5.0 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.8 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.7 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.6 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.5 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.4 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.3 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.2 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.1 lib/blazer/adapters/drill_adapter.rb
blazer-2.4.0 lib/blazer/adapters/drill_adapter.rb
blazer-2.3.1 lib/blazer/adapters/drill_adapter.rb
blazer-2.3.0 lib/blazer/adapters/drill_adapter.rb
blazer-2.2.8 lib/blazer/adapters/drill_adapter.rb
blazer-2.2.7 lib/blazer/adapters/drill_adapter.rb